Documentation
¶
Index ¶
- func NewRethinkDBStateStore(logger logger.Logger) state.Store
- type ConnectOptsWrapper
- type RethinkDB
- func (s *RethinkDB) BulkDelete(ctx context.Context, req []state.DeleteRequest, _ state.BulkStoreOpts) error
- func (s *RethinkDB) BulkGet(ctx context.Context, req []state.GetRequest, opts state.BulkGetOpts) ([]state.BulkGetResponse, error)
- func (s *RethinkDB) BulkSet(ctx context.Context, req []state.SetRequest, _ state.BulkStoreOpts) error
- func (s *RethinkDB) Close() error
- func (s *RethinkDB) Delete(ctx context.Context, req *state.DeleteRequest) error
- func (s *RethinkDB) Features() []state.Feature
- func (s *RethinkDB) Get(ctx context.Context, req *state.GetRequest) (*state.GetResponse, error)
- func (s *RethinkDB) GetComponentMetadata() (metadataInfo metadata.MetadataMap)
- func (s *RethinkDB) Init(ctx context.Context, metadata state.Metadata) error
- func (s *RethinkDB) Set(ctx context.Context, req *state.SetRequest) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
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 (s *RethinkDB) BulkGet(ctx context.Context, req []state.GetRequest, opts state.BulkGetOpts) ([]state.BulkGetResponse, error)
func (*RethinkDB) BulkSet ¶
func (s *RethinkDB) BulkSet(ctx context.Context, req []state.SetRequest, _ state.BulkStoreOpts) error
BulkSet performs a bulk save operation.
func (*RethinkDB) Features ¶ added in v1.1.1
Features returns the features available in this state store.
func (*RethinkDB) Get ¶
func (s *RethinkDB) Get(ctx context.Context, req *state.GetRequest) (*state.GetResponse, error)
Get retrieves a RethinkDB KV item.
func (*RethinkDB) GetComponentMetadata ¶ added in v1.10.1
func (s *RethinkDB) GetComponentMetadata() (metadataInfo metadata.MetadataMap)
Click to show internal directories.
Click to hide internal directories.