Documentation ¶
Index ¶
- type BusKafka
- func (b *BusKafka) Build() (eventbus.Bus, error)
- func (b *BusKafka) SetDuplicator(d eventbus.Duplicator) *BusKafka
- func (b *BusKafka) SetErrorHandler(h messaging.ErrorHandler) *BusKafka
- func (b *BusKafka) SetErrorHandlerFunc(h messaging.ErrorHandlerFunc) *BusKafka
- func (b *BusKafka) SetGroupProcessing(serviceName string) *BusKafka
- func (b *BusKafka) SetKafkaConfig(c *sarama.Config) *BusKafka
- func (b *BusKafka) SetListenerOptions(opts ...messagingkafka.ReceiverOption) *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 ...eventbus.Option) *BusKafka
- func (b *BusKafka) SetPublisherOptions(opts ...eventbus.PublisherOption) *BusKafka
- func (b *BusKafka) SetReBalanceHook(hook messagingkafka.Hook) *BusKafka
- func (b *BusKafka) SetSubscriberOptions(opts ...eventbus.SubscriberOption) *BusKafka
- type PublisherKafka
- type SubscriberKafka
- func (s *SubscriberKafka) Build() eventbus.Subscriber
- func (s *SubscriberKafka) SetDuplicator(d eventbus.Duplicator) *SubscriberKafka
- func (s *SubscriberKafka) SetErrorHandler(h messaging.ErrorHandler) *SubscriberKafka
- func (s *SubscriberKafka) SetErrorHandlerFunc(h messaging.ErrorHandlerFunc) *SubscriberKafka
- func (s *SubscriberKafka) SetKafkaConfig(c *sarama.Config) *SubscriberKafka
- func (s *SubscriberKafka) SetListenOption(opts ...messagingkafka.ReceiverOption) *SubscriberKafka
- func (s *SubscriberKafka) SetReBalanceHook(hook messagingkafka.Hook) *SubscriberKafka
- func (s *SubscriberKafka) SetSubscribeOptions(opts ...eventbus.SubscriberOption) *SubscriberKafka
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type BusKafka ¶
type BusKafka struct {
// contains filtered or unexported fields
}
func (*BusKafka) SetDuplicator ¶
func (b *BusKafka) SetDuplicator(d eventbus.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) SetGroupProcessing ¶
func (*BusKafka) SetListenerOptions ¶
func (b *BusKafka) SetListenerOptions(opts ...messagingkafka.ReceiverOption) *BusKafka
func (*BusKafka) SetLoggingMiddleware ¶
func (*BusKafka) SetMetricsMiddleware ¶
func (*BusKafka) SetPublisherOptions ¶
func (b *BusKafka) SetPublisherOptions(opts ...eventbus.PublisherOption) *BusKafka
func (*BusKafka) SetReBalanceHook ¶
func (b *BusKafka) SetReBalanceHook(hook messagingkafka.Hook) *BusKafka
func (*BusKafka) SetSubscriberOptions ¶
func (b *BusKafka) SetSubscriberOptions(opts ...eventbus.SubscriberOption) *BusKafka
type PublisherKafka ¶
type PublisherKafka struct {
// contains filtered or unexported fields
}
func NewPublisherKafka ¶
func NewPublisherKafka(addr []string, c codec.Codec) *PublisherKafka
func (*PublisherKafka) SetKafkaConfig ¶
func (p *PublisherKafka) SetKafkaConfig(c *sarama.Config) *PublisherKafka
func (*PublisherKafka) SetPublisherOptions ¶
func (p *PublisherKafka) SetPublisherOptions(opts ...eventbus.PublisherOption) *PublisherKafka
type SubscriberKafka ¶
type SubscriberKafka struct {
// contains filtered or unexported fields
}
func NewSubscriberKafka ¶
func NewSubscriberKafka(addr []string, c codec.Codec) *SubscriberKafka
func (*SubscriberKafka) Build ¶
func (s *SubscriberKafka) Build() eventbus.Subscriber
func (*SubscriberKafka) SetDuplicator ¶
func (s *SubscriberKafka) SetDuplicator(d eventbus.Duplicator) *SubscriberKafka
func (*SubscriberKafka) SetErrorHandler ¶
func (s *SubscriberKafka) SetErrorHandler(h messaging.ErrorHandler) *SubscriberKafka
func (*SubscriberKafka) SetErrorHandlerFunc ¶
func (s *SubscriberKafka) SetErrorHandlerFunc(h messaging.ErrorHandlerFunc) *SubscriberKafka
func (*SubscriberKafka) SetKafkaConfig ¶
func (s *SubscriberKafka) SetKafkaConfig(c *sarama.Config) *SubscriberKafka
func (*SubscriberKafka) SetListenOption ¶
func (s *SubscriberKafka) SetListenOption(opts ...messagingkafka.ReceiverOption) *SubscriberKafka
func (*SubscriberKafka) SetReBalanceHook ¶
func (s *SubscriberKafka) SetReBalanceHook(hook messagingkafka.Hook) *SubscriberKafka
func (*SubscriberKafka) SetSubscribeOptions ¶
func (s *SubscriberKafka) SetSubscribeOptions(opts ...eventbus.SubscriberOption) *SubscriberKafka
Click to show internal directories.
Click to hide internal directories.