statechange

Documentation

Index

• func NewRethinkDBStateChangeBinding(logger logger.Logger) bindings.InputBinding
• type Binding
  • func (b *Binding) Close() error
  • func (b *Binding) GetComponentMetadata() (metadataInfo metadata.MetadataMap)
  • func (b *Binding) Init(ctx context.Context, metadata bindings.Metadata) error
  • func (b *Binding) Read(ctx context.Context, handler bindings.Handler) error
• type StateConfig

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

func (b *Binding) Close() error

func (*Binding) GetComponentMetadata

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 StateConfig

type StateConfig struct {
	r.ConnectOpts `mapstructure:",squash"`
	Table         string `mapstructure:"table"`
}

StateConfig is the binding config.