stanq

Documentation

Index

• func MustNewConsumerManager(cfg *StanqConfig, cq []*ConsumerQueue) queue.MessageQueue
• type ConsumeHandle
• type ConsumeHandler
• type ConsumerManager
  • func (cm *ConsumerManager) Start()
  • func (cm *ConsumerManager) Stop()
• type ConsumerQueue
• type Producer
  • func NewProducer(c *StanqConfig) (*Producer, error)
  • func (p *Producer) AsyncPublish(subject string, data []byte, ackHandler func(guid string, err error)) (string, error)
  • func (p *Producer) Close()
  • func (p *Producer) Publish(subject string, data []byte) error
• type StanqConfig

Functions

func MustNewConsumerManager

func MustNewConsumerManager(cfg *StanqConfig, cq []*ConsumerQueue) queue.MessageQueue

MustNewConsumerManager

Types

type ConsumeHandle

type ConsumeHandle func(m *stan.Msg) error

type ConsumeHandler

type ConsumeHandler interface {
	HandleMessage(m *stan.Msg) error
}

ConsumeHandler Consumer interface, used to define the methods required by the consumer

type ConsumerManager

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

ConsumerManager Consumer manager for managing multiple consumer queues

func (*ConsumerManager) Start

func (cm *ConsumerManager) Start()

Start consuming messages in the queue

func (*ConsumerManager) Stop

func (cm *ConsumerManager) Stop()

Stop close connect

type ConsumerQueue

type ConsumerQueue struct {
	GroupName     string                    // consumer group name
	QueueName     string                    // queue name
	Subject       string                    // Subscribe subject
	Consumer      ConsumeHandler            // consumer object
	AckWaitTime   int                       // Waiting time for Ack
	MaxInflight   int                       // Maximum number of unacked messages
	ManualAckMode bool                      //Whether to manually ack
	Options       []stan.SubscriptionOption // Subscription configuration item
}

ConsumerQueue Consumer queue, used to maintain the relationship between a consumer group and queue

type Producer

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

func NewProducer

func NewProducer(c *StanqConfig) (*Producer, error)

func (*Producer) AsyncPublish

func (p *Producer) AsyncPublish(subject string, data []byte, ackHandler func(guid string, err error)) (string, error)

func (*Producer) Close

func (p *Producer) Close()

func (*Producer) Publish

func (p *Producer) Publish(subject string, data []byte) error

type StanqConfig

type StanqConfig struct {
	ClusterID string        `json:"cluster_id"`
	ClientID  string        `json:"client_id"`
	Options   []stan.Option `json:"options"`
}