producer

Documentation

Index

• Constants
• type Producer
  • func NewProducer(config ProducerConfig) *Producer
  • func (p *Producer) Produce(msg api.Message) error
  • func (p *Producer) ProduceBatch() error
• type ProducerConfig

Constants

const BROKER_URL = "http://localhost:3000"

Types

type Producer

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

Producer for queue events/messages

func NewProducer

func NewProducer(config ProducerConfig) *Producer

func (*Producer) Produce

func (p *Producer) Produce(msg api.Message) error

func (*Producer) ProduceBatch

func (p *Producer) ProduceBatch() error

type ProducerConfig

type ProducerConfig struct {
}