queue

Documentation

Index

• type ConsumeMsgHandler
• type MsgInfo
• type SQueue
  • func NewSQueue(c *rredis.Redis) *SQueue
  • func (s *SQueue) Consume(ctx context.Context, topic, group, consumer string, batchSize int, ...) error
  • func (s *SQueue) Count(ctx context.Context, topic string) int64
  • func (s *SQueue) Publish(ctx context.Context, topic string, msg map[string]interface{}) error
  • func (s *SQueue) SetMaxCount(ctx context.Context, topic string, max int64) error

Types

type ConsumeMsgHandler

type ConsumeMsgHandler func(info *MsgInfo, msg map[string]interface{}) error

type MsgInfo

type MsgInfo struct {
	Topic    string
	Group    string
	Consumer string
	MsgId    string
}

type SQueue

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

func NewSQueue

func NewSQueue(c *rredis.Redis) *SQueue

func (*SQueue) Consume

func (s *SQueue) Consume(ctx context.Context, topic, group, consumer string, batchSize int, handler ConsumeMsgHandler) error

func (*SQueue) Count

func (s *SQueue) Count(ctx context.Context, topic string) int64

func (*SQueue) Publish

func (s *SQueue) Publish(ctx context.Context, topic string, msg map[string]interface{}) error

func (*SQueue) SetMaxCount

func (s *SQueue) SetMaxCount(ctx context.Context, topic string, max int64) error