cons

Documentation

Index

• type Consumer
  • func New() *Consumer
  • func (this *Consumer) NewConsumer(servers []string, groupName string) error
  • func (this *Consumer) NewCustomConsumer(opts ...consumer.Option) error
  • func (this *Consumer) Shutdown() error
  • func (this *Consumer) Start() error
  • func (this *Consumer) Subscribe(topic string, _receiver OnReceiver) error
• type OnReceiver

Types

type Consumer

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

func New

func New() *Consumer

func (*Consumer) NewConsumer

func (this *Consumer) NewConsumer(servers []string, groupName string) error

func (*Consumer) NewCustomConsumer

func (this *Consumer) NewCustomConsumer(opts ...consumer.Option) error

func (*Consumer) Shutdown

func (this *Consumer) Shutdown() error

func (*Consumer) Start

func (this *Consumer) Start() error

func (*Consumer) Subscribe

func (this *Consumer) Subscribe(topic string, _receiver OnReceiver) error

type OnReceiver

type OnReceiver func(msg *primitive.MessageExt)