benthos

package

v1.0.8 Latest Latest Go to latest Published: Jan 18, 2024 License: MIT Imports: 5 Imported by: 0

Documentation ¶

This section is empty.

View Source

var TypeIBenthosRegistration = reflect.TypeOf((*IBenthosRegistration)(nil))

This section is empty.

type IBenthosRegistration interface {
	Register() error
}

type IBenthosStream interface {
	Run(ctx context.Context) (err error)
	Stop(ctx context.Context) (err error)
}

type UnimplementedBenthosOutput struct {
}

func (UnimplementedBenthosOutput) Close(ctx context.Context) error

func (UnimplementedBenthosOutput) Connect(context.Context) error

func (UnimplementedBenthosOutput) Write(context.Context, *benthos_service.Message) error

type UnimplementedIBenthosRegistration struct {
}

func (UnimplementedIBenthosRegistration) Register() error