Documentation
¶
Index ¶
- func NewJetstreamStateStore(logger logger.Logger) state.Store
- type StateStore
- func (js *StateStore) Delete(ctx context.Context, req *state.DeleteRequest) error
- func (js *StateStore) Features() []state.Feature
- func (js *StateStore) Get(ctx context.Context, req *state.GetRequest) (*state.GetResponse, error)
- func (js *StateStore) GetComponentMetadata() map[string]string
- func (js *StateStore) Init(_ context.Context, metadata state.Metadata) error
- func (js *StateStore) Set(ctx context.Context, req *state.SetRequest) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
Types ¶
type StateStore ¶
StateStore is a nats jetstream KV state store.
func (*StateStore) Delete ¶
func (js *StateStore) Delete(ctx context.Context, req *state.DeleteRequest) error
Delete performs a delete operation.
func (*StateStore) Features ¶
func (js *StateStore) Features() []state.Feature
func (*StateStore) Get ¶
func (js *StateStore) Get(ctx context.Context, req *state.GetRequest) (*state.GetResponse, error)
Get retrieves state with a key.
func (*StateStore) GetComponentMetadata ¶ added in v1.10.1
func (js *StateStore) GetComponentMetadata() map[string]string
func (*StateStore) Set ¶
func (js *StateStore) Set(ctx context.Context, req *state.SetRequest) error
Set stores value for a key.
Click to show internal directories.
Click to hide internal directories.