Documentation ¶
Index ¶
- Constants
- func New(options ...Option) (leafMQ.MessageQueue, error)
- func NewMultiple(multiplier int, options ...Option) (leafMQ.MessageQueue, error)
- type Option
- func WithClientID(clientID string) Option
- func WithConsumerGroup(group string) Option
- func WithConsumerRetryMax(maxRetry int) Option
- func WithConsumerWorker(worker int) Option
- func WithHeartbeat(heartbeat int) Option
- func WithHost(host []string) Option
- func WithKafkaVersion(version string) Option
- func WithLog(logger leafLogger.Logger) Option
- func WithProducerMaxBytes(maxBytes int) Option
- func WithProducerRetryBackOff(retryBackoff time.Duration) Option
- func WithProducerRetryMax(maxRetry int) Option
- func WithSlackNotification(notification SlackNotification) Option
- func WithStrategy(strategy Strategy) Option
- func WithoutConsumer() Option
- func WithoutProducer() Option
- func WithoutSlackNotification() Option
- type SlackNotification
- type Strategy
Constants ¶
View Source
const ( DefaultConsumerWorker = 10 DefaultConsumerRetryMax = 3 DefaultConsumerRetryBackoff = 2 * time.Second DefaultFailedDeadline = 60 * time.Second DefaultStrategy = "BalanceStrategyRoundRobin" DefaultHeartbeat = 3 DefaultProducerMaxBytes = 1000000 DefaultProducerRetryMax = 3 DefaultProducerRetryBackoff = 100 BalanceStrategySticky = "BalanceStrategySticky" BalanceStrategyRoundRobin = "BalanceStrategyRoundRobin" BalanceStrategyRange = "BalanceStrategyRange" )
View Source
const (
EventPublish = "kafka_publish"
)
Variables ¶
This section is empty.
Functions ¶
func NewMultiple ¶
func NewMultiple(multiplier int, options ...Option) (leafMQ.MessageQueue, error)
Types ¶
type Option ¶
type Option interface {
Apply(o *option)
}
func WithClientID ¶
func WithConsumerGroup ¶
func WithConsumerRetryMax ¶
func WithConsumerWorker ¶
func WithHeartbeat ¶
func WithKafkaVersion ¶
func WithLog ¶
func WithLog(logger leafLogger.Logger) Option
func WithProducerMaxBytes ¶
func WithProducerRetryMax ¶
func WithSlackNotification ¶
func WithSlackNotification(notification SlackNotification) Option
func WithStrategy ¶
func WithoutConsumer ¶
func WithoutConsumer() Option
func WithoutProducer ¶
func WithoutProducer() Option
func WithoutSlackNotification ¶
func WithoutSlackNotification() Option
type SlackNotification ¶
Click to show internal directories.
Click to hide internal directories.