bindings

package

v1.17.18 Latest Latest Go to latest Published: Oct 21, 2026 License: Apache-2.0 Imports: 11 Imported by: 2

Details

This section is empty.

This section is empty.

func NewGRPCInputBinding(l logger.Logger, socket string) *grpcInputBinding

NewGRPCInputBinding creates a new grpc inputbindingusing the given socket factory.

func NewGRPCOutputBinding(l logger.Logger, socket string) *grpcOutputBinding

NewGRPCOutputBinding creates a new grpc outputbinding using the given socket factory.

type Registry struct {
	Logger logger.Logger
	// contains filtered or unexported fields
}

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 NewRegistry() *Registry

NewRegistry is used to create new bindings.

func (b *Registry) CreateInputBinding(name, version, logName string) (bindings.InputBinding, error)

CreateInputBinding Create instantiates an input binding based on `name`.

func (b *Registry) CreateOutputBinding(name, version, logName string) (bindings.OutputBinding, error)

CreateOutputBinding Create instantiates an output binding based on `name`.

func (b *Registry) HasInputBinding(name, version string) bool

HasInputBinding checks if an input binding based on `name` exists in the registry.

func (b *Registry) HasOutputBinding(name, version string) bool

HasOutputBinding checks if an output binding based on `name` exists in the registry.

func (b *Registry) RegisterInputBinding(componentFactory func(logger.Logger) bindings.InputBinding, names ...string)

RegisterInputBinding adds a name input binding to the registry.

func (b *Registry) RegisterOutputBinding(componentFactory func(logger.Logger) bindings.OutputBinding, names ...string)

RegisterOutputBinding adds a name output binding to the registry.