aerospike

package

v1.0.0-rc.3 Latest Latest Go to latest Published: Jan 26, 2021 License: MIT Imports: 10 Imported by: 3

Details

This section is empty.

This section is empty.

func NewAerospikeStateStore(logger logger.Logger) state.Store

NewAerospikeStateStore returns a new Aerospike state store

type Aerospike struct {
	state.DefaultBulkStore
	// contains filtered or unexported fields
}

Aerospike is a state store

func (aspike *Aerospike) Delete(req *state.DeleteRequest) error

Delete performs a delete operation

func (aspike *Aerospike) Get(req *state.GetRequest) (*state.GetResponse, error)

Get retrieves state from Aerospike with a key

func (aspike *Aerospike) Init(metadata state.Metadata) error

Init does metadata and connection parsing

func (aspike *Aerospike) Set(req *state.SetRequest) error

Set stores value for a key to Aerospike. It honors ETag (for concurrency) and consistency settings