rethinkdb

package
v1.5.1 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Nov 29, 2021 License: MIT Imports: 10 Imported by: 4

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

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) BulkGet added in v1.0.0

func (s *RethinkDB) BulkGet(req []state.GetRequest) (bool, []state.BulkGetResponse, error)

BulkGet performs a bulks get operations.

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) Features added in v1.1.1

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

Features returns the features available in this state store.

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

Multi performs multiple operations.

func (*RethinkDB) Ping added in v1.4.4

func (s *RethinkDB) Ping() error

func (*RethinkDB) Set

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

Set saves a state KV item.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL