kafka

Documentation

Index

• func GetDomainEventInfra() freedom.DomainEventInfra
• func SettingConfig(confFunc func(config *sarama.Config, other map[string]interface{}))
• func Sleep(retry int, minBackoff time.Duration, maxBackoff time.Duration)
• type Consumer
  • func (c *Consumer) Booting(sb freedom.SingleBoot)
  • func (c *Consumer) Close()
  • func (c *Consumer) Listen()
  • func (c *Consumer) StartUp(f func())
• type Limiter
  • func (s *Limiter) Close(deltas ...int32)
  • func (s *Limiter) Open(deltas ...int32)
• type Msg
  • func (msg *Msg) Publish()
  • func (msg *Msg) SelectClient(producer string) *Msg
  • func (msg *Msg) SetHeaders(headers map[string]string) *Msg
  • func (msg *Msg) SetWorker(worker freedom.Worker) *Msg
• type Producer
• type ProducerImpl
  • func (p *ProducerImpl) Booting(sb freedom.SingleBoot)
  • func (p *ProducerImpl) DomainEvent(producer, topic string, data []byte, worker freedom.Worker, ...)
  • func (p *ProducerImpl) NewMsg(topic string, content []byte, producerName ...string) *Msg
  • func (c *ProducerImpl) StartUp(f func())

Functions

func GetDomainEventInfra

func GetDomainEventInfra() freedom.DomainEventInfra

func SettingConfig

func SettingConfig(confFunc func(config *sarama.Config, other map[string]interface{}))

SettingConfig .

func Sleep

func Sleep(retry int, minBackoff time.Duration, maxBackoff time.Duration)

Types

type Consumer

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

Consumer .

func (*Consumer) Booting

func (c *Consumer) Booting(sb freedom.SingleBoot)

Booting .

func (*Consumer) Close

func (c *Consumer) Close()

func (*Consumer) Listen

func (c *Consumer) Listen()

func (*Consumer) StartUp

func (c *Consumer) StartUp(f func())

StartUp .

type Limiter

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

func (*Limiter) Close

func (s *Limiter) Close(deltas ...int32)

func (*Limiter) Open

func (s *Limiter) Open(deltas ...int32)

type Msg

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

Msg .

func (*Msg) Publish

func (msg *Msg) Publish()

Publish .

func (*Msg) SelectClient

func (msg *Msg) SelectClient(producer string) *Msg

SelectClient .

func (*Msg) SetHeaders

func (msg *Msg) SetHeaders(headers map[string]string) *Msg

SetHeaders .

func (*Msg) SetWorker

func (msg *Msg) SetWorker(worker freedom.Worker) *Msg

SetWorker .

type Producer

type Producer interface {
	NewMsg(topic string, content []byte, producerName ...string) *Msg
}

type ProducerImpl

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

ProducerImpl .

func (*ProducerImpl) Booting

func (p *ProducerImpl) Booting(sb freedom.SingleBoot)

Booting .

func (*ProducerImpl) DomainEvent

func (p *ProducerImpl) DomainEvent(producer, topic string, data []byte, worker freedom.Worker, header ...map[string]string)

DomainEvent .

func (*ProducerImpl) NewMsg

func (p *ProducerImpl) NewMsg(topic string, content []byte, producerName ...string) *Msg

NewMsg .

func (*ProducerImpl) StartUp

func (c *ProducerImpl) StartUp(f func())

StartUp .