group

Documentation

Index

• type Kafka
  • func NewKafka(addr []string, name string) *Kafka
  • func (k *Kafka) Build() (*group.Group, error)
  • func (k *Kafka) SetChannel(channel string) *Kafka
  • func (k *Kafka) SetCodec(command codec.Codec, replies codec.Codec) *Kafka
  • func (k *Kafka) SetConfig(c *sarama.Config) *Kafka
  • func (k *Kafka) SetErrorHandler(h messaging.ErrorHandler) *Kafka
  • func (k *Kafka) SetListenerOptions(opts ...messagingkafka.ReceiverOption) *Kafka
  • func (k *Kafka) SetLogger(l group.Logger) *Kafka
  • func (k *Kafka) SetPostgresStore(pool *pgxpool.Pool) *Kafka
  • func (k *Kafka) SetReplierOpts(opts ...commandbus.ReplierOption) *Kafka
  • func (k *Kafka) SetStore(s group.Store) *Kafka

Types

type Kafka

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

func NewKafka

func NewKafka(addr []string, name string) *Kafka

func (*Kafka) Build

func (k *Kafka) Build() (*group.Group, error)

func (*Kafka) SetChannel

func (k *Kafka) SetChannel(channel string) *Kafka

func (*Kafka) SetCodec

func (k *Kafka) SetCodec(command codec.Codec, replies codec.Codec) *Kafka

func (*Kafka) SetConfig

func (k *Kafka) SetConfig(c *sarama.Config) *Kafka

func (*Kafka) SetErrorHandler

func (k *Kafka) SetErrorHandler(h messaging.ErrorHandler) *Kafka

func (*Kafka) SetListenerOptions

func (k *Kafka) SetListenerOptions(opts ...messagingkafka.ReceiverOption) *Kafka

func (*Kafka) SetLogger

func (k *Kafka) SetLogger(l group.Logger) *Kafka

func (*Kafka) SetPostgresStore

func (k *Kafka) SetPostgresStore(pool *pgxpool.Pool) *Kafka

func (*Kafka) SetReplierOpts

func (k *Kafka) SetReplierOpts(opts ...commandbus.ReplierOption) *Kafka

func (*Kafka) SetStore

func (k *Kafka) SetStore(s group.Store) *Kafka