producer

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

type KafkaConfig struct {
	Brokers        []string `yaml:"brokers" env:"BROKERS"`
	Compression    string   `yaml:"compression" env:"COMPRESSION"`
	RetryMax       int      `yaml:"retry-max" env:"RETRY_MAX"`
	RequestSizeMax int32    `yaml:"request-size-max" env:"REQUEST_SIZE_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"`
}

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

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

type NATSConfig struct {
	URL string `yaml:"url"`
}

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

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

type Producer struct {
	MQ           MQueue
	MQConfigFile string
	MQErrorCount *uint64

	Topic string
	Chan  chan []byte

	Logger *log.Logger
}

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

type RawSocketConfig struct {
	URL      string `yaml:"url"`
	Protocol string `yaml:"protocol"`
	MaxRetry int    `yaml:"retry-max"`
}