bindings

Documentation

Index

• Variables
• func RegisterInput(server *grpc.Server, getInstance func(context.Context) InputBinding)
• func RegisterOutput(server *grpc.Server, getInstance func(context.Context) OutputBinding)
• type InputBinding
• type OutputBinding

Variables

var ErrAckTimeout = errors.New("ack has timed out")

Functions

func RegisterInput

func RegisterInput(server *grpc.Server, getInstance func(context.Context) InputBinding)

RegisterInput the inputbinding implementation for the component gRPC service.

func RegisterOutput

func RegisterOutput(server *grpc.Server, getInstance func(context.Context) OutputBinding)

RegisterOutput the outputbinding implementation for the component gRPC service.

Types

type InputBinding

type InputBinding interface {
	contribBindings.InputBinding
}

InputBinding is the interface to define a binding that triggers on incoming events. It wraps the contrib interface

type OutputBinding

type OutputBinding interface {
	contribBindings.OutputBinding
}

OutputBinding is an interface to perform operations in remote systems using optional payloads. It wraps the contrib interface