kvstore

type DeleteCallback func(context.Context, string) error

type GetCallback func(context.Context, string, ...GetOpt) ([]*Record, error)

type GetOpt interface{}

type KVStore interface {
	component.Component
	// Init initializes the store with the given options
	Init(opts ...Option) error
	// Put the value for the key
	Put(ctx context.Context, record *Record, opts ...SetOpt) (*Record, error)
	// Get the value for the key
	Get(ctx context.Context, key string, opts ...GetOpt) ([]*Record, error)
	// Delete the key from the store
	Delete(ctx context.Context, key string) error
	// Txn handles transactions
	Txn(ctx context.Context, handler TxnHandler) error
	// Subscribe to the changes made to the given key
	Subscribe(ctx context.Context, key string, handler SubscribeHandler, opts ...SubscribeOpt) error
	// Unsubscribe from a subscription
	Unsubscribe(ctx context.Context, key string) error
	// String returns the name of the store implementation
	String() string
}

type Option interface{}

type PutCallback func(context.Context, *Record, ...SetOpt) (*Record, error)

type Record struct {
	// Key to store the record
	Key string `json:"key"`
	// Value for the key set in the store
	Value []byte `json:"value"`
	// Expiry is the time to expire a record
	Expiry time.Duration `json:"expiry,omitempty"`
	// Metadata is the metadata of the record
	Metadata map[string]interface{} `json:"metadata"`
}

type SetOpt interface{}

type SubscribeCallback func(context.Context, string, SubscribeHandler) error

type SubscribeHandler interface {
	// Handle the subscription for the given key
	Handle(ctx context.Context, key string, args ...interface{}) error
}

type SubscribeOpt interface{}

type Trace struct {
	// contains filtered or unexported fields
}

type TxnCallback func(context.Context, TxnHandler) error

type TxnHandler interface {
	// Handle the transaction
	Handle(ctx context.Context, store KVStore) error
}

type Wrapper struct {
	// contains filtered or unexported fields
}