rethinkdb

package
v1.16.1 Latest Latest
Warning

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

Go to latest
Published: Oct 1, 2025 License: Apache-2.0 Imports: 14 Imported by: 4

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func NewRethinkDBStateStore

func NewRethinkDBStateStore(logger logger.Logger) state.Store

NewRethinkDBStateStore returns a new RethinkDB state store.

Types

type ConnectOptsWrapper added in v1.16.0

type ConnectOptsWrapper struct {
	Address             string        `gorethink:"address,omitempty"`
	Addresses           []string      `gorethink:"addresses,omitempty"`
	Database            string        `gorethink:"database,omitempty"`
	Username            string        `gorethink:"username,omitempty"`
	Password            string        `gorethink:"password,omitempty"`
	AuthKey             string        `gorethink:"authkey,omitempty"`
	Timeout             time.Duration `gorethink:"timeout,omitempty"`
	WriteTimeout        time.Duration `gorethink:"write_timeout,omitempty"`
	ReadTimeout         time.Duration `gorethink:"read_timeout,omitempty"`
	KeepAlivePeriod     time.Duration `gorethink:"keep_alive_timeout,omitempty"`
	HandshakeVersion    int           `gorethink:"handshake_version,omitempty"`
	MaxIdle             int           `gorethink:"max_idle,omitempty"`
	InitialCap          int           `gorethink:"initial_cap,omitempty"`
	MaxOpen             int           `gorethink:"max_open,omitempty"`
	DiscoverHosts       bool          `gorethink:"discover_hosts,omitempty"`
	NodeRefreshInterval time.Duration `gorethink:"node_refresh_interval,omitempty"`
	UseJSONNumber       bool          `gorethink:"use_json_number,omitempty"`
	NumRetries          int           `gorethink:"num_retries,omitempty"`
	HostDecayDuration   time.Duration `gorethink:"host_decay_duration,omitempty"`
	UseOpentracing      bool          `gorethink:"use_opentracing,omitempty"`

	// TLS fields must be brought in as separate fields as they will not be processed by the metadata decoder properly without this
	EnableTLS  bool   `gorethink:"enable_tls,omitempty"`
	ClientCert string `gorethink:"client_cert,omitempty"`
	ClientKey  string `gorethink:"client_key,omitempty"`
}

ConnectOptsWrapper wraps r.ConnectOpts but excludes TLSConfig This is needed because the metadata decoder does not support nested structs with tags as inputs in the metadata.yaml file

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

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 added in v1.12.0

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

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

Features returns the features available in this state store.

func (*RethinkDB) Get

Get retrieves a RethinkDB KV item.

func (*RethinkDB) GetComponentMetadata added in v1.10.1

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.

Jump to

Keyboard shortcuts

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