kfkp

package module

v0.0.1 Latest Latest Go to latest Published: Jul 26, 2024 License: MIT Imports: 9 Imported by: 0

Details

A kafka producer pool for Go

This section is empty.

This section is empty.

This section is empty.

type Option func(*poolInfo)

func WithAsync(async bool) Option

func WithBrokerAddress(brokerAddress string) Option

func WithInitCapacity(size int) Option

func WithMaxCapacity(size int) Option

func WithMaxIdle(size int) Option

func WithRequiredAcks(requiredAcks kafka.RequiredAcks) Option

func WithTopic(topic string) Option

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

func NewPool(opts ...Option) (*Pool, error)

func (p *Pool) ClosePool() error

func (p *Pool) GetConn() (*producer, error)

func (p *Pool) GetRunning() int

func (p *Pool) PutConn(pd *producer) error

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