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(reqs []state.TransactionalRequest) error
  • func (s *RethinkDB) Set(req *state.SetRequest) error
• type StateConfig
• type StateRecord

Types

type RethinkDB

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

RethinkDB is a state store implementation 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(reqs []state.TransactionalRequest) error

Multi performs multiple operations

func (*RethinkDB) Set

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

Set saves a state KV item

type StateConfig

type StateConfig struct {
	r.ConnectOpts
	Archive bool `json:"archive"`
}

StateConfig represents configuration for RethinkDB

type StateRecord

type StateRecord struct {
	ID   string      `json:"id" rethinkdb:"id"`
	TS   int64       `json:"timestamp" rethinkdb:"timestamp"`
	Hash string      `json:"hash,omitempty" rethinkdb:"hash,omitempty"`
	Data interface{} `json:"data,omitempty" rethinkdb:"data,omitempty"`
}

StateRecord represents a single state record