Documentation
¶
Overview ¶
Package cosmosdb provides an in-memory mock implementation of Azure Cosmos DB.
Index ¶
- Constants
- type Mock
- func (m *Mock) BatchGetItems(_ context.Context, table string, keys []map[string]any) ([]map[string]any, error)
- func (m *Mock) BatchPutItems(_ context.Context, table string, items []map[string]any) error
- func (m *Mock) CreateTable(_ context.Context, cfg driver.TableConfig) error
- func (m *Mock) DeleteItem(_ context.Context, table string, key map[string]any) error
- func (m *Mock) DeleteTable(_ context.Context, name string) error
- func (m *Mock) DescribeTTL(_ context.Context, table string) (*driver.TTLConfig, error)
- func (m *Mock) DescribeTable(_ context.Context, name string) (*driver.TableConfig, error)
- func (m *Mock) GetItem(_ context.Context, table string, key map[string]any) (map[string]any, error)
- func (m *Mock) GetStreamRecords(_ context.Context, table string, limit int, token string) (*driver.StreamIterator, error)
- func (m *Mock) ListTables(_ context.Context) ([]string, error)
- func (m *Mock) PutItem(_ context.Context, table string, item map[string]any) error
- func (m *Mock) Query(_ context.Context, input driver.QueryInput) (*driver.QueryResult, error)
- func (m *Mock) Scan(_ context.Context, input driver.ScanInput) (*driver.QueryResult, error)
- func (m *Mock) SetMonitoring(mon mondriver.Monitoring)
- func (m *Mock) TransactWriteItems(_ context.Context, table string, puts []map[string]any, ...) error
- func (m *Mock) UpdateItem(_ context.Context, input driver.UpdateItemInput) (map[string]any, error)
- func (m *Mock) UpdateStreamConfig(_ context.Context, table string, cfg driver.StreamConfig) error
- func (m *Mock) UpdateTTL(_ context.Context, table string, cfg driver.TTLConfig) error
Constants ¶
const ( OpEqual = "=" OpNotEqual = "!=" OpLessThan = "<" OpGreaterThan = ">" OpLessEqual = "<=" OpGreaterEqual = ">=" OpContains = "CONTAINS" OpBeginsWith = "BEGINS_WITH" OpBetween = "BETWEEN" )
Scan/query filter operator constants.
const ( ViewNewImage = "NEW_IMAGE" ViewOldImage = "OLD_IMAGE" ViewNewAndOld = "NEW_AND_OLD_IMAGES" ViewKeysOnly = "KEYS_ONLY" )
Change feed and TTL constants.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Mock ¶
type Mock struct {
// contains filtered or unexported fields
}
Mock is an in-memory mock implementation of Azure Cosmos DB.
func (*Mock) BatchGetItems ¶
func (m *Mock) BatchGetItems(_ context.Context, table string, keys []map[string]any) ([]map[string]any, error)
BatchGetItems retrieves multiple items from a container by keys.
func (*Mock) BatchPutItems ¶
BatchPutItems stores multiple items in a container.
func (*Mock) CreateTable ¶
CreateTable creates a new container (table) in Cosmos DB.
func (*Mock) DeleteItem ¶
DeleteItem deletes an item from a container by key.
func (*Mock) DeleteTable ¶
DeleteTable deletes a container (table) from Cosmos DB.
func (*Mock) DescribeTTL ¶ added in v1.2.0
DescribeTTL returns the TTL configuration for a container.
func (*Mock) DescribeTable ¶
DescribeTable returns the configuration of a container (table).
func (*Mock) GetStreamRecords ¶ added in v1.2.0
func (m *Mock) GetStreamRecords( _ context.Context, table string, limit int, token string, ) (*driver.StreamIterator, error)
GetStreamRecords returns change feed records after the given token.
func (*Mock) ListTables ¶
ListTables lists all containers (tables) in Cosmos DB.
func (*Mock) Query ¶
func (m *Mock) Query(_ context.Context, input driver.QueryInput) (*driver.QueryResult, error)
Query executes a query against a container.
func (*Mock) SetMonitoring ¶ added in v1.2.0
func (m *Mock) SetMonitoring(mon mondriver.Monitoring)
SetMonitoring sets the monitoring backend for auto-metric generation.
func (*Mock) TransactWriteItems ¶ added in v1.2.0
func (m *Mock) TransactWriteItems( _ context.Context, table string, puts []map[string]any, deletes []map[string]any, ) error
TransactWriteItems executes puts and deletes atomically.
func (*Mock) UpdateItem ¶ added in v1.3.1
UpdateItem applies partial updates to an existing document in a container.
func (*Mock) UpdateStreamConfig ¶ added in v1.2.0
UpdateStreamConfig configures the change feed for a container.
Source Files