common/redis/message.go

package redis

import "context"

type QueueMessage struct {
	StreamKey    string // Stream 键名
	GroupName    string // 消费者组名称
	ConsumerName string // 消费者名称
	BatchSize    int64  // 最大并发数（信号量容量）
	BlockMs      int64  // 阻塞时间
	AutoAck      bool   // ACK确认,true自动确认,false手动确认
	HandleFunc   func(ctx context.Context, message map[string]interface{}) error
}