databusc

Nov 5, 2021

Changes in this version

type ConsumerParam

+ PollMs int

+ SessionMs int

Jan 11, 2021

Changes in this version

type ProducerEvent

+ SendMessageByMod func(data []byte, key uint32) error

+ SendMessagePartition func(data []byte, partition uint32) error

Nov 27, 2020

Changes in this version

type ConsumerParam

+ CommitMode int

Nov 6, 2020

Changes in this version

type ConsumerParam

+ QueueLen int

Nov 6, 2020

Changes in this version

+ func NewConsumerHandle(param *ConsumerParam, appname string, Id int) (*consumerEvent, error)

Nov 3, 2020

Changes in this version

+ var ErrEmptyCircle = errors.New("empty circle")

+ type Consistent struct

+ NumberOfReplicas int

+ UseFnv bool

+ func New() *Consistent

+ func (c *Consistent) Add(elt string)

+ func (c *Consistent) Get(name string) (string, error)

+ func (c *Consistent) GetN(name string, n int) ([]string, error)

+ func (c *Consistent) GetTwo(name string) (string, string, error)

+ func (c *Consistent) Members() []string

+ func (c *Consistent) Remove(elt string)

+ func (c *Consistent) Set(elts []string)

type ConsumerParam

+ AutoCommitMode int

+ ThreadNum int

type ProducerParam

+ ConsumerMode int

Nov 2, 2020

Changes in this version

+ type ConsumerDeal interface

+ DealMessage func(msg *kafka.Message) error

+ type ConsumerEvent interface

+ Close func()

+ CommitMessage func(msg *kafka.Message) error

+ Start func() error

+ func NewConsumer(param *ConsumerParam) (ConsumerEvent, error)

+ type ConsumerParam struct

+ Address string

+ AutoCommit int

+ ConsumerMode int

+ Dealhanle ConsumerDeal

+ GroupId string

+ Topic string

+ type ProducerEvent interface

+ Close func()

+ SendMessage func(data []byte, key string) error

+ func NewAsyncProducer(param *ProducerParam) (ProducerEvent, error)

+ type ProducerParam struct

+ Address string

+ IsAck bool

+ KafkaVer string

+ Topic string