producer

Documentation

Overview

Package producer pushes decoded messages to message queues

Index

• type Kafka
• type KafkaConfig
• type MQueue
• type NATS
• type NATSConfig
• type NSQ
• type NSQConfig
• type Producer
  • func NewProducer(mqName string) *Producer
  • func (p *Producer) Run() error
  • func (p *Producer) Shutdown()

Types

type Kafka

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

Kafka represents kafka producer

type KafkaConfig

type KafkaConfig struct {
	Brokers      []string `yaml:"brokers" env:"BROKERS"`
	Compression  string   `yaml:"compression" env:"COMPRESSION"`
	RetryMax     int      `yaml:"retry-max" env:"RETRY_MAX"`
	RetryBackoff int      `yaml:"retry-backoff" env:"RETRY_BACKOFF"`
	TLSCertFile  string   `yaml:"tls-cert" env:"TLS_CERT"`
	TLSKeyFile   string   `yaml:"tls-key" env:"TLS_KEY"`
	CAFile       string   `yaml:"ca-file" env:"CA_FILE"`
	VerifySSL    bool     `yaml:"verify-ssl" env:"VERIFY_SSL"`
}

KafkaConfig represents kafka configuration

type MQueue

type MQueue interface {
	// contains filtered or unexported methods
}

MQueue represents messaging queue methods

type NATS

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

NATS represents nats producer

type NATSConfig

type NATSConfig struct {
	URL string `json:"endpoint"`
}

NATSConfig is the struct that holds all configuation for NATS connections

type NSQ

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

NSQ represents nsq producer

type NSQConfig

type NSQConfig struct {
	Server string `json:"server"`
}

NSQConfig represents NSQ configuration

type Producer

type Producer struct {
	MQ           MQueue
	MQConfigFile string
	MQErrorCount *uint64

	Topic string
	Chan  chan []byte

	Logger *log.Logger
}

Producer represents messaging queue

func NewProducer

func NewProducer(mqName string) *Producer

NewProducer constructs new Messaging Queue

func (*Producer) Run

func (p *Producer) Run() error

Run configs and tries to be ready to produce

func (*Producer) Shutdown

func (p *Producer) Shutdown()

Shutdown stops the producer