statechange

Documentation

Index

• func NewRethinkDBStateChangeBinding(logger logger.Logger) bindings.InputBinding
• type Binding
  • func (b *Binding) Init(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) Init

func (b *Binding) Init(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
	Table string `json:"table"`
}

StateConfig is the binding config.