leafKafka

package module

v0.0.0-...-0829b1e Latest Latest Go to latest Published: May 23, 2022 License: MIT Imports: 23 Imported by: 2

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/paulusrobin/leaf-utilities

Links

Open Source Insights

README ¶

Message-Queue-Kafka

Documentation ¶

Index ¶

Constants
func New(options ...Option) (leafMQ.MessageQueue, error)
func NewMultiple(multiplier int, options ...Option) (leafMQ.MessageQueue, error)
type 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 New ¶

func New(options ...Option) (leafMQ.MessageQueue, error)

func NewMultiple ¶

func NewMultiple(multiplier int, options ...Option) (leafMQ.MessageQueue, error)

Types ¶

type Option ¶

type Option interface {
	Apply(o *option)
}

func WithClientID ¶

func WithClientID(clientID string) Option

func WithConsumerGroup ¶

func WithConsumerGroup(group string) Option

func WithConsumerRetryMax ¶

func WithConsumerRetryMax(maxRetry int) Option

func WithConsumerWorker ¶

func WithConsumerWorker(worker int) Option

func WithHeartbeat ¶

func WithHeartbeat(heartbeat int) Option

func WithHost ¶

func WithHost(host []string) Option

func WithKafkaVersion ¶

func WithKafkaVersion(version string) Option

func WithLog ¶

func WithLog(logger leafLogger.Logger) Option

func WithProducerMaxBytes ¶

func WithProducerMaxBytes(maxBytes int) Option

func WithProducerRetryBackOff ¶

func WithProducerRetryBackOff(retryBackoff time.Duration) Option

func WithProducerRetryMax ¶

func WithProducerRetryMax(maxRetry int) Option

func WithSlackNotification ¶

func WithSlackNotification(notification SlackNotification) Option

func WithStrategy ¶

func WithStrategy(strategy Strategy) Option

func WithoutConsumer ¶

func WithoutConsumer() Option

func WithoutProducer ¶

func WithoutProducer() Option

func WithoutSlackNotification ¶

func WithoutSlackNotification() Option

type SlackNotification ¶

type SlackNotification struct {
	Active  bool
	Hook    string
	Timeout time.Duration
}

type Strategy ¶

type Strategy string

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL