statechange

Documentation

Index

• type Binding
  • func NewRethinkDBStateChangeBinding(logger logger.Logger) *Binding
  • func (b *Binding) Init(metadata bindings.Metadata) error
  • func (b *Binding) Read(handler func(*bindings.ReadResponse) ([]byte, error)) error
• type StateConfig

Types

type Binding

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

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

func NewRethinkDBStateChangeBinding

func NewRethinkDBStateChangeBinding(logger logger.Logger) *Binding

NewRethinkDBStateChangeBinding returns a new RethinkDB actor event input binding.

func (*Binding) Init

func (b *Binding) Init(metadata bindings.Metadata) error

Init initializes the RethinkDB binding.

func (*Binding) Read

func (b *Binding) Read(handler func(*bindings.ReadResponse) ([]byte, error)) error

Read triggers the RethinkDB scheduler.

type StateConfig

type StateConfig struct {
	r.ConnectOpts
	Table string `json:"table"`
}

StateConfig is the binding config.