Azure Cosmos DB

Read a value from an Azure Cosmos DB document (SQL / Core API).


Scheme	`cosmos://`
Module	`github.com/xavidop/mamori/providers/cosmos`
Sensitive	no (opt-in with `WithSensitive`)
Watch	poll (ETag)
Auth	`DefaultAzureCredential` + endpoint, or a connection string

Install

go get github.com/xavidop/mamori/providers/cosmos

import _ "github.com/xavidop/mamori/providers/cosmos"

Using the ref

A cosmos:// ref points at one item (document) in a container, read by its id and partition key.

cosmos://<database>/<container>/<id>[#field][?pk=<partition-key>]

Part	Required	What it means
`<database>`	yes	The Cosmos database name.
`<container>`	yes	The container within that database.
`<id>`	yes	The item’s `id`.
`#field`	no	Return one field of the document instead of the whole thing (JSON selection).
`?pk=`	no	The partition-key value. Defaults to `<id>` (common when the id is the partition key).

Examples

cosmos://appdb/config/service-a reads the document with id service-a (partition key service-a) and returns it as JSON.
cosmos://appdb/config/service-a#endpoint returns just the endpoint field of that document.
cosmos://appdb/tenants/acme?pk=us-east reads id acme in the us-east logical partition.

Value.Version is the document’s _etag, so change detection is cheap. Wrap a field in secret.String (or set WithSensitive) if the document holds credentials.

Watch

Cosmos DB’s change feed is pull-based, so mamori polls (WithPollInterval + jitter) using the ETag. The change feed can drive an on-demand reload in your app for push.

Configuration

import cosmosprov "github.com/xavidop/mamori/providers/cosmos"

// AAD credential + account endpoint
mamori.WithProvider(cosmosprov.New(cosmosprov.WithEndpoint("https://myacct.documents.azure.com:443/")))
// or a connection string
mamori.WithProvider(cosmosprov.New(cosmosprov.WithConnectionString(os.Getenv("COSMOS_CONNECTION_STRING"))))

Verified with an in-memory fake; live behavior is covered by //go:build integration tests.