statechange

package
v1.18.2 Latest Latest
Warning

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

Go to latest
Published: Jul 14, 2026 License: Apache-2.0 Imports: 15 Imported by: 1

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func NewRethinkDBStateChangeBinding

func NewRethinkDBStateChangeBinding(logger logger.Logger) bindings.InputBinding

NewRethinkDBStateChangeBinding returns a new RethinkDB actor event input binding.

Types

type Binding

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

Binding represents RethinkDB change state input binding which fires handler with both the previous and current state store content each time there is a change.

func (*Binding) Close added in v1.11.0

func (b *Binding) Close() error

func (*Binding) GetComponentMetadata added in v1.11.0

func (b *Binding) GetComponentMetadata() (metadataInfo metadata.MetadataMap)

GetComponentMetadata returns the metadata of the component.

func (*Binding) Init

func (b *Binding) Init(ctx context.Context, metadata bindings.Metadata) error

Init initializes the RethinkDB binding.

func (*Binding) Read

func (b *Binding) Read(ctx context.Context, handler bindings.Handler) error

Read triggers the RethinkDB scheduler.

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 StateConfig

type StateConfig struct {
	ConnectOptsWrapper `mapstructure:",squash"`
	Table              string `mapstructure:"table"`
}

StateConfig is the binding config.

Jump to

Keyboard shortcuts

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