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) GetComponentMetadata ¶ added in v1.11.0
func (b *Binding) GetComponentMetadata() (metadataInfo metadata.MetadataMap)
GetComponentMetadata returns the metadata of the component.
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.
Click to show internal directories.
Click to hide internal directories.