dlq

Documentation

Index

• type Builder
• type DLQ
  • func NewDLQ(options *Options) (DLQ, error)
• type DqlType
• type Options

Types

type Builder

type Builder func() (DLQ, error)

type DLQ

type DLQ interface {
	Publish(ctx context.Context, record *data.Record) error
}

func NewDLQ

func NewDLQ(options *Options) (DLQ, error)

type DqlType

type DqlType int

const DqlGlobal DqlType = 1

const DqlPerTopic DqlType = 2

type Options

type Options struct {
	BootstrapServers []string
	Topic            string
	TopicFormat      string
	Type             DqlType
	Producer         producer.Producer
}