c69d5ea2ca
* Add Metadata to transactional request * Use new transactional request strcut |
||
|---|---|---|
| .. | ||
| aerospike | ||
| aws/dynamodb | ||
| azure | ||
| cassandra | ||
| cloudstate | ||
| couchbase | ||
| etcd | ||
| gcp/firestore | ||
| hashicorp/consul | ||
| hazelcast | ||
| memcached | ||
| mongodb | ||
| postgresql | ||
| redis | ||
| sqlserver | ||
| zookeeper | ||
| Readme.md | ||
| metadata.go | ||
| request_options.go | ||
| request_options_test.go | ||
| requests.go | ||
| responses.go | ||
| store.go | ||
| transactional_store.go | ||
Readme.md
State Stores
State Stores provide a common way to interact with different data store implementations, and allow users to opt-in to advanced capabilities using defined metadata.
Currently supported state stores are:
- AWS DynamoDB
- Azure CosmosDB
- Azure Table Storage
- Cassandra
- Cloud Firestore (Datastore mode)
- CloudState
- Couchbase
- Etcd
- HashiCorp Consul
- Hazelcast
- Memcached
- MongoDB
- Redis
- SQL Server
- Zookeeper
- Cloud Firestore (Datastore mode)
- Couchbase
Implementing a new State Store
A compliant state store needs to implement one or more interfaces: Store and TransactionalStore.
The interface for Store:
type Store interface {
Init(metadata Metadata) error
Delete(req *DeleteRequest) error
BulkDelete(req []DeleteRequest) error
Get(req *GetRequest) (*GetResponse, error)
Set(req *SetRequest) error
BulkSet(req []SetRequest) error
}
The interface for TransactionalStore:
type TransactionalStore interface {
Init(metadata Metadata) error
Multi(reqs []TransactionalRequest) error
}
See the documentation repo for examples.