producer

Documentation

Index

• type Factory
  • func NewFactory(cfg *config.Config, interceptors []Interceptor) (Factory, error)
• type InterceptNextFunc
• type Interceptor
• type InterceptorFunc
  • func (f InterceptorFunc) Intercept(ctx context.Context, msgs []Message, next InterceptNextFunc) error
• type Message
• type Producer

Types

type Factory

type Factory interface {
	Get(name string) Producer
}

func NewFactory

func NewFactory(cfg *config.Config, interceptors []Interceptor) (Factory, error)

type InterceptNextFunc

type InterceptNextFunc func(ctx context.Context, msg ...Message) error

type Interceptor

type Interceptor interface {
	Intercept(ctx context.Context, msgs []Message, next InterceptNextFunc) error
}

type InterceptorFunc

type InterceptorFunc func(ctx context.Context, msgs []Message, next InterceptNextFunc) error

func (InterceptorFunc) Intercept

func (f InterceptorFunc) Intercept(ctx context.Context, msgs []Message, next InterceptNextFunc) error

type Message

type Message = kafkalib.Message

type Producer

type Producer interface {
	Produce(context.Context, ...Message) error
}