rethinkdb

Documentation

Index

• type RethinkDB
  • func NewRethinkDBStateStore(logger logger.Logger) *RethinkDB
  • func (s *RethinkDB) BulkDelete(req []state.DeleteRequest) error
  • func (s *RethinkDB) BulkSet(req []state.SetRequest) error
  • func (s *RethinkDB) Delete(req *state.DeleteRequest) error
  • func (s *RethinkDB) Get(req *state.GetRequest) (*state.GetResponse, error)
  • func (s *RethinkDB) Init(metadata state.Metadata) error
  • func (s *RethinkDB) Multi(req state.TransactionalStateRequest) error
  • func (s *RethinkDB) Set(req *state.SetRequest) error

Types

type RethinkDB

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

RethinkDB is a state store implementation with transactional support for RethinkDB.

func NewRethinkDBStateStore

func NewRethinkDBStateStore(logger logger.Logger) *RethinkDB

NewRethinkDBStateStore returns a new RethinkDB state store.

func (*RethinkDB) BulkDelete

func (s *RethinkDB) BulkDelete(req []state.DeleteRequest) error

BulkDelete performs a bulk delete operation

func (*RethinkDB) BulkSet

func (s *RethinkDB) BulkSet(req []state.SetRequest) error

BulkSet performs a bulk save operation

func (*RethinkDB) Delete

func (s *RethinkDB) Delete(req *state.DeleteRequest) error

Delete performes a RethinkDB KV delete operation

func (*RethinkDB) Get

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

Get retrieves a RethinkDB KV item

func (*RethinkDB) Init

func (s *RethinkDB) Init(metadata state.Metadata) error

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

func (*RethinkDB) Multi

func (s *RethinkDB) Multi(req state.TransactionalStateRequest) error

Multi performs multiple operations

func (*RethinkDB) Set

func (s *RethinkDB) Set(req *state.SetRequest) error

Set saves a state KV item