pipeline

Documentation

Index

• type ConsumerHandlerFunc
• type ConsumerPipeline
• type ConsumerPipelineConfiguration
• type ConsumerPipelineConfigurationBuilder
  • func NewConsumerPipelineConfigurationBuilder() ConsumerPipelineConfigurationBuilder
• type ConsumerPipelineConfigurationBuilderFunc

Types

type ConsumerHandlerFunc

type ConsumerHandlerFunc func() error

ConsumerHandlerFunc is a continuation for the next task to execute in the pipeline

type ConsumerPipeline

type ConsumerPipeline interface {
	Handle(ctx context.Context, consumerContext types.MessageConsumeContext, next ConsumerHandlerFunc) error
}

ConsumerPipeline is a Pipeline for wrapping the inner consumer handler.

type ConsumerPipelineConfiguration

type ConsumerPipelineConfiguration struct {
	Pipelines []ConsumerPipeline
}

type ConsumerPipelineConfigurationBuilder

type ConsumerPipelineConfigurationBuilder interface {
	AddPipeline(pipeline ConsumerPipeline) ConsumerPipelineConfigurationBuilder
	Build() *ConsumerPipelineConfiguration
}

func NewConsumerPipelineConfigurationBuilder

func NewConsumerPipelineConfigurationBuilder() ConsumerPipelineConfigurationBuilder

type ConsumerPipelineConfigurationBuilderFunc

type ConsumerPipelineConfigurationBuilderFunc func(ConsumerPipelineConfigurationBuilder)