producer

Documentation

Index

• Constants
• type KafkaProducerBuilder
  • func (kb *KafkaProducerBuilder) Create(config helper.MsgBusConfig) (builder.MessageSender, error)
• type Producer
  • func (p *Producer) AsyncSend(msg *types.Message) error
  • func (p *Producer) Close()
  • func (p *Producer) Flush(timeout int) error
  • func (p *Producer) Start() error

Constants

const (
	KAFKA_FLUSH_TIMEOUT_MS = 300000
)

Types

type KafkaProducerBuilder

type KafkaProducerBuilder struct {
}

func (*KafkaProducerBuilder) Create

func (kb *KafkaProducerBuilder) Create(config helper.MsgBusConfig) (builder.MessageSender, error)

type Producer

type Producer struct {
	// contains filtered or unexported fields
}

func (*Producer) AsyncSend

func (p *Producer) AsyncSend(msg *types.Message) error

func (*Producer) Close

func (p *Producer) Close()

func (*Producer) Flush

func (p *Producer) Flush(timeout int) error

func (*Producer) Start

func (p *Producer) Start() error