task_queue

type ConsumerFunc func(Delivery)

type Delivery interface {
	// Payload 消息内容
	Payload() string
}

type OptionFunc func(*TaskQueueEntity)

type Queue interface {
	// Publish 推送消息
	Publish(payload string) error
	// AddConsumerFunc 添加消费者函数
	AddConsumerFunc(consumerFunc ConsumerFunc)
	// StartConsuming 开启消费
	StartConsuming() error
}

type TaskQueueEntity struct {
	Name                   string         // 名称
	QueueKey               string         // 队列Key，根据名称计算
	MaxQueueConcurrencyNum int64          // 并发处理数
	RedisConn              *redis.Client  // Redis 连接
	ConsumerFuncs          []ConsumerFunc // 消息处理方法
	MaxQueueLen            int64          // 队列最大长度
	// contains filtered or unexported fields
}