rethinkdb

package
v1.2.3 Latest Latest
Warning

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

Go to latest
Published: Aug 11, 2021 License: MIT Imports: 10 Imported by: 0

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

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

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

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