benthos

Documentation

Index

• Variables
• type CentrifugeStreamConfig
• type IBenthosRegistration
• type IBenthosStream
• type UnimplementedBenthosOutput
  • func (UnimplementedBenthosOutput) Close(ctx context.Context) error
  • func (UnimplementedBenthosOutput) Connect(context.Context) error
  • func (UnimplementedBenthosOutput) Write(context.Context, *benthos_service.Message) error
• type UnimplementedIBenthosRegistration
  • func (UnimplementedIBenthosRegistration) Register() error
• type UnimplementedIBenthosStream
  • func (UnimplementedIBenthosStream) Configure(ctx context.Context, config *CentrifugeStreamConfig) (err error)

Variables

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

Types

type CentrifugeStreamConfig

type CentrifugeStreamConfig struct {
	ConfigPath string `json:"configPath"`
}

type IBenthosRegistration

type IBenthosRegistration interface {
	Register() error
}

type IBenthosStream

type IBenthosStream interface {
	Configure(ctx context.Context, config *CentrifugeStreamConfig) (err error)
	Run(ctx context.Context) (err error)
	Stop(ctx context.Context) (err error)
}

type UnimplementedBenthosOutput

type UnimplementedBenthosOutput struct {
}

func (UnimplementedBenthosOutput) Close

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

func (UnimplementedBenthosOutput) Connect

func (UnimplementedBenthosOutput) Connect(context.Context) error

func (UnimplementedBenthosOutput) Write

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

type UnimplementedIBenthosRegistration

type UnimplementedIBenthosRegistration struct {
}

func (UnimplementedIBenthosRegistration) Register

func (UnimplementedIBenthosRegistration) Register() error

type UnimplementedIBenthosStream

type UnimplementedIBenthosStream struct{}

func (UnimplementedIBenthosStream) Configure

func (UnimplementedIBenthosStream) Configure(ctx context.Context, config *CentrifugeStreamConfig) (err error)