Crate cosmos_utils

Structs

CosmosErrorStruct

CosmosSaga

CosmosState

This struct keeps the static state of cosmos DB, it must be initialized before any cosmos functions are called.

PartitionKeys

A collection of keys to partition on

Enums

CosmosErrorKind

ModifyReturn

RetryLoopError

Functions

delete

get

Returns a specific document from the cosmos DB together with a corresponding etag

get_blob

Gets the data from a blob storage

insert

Insert a document into the cosmos database and returning an etag from the response if successful

maybe_modify

Modifies a document in cosmos by applying transform closure on the existing document and either inserting the returned value or just returning it to the caller

modify

Modifies a document in cosmos by applying transform closure on the existing document and then inserting the returned document and returning the transformed document if successful If the transform closure fails then no insertion is performed and the error it fails with is returned

modify_async

Modifies a document in cosmos by applying transform async closure on the existing document and then inserting the returned document and returning the transformed document if successful If the transform closure fails then no insertion is performed and the error it fails with is returned

modify_async_get_old

Modifies a document in cosmos by applying transform async closure on the existing document and then inserting the returned document and returning both the transformed document, the old document and the etag if successful. If the transform closure fails then no insertion is performed and the error it fails with is returned

modify_no_retry

Modify in cosmos but does not retry on failure which is useful when one needs to pass in a FnOnce closure

query

query_crosspartition

query_crosspartition_etag

retry_loop

set_state

upload_blob

Uploads form data to the blob storage and returns the blob id

upload_image

Uploads a new form data image to the blob storage and returns the image_id

upsert

Upsert a document into the cosmos database and returning an etag from the response if successful