rethinkdb

package

v1.15.6 Latest Latest Go to latest Published: Jul 22, 2025 License: Apache-2.0 Imports: 13 Imported by: 4

Details

This section is empty.

This section is empty.

func NewRethinkDBStateStore(logger logger.Logger) state.Store

NewRethinkDBStateStore returns a new RethinkDB state store.

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

RethinkDB is a state store implementation for RethinkDB.

func (s *RethinkDB) BulkDelete(ctx context.Context, req []state.DeleteRequest, _ state.BulkStoreOpts) error

BulkDelete performs a bulk delete operation.

func (s *RethinkDB) BulkGet(ctx context.Context, req []state.GetRequest, opts state.BulkGetOpts) ([]state.BulkGetResponse, error)

func (s *RethinkDB) BulkSet(ctx context.Context, req []state.SetRequest, _ state.BulkStoreOpts) error

BulkSet performs a bulk save operation.

func (s *RethinkDB) Close() error

func (s *RethinkDB) Delete(ctx context.Context, req *state.DeleteRequest) error

Delete performes a RethinkDB KV delete operation.

func (s *RethinkDB) Features() []state.Feature

Features returns the features available in this state store.

func (s *RethinkDB) Get(ctx context.Context, req *state.GetRequest) (*state.GetResponse, error)

Get retrieves a RethinkDB KV item.

func (s *RethinkDB) GetComponentMetadata() (metadataInfo metadata.MetadataMap)

func (s *RethinkDB) Init(ctx context.Context, metadata state.Metadata) error

Init parses metadata, initializes the RethinkDB client, and ensures the state table exists.

func (s *RethinkDB) Set(ctx context.Context, req *state.SetRequest) error

Set saves a state KV item.