rocket

Documentation

Index

• type Consumer
  • func NewConsumer(ctx context.Context, nameServer []string, namespace string, groupId string, ...) (*Consumer, error)
  • func (c *Consumer) Close(ctx context.Context) error
  • func (c *Consumer) Start(ctx context.Context) error
  • func (c *Consumer) Subscribe(ctx context.Context, topic string, tag string, ...) error
  • func (c *Consumer) Unsubscribe(ctx context.Context, topic string) error
• type Producer
  • func NewProducer(ctx context.Context, nameServer []string, namespace string, groupId string, ...) (*Producer, error)
  • func (p *Producer) Close(ctx context.Context) error
  • func (p *Producer) SendMsg(ctx context.Context, topic string, msg *message.Producer) error
  • func (p *Producer) Start(ctx context.Context) error
• type ProducerHashSelector
  • func NewProducerHashSelector() *ProducerHashSelector
  • func (m *ProducerHashSelector) Select(message *primitive.Message, queues []*primitive.MessageQueue) *primitive.MessageQueue

Types

type Consumer

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

func NewConsumer

func NewConsumer(ctx context.Context, nameServer []string, namespace string, groupId string, options ...option.ConsumerFunc) (*Consumer, error)

func (*Consumer) Close

func (c *Consumer) Close(ctx context.Context) error

func (*Consumer) Start

func (c *Consumer) Start(ctx context.Context) error

func (*Consumer) Subscribe

func (c *Consumer) Subscribe(ctx context.Context, topic string, tag string, f func(context.Context, ...*message.Consumer) bool) error

func (*Consumer) Unsubscribe

func (c *Consumer) Unsubscribe(ctx context.Context, topic string) error

type Producer

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

func NewProducer

func NewProducer(ctx context.Context, nameServer []string, namespace string, groupId string, options ...option.ProducerFunc) (*Producer, error)

func (*Producer) Close

func (p *Producer) Close(ctx context.Context) error

func (*Producer) SendMsg

func (p *Producer) SendMsg(ctx context.Context, topic string, msg *message.Producer) error

func (*Producer) Start

func (p *Producer) Start(ctx context.Context) error

type ProducerHashSelector

type ProducerHashSelector struct {
	RoundRobin producer.QueueSelector
}

func NewProducerHashSelector

func NewProducerHashSelector() *ProducerHashSelector

func (*ProducerHashSelector) Select

func (m *ProducerHashSelector) Select(message *primitive.Message, queues []*primitive.MessageQueue) *primitive.MessageQueue