Documentation
¶
Overview ¶
Package producer pushes decoded messages to message queues
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type KafkaSarama ¶ added in v0.9.1
type KafkaSarama struct {
// contains filtered or unexported fields
}
KafkaSarama represents kafka producer
type KafkaSaramaConfig ¶ added in v0.9.1
type KafkaSaramaConfig 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"`
TLSEnabled bool `yaml:"tls-enabled" env:"TLS_ENABLED"`
TLSCertFile string `yaml:"tls-cert" env:"TLS_CERT"`
TLSKeyFile string `yaml:"tls-key" env:"TLS_KEY"`
CAFile string `yaml:"ca-file" env:"CA_FILE"`
TLSSkipVerify bool `yaml:"tls-skip-verify" env:"TLS_SKIP_VERIFY"`
SASLUsername string `yaml:"sasl-username" env:"SASL_USERNAME"`
SASLPassword string `yaml:"sasl-password" env:"SASL_PASSWORD"`
}
KafkaSaramaConfig represents kafka configuration
type KafkaSegmentio ¶ added in v0.9.1
type KafkaSegmentio struct {
// contains filtered or unexported fields
}
KafkaSegmentio represents kafka producer
type KafkaSegmentioConfig ¶ added in v0.9.1
type KafkaSegmentioConfig struct {
Brokers []string `yaml:"brokers" env:"BROKERS"`
BootstrapServer string `yaml:"bootstrap-server" env:"BOOTSTRAP_SERVER"`
ClientID string `yaml:"client-id" env:"CLIENT_ID"`
Compression string `yaml:"compression" env:"COMPRESSION"`
MaxAttempts int `yaml:"max-attempts" env:"MAX_ATTEMPTS"`
QueueSize int `yaml:"queue-size" env:"QUEUE_SIZE"`
BatchSize int `yaml:"batch-size" env:"BATCH_SIZE"`
KeepAlive int `yaml:"keepalive" env:"KEEPALIVE"`
IOTimeout int `yaml:"connect-timeout" env:"CONNECT_TIMEOUT"`
RequiredAcks int `yaml:"required-acks" env:"REQUIRED_ACKS"`
PeriodicFlush int `yaml:"pflush" env:"PERIODIC_FLUSH"`
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"`
// contains filtered or unexported fields
}
KafkaSegmentioConfig represents kafka configuration
type MQueue ¶
type MQueue interface {
// contains filtered or unexported methods
}
MQueue represents messaging queue methods
type NATS ¶ added in v0.3.2
type NATS struct {
// contains filtered or unexported fields
}
NATS represents nats producer
type NATSConfig ¶ added in v0.3.2
type NATSConfig struct {
URL string `yaml:"url"`
}
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 `yaml:"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 ¶
NewProducer constructs new Messaging Queue
type RawSocket ¶ added in v0.5.0
type RawSocket struct {
// contains filtered or unexported fields
}
RawSocket represents RawSocket producer
type RawSocketConfig ¶ added in v0.5.0
type RawSocketConfig struct {
URL string `yaml:"url"`
Protocol string `yaml:"protocol"`
MaxRetry int `yaml:"retry-max"`
}
RawSocketConfig is the struct that holds all configuation for RawSocketConfig connections