commandbus

Documentation

Index

• type BusKafka
  • func NewKafka(addr []string, replyTo string, cc, rc codec.Codec) *BusKafka
  • func (b *BusKafka) Build() (commandbus.Bus, error)
  • func (b *BusKafka) SetChannelBuilder(command, reply messaging.ChannelBuilderFunc) *BusKafka
  • func (b *BusKafka) SetDuplicator(d commandbus.Duplicator) *BusKafka
  • func (b *BusKafka) SetErrorHandler(h messaging.ErrorHandler) *BusKafka
  • func (b *BusKafka) SetErrorHandlerFunc(h messaging.ErrorHandlerFunc) *BusKafka
  • func (b *BusKafka) SetKafkaConfig(c *sarama.Config) *BusKafka
  • func (b *BusKafka) SetLoggingMiddleware(logger log.Logger) *BusKafka
  • func (b *BusKafka) SetMetricsMiddleware(ns string, serviceName string, reg *prometheus.Registry) *BusKafka
  • func (b *BusKafka) SetOptions(o ...commandbus.Option) *BusKafka
  • func (b *BusKafka) SetReBalanceHook(hook messagingkafka.Hook) *BusKafka
  • func (b *BusKafka) SetReceiverListenOption(opts ...messagingkafka.ReceiverOption) *BusKafka
  • func (b *BusKafka) SetReceiverOptions(opts ...commandbus.ReceiverOption) *BusKafka
  • func (b *BusKafka) SetReplierListenOption(opts ...messagingkafka.ReceiverOption) *BusKafka
  • func (b *BusKafka) SetReplierOption(opts ...commandbus.ReplierOption) *BusKafka
  • func (b *BusKafka) SetSenderListenOption(opts ...messagingkafka.ReceiverOption) *BusKafka
• type ReplierKafka
  • func NewReplierKafka(addr []string, replyTo stream.Type, cc, rc codec.Codec) *ReplierKafka
  • func (r *ReplierKafka) Build() (commandbus.Replier, error)
  • func (r *ReplierKafka) SetChannelBuilder(command, reply messaging.ChannelBuilderFunc) *ReplierKafka
  • func (r *ReplierKafka) SetErrorHandler(h messaging.ErrorHandler) *ReplierKafka
  • func (r *ReplierKafka) SetErrorHandlerFunc(h messaging.ErrorHandlerFunc) *ReplierKafka
  • func (r *ReplierKafka) SetKafkaConfig(c *sarama.Config) *ReplierKafka
  • func (r *ReplierKafka) SetReBalanceHook(hook messagingkafka.Hook) *ReplierKafka
  • func (r *ReplierKafka) SetReceiverListenOption(opts ...messagingkafka.ReceiverOption) *ReplierKafka
  • func (r *ReplierKafka) SetReplierOptions(opts ...commandbus.ReplierOption) *ReplierKafka

Types

type BusKafka

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

func NewKafka

func NewKafka(addr []string, replyTo string, cc, rc codec.Codec) *BusKafka

func (*BusKafka) Build

func (b *BusKafka) Build() (commandbus.Bus, error)

func (*BusKafka) SetChannelBuilder

func (b *BusKafka) SetChannelBuilder(command, reply messaging.ChannelBuilderFunc) *BusKafka

func (*BusKafka) SetDuplicator

func (b *BusKafka) SetDuplicator(d commandbus.Duplicator) *BusKafka

func (*BusKafka) SetErrorHandler

func (b *BusKafka) SetErrorHandler(h messaging.ErrorHandler) *BusKafka

func (*BusKafka) SetErrorHandlerFunc

func (b *BusKafka) SetErrorHandlerFunc(h messaging.ErrorHandlerFunc) *BusKafka

func (*BusKafka) SetKafkaConfig

func (b *BusKafka) SetKafkaConfig(c *sarama.Config) *BusKafka

func (*BusKafka) SetLoggingMiddleware

func (b *BusKafka) SetLoggingMiddleware(logger log.Logger) *BusKafka

func (*BusKafka) SetMetricsMiddleware

func (b *BusKafka) SetMetricsMiddleware(ns string, serviceName string, reg *prometheus.Registry) *BusKafka

func (*BusKafka) SetOptions

func (b *BusKafka) SetOptions(o ...commandbus.Option) *BusKafka

func (*BusKafka) SetReBalanceHook

func (b *BusKafka) SetReBalanceHook(hook messagingkafka.Hook) *BusKafka

func (*BusKafka) SetReceiverListenOption

func (b *BusKafka) SetReceiverListenOption(opts ...messagingkafka.ReceiverOption) *BusKafka

func (*BusKafka) SetReceiverOptions

func (b *BusKafka) SetReceiverOptions(opts ...commandbus.ReceiverOption) *BusKafka

func (*BusKafka) SetReplierListenOption

func (b *BusKafka) SetReplierListenOption(opts ...messagingkafka.ReceiverOption) *BusKafka

func (*BusKafka) SetReplierOption

func (b *BusKafka) SetReplierOption(opts ...commandbus.ReplierOption) *BusKafka

func (*BusKafka) SetSenderListenOption

func (b *BusKafka) SetSenderListenOption(opts ...messagingkafka.ReceiverOption) *BusKafka

type ReplierKafka

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

func NewReplierKafka

func NewReplierKafka(addr []string, replyTo stream.Type, cc, rc codec.Codec) *ReplierKafka

func (*ReplierKafka) Build

func (r *ReplierKafka) Build() (commandbus.Replier, error)

func (*ReplierKafka) SetChannelBuilder

func (r *ReplierKafka) SetChannelBuilder(command, reply messaging.ChannelBuilderFunc) *ReplierKafka

func (*ReplierKafka) SetErrorHandler

func (r *ReplierKafka) SetErrorHandler(h messaging.ErrorHandler) *ReplierKafka

func (*ReplierKafka) SetErrorHandlerFunc

func (r *ReplierKafka) SetErrorHandlerFunc(h messaging.ErrorHandlerFunc) *ReplierKafka

func (*ReplierKafka) SetKafkaConfig

func (r *ReplierKafka) SetKafkaConfig(c *sarama.Config) *ReplierKafka

func (*ReplierKafka) SetReBalanceHook

func (r *ReplierKafka) SetReBalanceHook(hook messagingkafka.Hook) *ReplierKafka

func (*ReplierKafka) SetReceiverListenOption

func (r *ReplierKafka) SetReceiverListenOption(opts ...messagingkafka.ReceiverOption) *ReplierKafka

func (*ReplierKafka) SetReplierOptions

func (r *ReplierKafka) SetReplierOptions(opts ...commandbus.ReplierOption) *ReplierKafka