rethinkdb

Documentation

Index

• func NewRethinkDBStateStore(logger logger.Logger) state.Store
• type RethinkDB
  • func (s *RethinkDB) BulkDelete(ctx context.Context, req []state.DeleteRequest, _ state.BulkStoreOpts) error
  • 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
  • func (s *RethinkDB) Close() error
  • func (s *RethinkDB) Delete(ctx context.Context, req *state.DeleteRequest) error
  • func (s *RethinkDB) Features() []state.Feature
  • func (s *RethinkDB) Get(ctx context.Context, req *state.GetRequest) (*state.GetResponse, error)
  • func (s *RethinkDB) GetComponentMetadata() (metadataInfo metadata.MetadataMap)
  • func (s *RethinkDB) Init(ctx context.Context, metadata state.Metadata) error
  • func (s *RethinkDB) Set(ctx context.Context, req *state.SetRequest) error

Functions

func NewRethinkDBStateStore

func NewRethinkDBStateStore(logger logger.Logger) state.Store

NewRethinkDBStateStore returns a new RethinkDB state store.

Types

type RethinkDB

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

RethinkDB is a state store implementation for RethinkDB.

func (*RethinkDB) BulkDelete

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

BulkDelete performs a bulk delete operation.

func (*RethinkDB) BulkGet

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

func (*RethinkDB) BulkSet

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

BulkSet performs a bulk save operation.

func (*RethinkDB) Close

func (s *RethinkDB) Close() error

func (*RethinkDB) Delete

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

Delete performes a RethinkDB KV delete operation.

func (*RethinkDB) Features

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

Features returns the features available in this state store.

func (*RethinkDB) Get

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

Get retrieves a RethinkDB KV item.

func (*RethinkDB) GetComponentMetadata

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

func (*RethinkDB) Init

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 (*RethinkDB) Set

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

Set saves a state KV item.