Documentation
¶
Index ¶
- type CosmosItem
- type CosmosItemWithRawMessage
- type StateStore
- func (c *StateStore) BulkDelete(req []state.DeleteRequest) error
- func (c *StateStore) BulkSet(req []state.SetRequest) error
- func (c *StateStore) Delete(req *state.DeleteRequest) error
- func (c *StateStore) Get(req *state.GetRequest) (*state.GetResponse, error)
- func (c *StateStore) Init(metadata state.Metadata) error
- func (c *StateStore) Multi(request *state.TransactionalStateRequest) error
- func (c *StateStore) Set(req *state.SetRequest) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type CosmosItem ¶
type CosmosItem struct {
documentdb.Document
ID string `json:"id"`
Value interface{} `json:"value"`
PartitionKey string `json:"partitionKey"`
}
CosmosItem is a wrapper around a CosmosDB document
type CosmosItemWithRawMessage ¶ added in v0.2.1
type CosmosItemWithRawMessage struct {
documentdb.Document
ID string `json:"id"`
Value jsoniter.RawMessage `json:"value"`
PartitionKey string `json:"partitionKey"`
}
CosmosItemWithRawMessage is a version of CosmosItem with a Value of RawMessage so this field is not marshalled. If it is marshalled it will end up in a form that cannot be unmarshalled. This type is used when SetRequest.Value arrives as bytes.
type StateStore ¶
type StateStore struct {
// contains filtered or unexported fields
}
StateStore is a CosmosDB state store
func NewCosmosDBStateStore ¶
func NewCosmosDBStateStore(logger logger.Logger) *StateStore
NewCosmosDBStateStore returns a new CosmosDB state store
func (*StateStore) BulkDelete ¶
func (c *StateStore) BulkDelete(req []state.DeleteRequest) error
BulkDelete performs a bulk delete operation
func (*StateStore) BulkSet ¶
func (c *StateStore) BulkSet(req []state.SetRequest) error
BulkSet performs a bulk set operation
func (*StateStore) Delete ¶
func (c *StateStore) Delete(req *state.DeleteRequest) error
Delete performs a delete operation
func (*StateStore) Get ¶
func (c *StateStore) Get(req *state.GetRequest) (*state.GetResponse, error)
Get retrieves a CosmosDB item
func (*StateStore) Init ¶
func (c *StateStore) Init(metadata state.Metadata) error
Init does metadata and connection parsing
func (*StateStore) Multi ¶ added in v0.2.0
func (c *StateStore) Multi(request *state.TransactionalStateRequest) error
Multi performs a transactional operation. succeeds only if all operations succeed, and fails if one or more operations fail
func (*StateStore) Set ¶
func (c *StateStore) Set(req *state.SetRequest) error
Set saves a CosmosDB item
Source Files