bindings

Documentation

Index

• func Load()
• func RegisterInputBinding(name string, factoryMethod func() bindings.InputBinding)
• func RegisterOutputBinding(name string, factoryMethod func() bindings.OutputBinding)
• type Registry
  • func NewRegistry() Registry

Functions

func Load

func Load()

Load input/output bindings

func RegisterInputBinding

func RegisterInputBinding(name string, factoryMethod func() bindings.InputBinding)

RegisterInputBinding registers a new factory method that creates an instance of an InputBinding. The key is the name of the binding, eg. kafka.

func RegisterOutputBinding

func RegisterOutputBinding(name string, factoryMethod func() bindings.OutputBinding)

RegisterOutputBinding registers a new factory method that creates an instance of an OutputBinding. The key is the name of the binding, eg. kafka.

Types

type Registry

type Registry interface {
	CreateInputBinding(name string) (bindings.InputBinding, error)
	CreateOutputBinding(name string) (bindings.OutputBinding, error)
}

Registry is the interface of a components that allows callers to get registered instances of input and output bindings

func NewRegistry

func NewRegistry() Registry

NewRegistry is used to create new bindings