Documentation ¶
Index ¶
- func NewGRPCInputBinding(l logger.Logger, socket string) *grpcInputBinding
- func NewGRPCOutputBinding(l logger.Logger, socket string) *grpcOutputBinding
- type Registry
- func (b *Registry) CreateInputBinding(name, version, logName string) (bindings.InputBinding, error)
- func (b *Registry) CreateOutputBinding(name, version, logName string) (bindings.OutputBinding, error)
- func (b *Registry) HasInputBinding(name, version string) bool
- func (b *Registry) HasOutputBinding(name, version string) bool
- func (b *Registry) RegisterInputBinding(componentFactory func(logger.Logger) bindings.InputBinding, names ...string)
- func (b *Registry) RegisterOutputBinding(componentFactory func(logger.Logger) bindings.OutputBinding, names ...string)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func NewGRPCInputBinding ¶ added in v1.9.0
NewGRPCInputBinding creates a new grpc inputbindingusing the given socket factory.
func NewGRPCOutputBinding ¶ added in v1.9.0
NewGRPCOutputBinding creates a new grpc outputbinding using the given socket factory.
Types ¶
type Registry ¶
Registry is the interface of a components that allows callers to get registered instances of input and output bindings.
var DefaultRegistry *Registry = NewRegistry()
DefaultRegistry is the singleton with the registry.
func (*Registry) CreateInputBinding ¶
func (b *Registry) CreateInputBinding(name, version, logName string) (bindings.InputBinding, error)
CreateInputBinding Create instantiates an input binding based on `name`.
func (*Registry) CreateOutputBinding ¶
func (b *Registry) CreateOutputBinding(name, version, logName string) (bindings.OutputBinding, error)
CreateOutputBinding Create instantiates an output binding based on `name`.
func (*Registry) HasInputBinding ¶ added in v1.0.0
HasInputBinding checks if an input binding based on `name` exists in the registry.
func (*Registry) HasOutputBinding ¶ added in v1.0.0
HasOutputBinding checks if an output binding based on `name` exists in the registry.
func (*Registry) RegisterInputBinding ¶ added in v1.9.0
func (b *Registry) RegisterInputBinding(componentFactory func(logger.Logger) bindings.InputBinding, names ...string)
RegisterInputBinding adds a name input binding to the registry.
func (*Registry) RegisterOutputBinding ¶ added in v1.9.0
func (b *Registry) RegisterOutputBinding(componentFactory func(logger.Logger) bindings.OutputBinding, names ...string)
RegisterOutputBinding adds a name output binding to the registry.