redis消费队列接口优化
This commit is contained in:
@@ -6,9 +6,8 @@ type QueueMessage struct {
|
|||||||
StreamKey string // Stream 键名
|
StreamKey string // Stream 键名
|
||||||
GroupName string // 消费者组名称
|
GroupName string // 消费者组名称
|
||||||
ConsumerName string // 消费者名称
|
ConsumerName string // 消费者名称
|
||||||
Timeout int64 // 阻塞超时时间(毫秒)
|
|
||||||
BatchSize int64 // 最大并发数(信号量容量)
|
BatchSize int64 // 最大并发数(信号量容量)
|
||||||
BlockMs int64 // 阻塞时间
|
BlockMs int64 // 阻塞时间
|
||||||
AutoAck bool //ACK确认,true自动确认,false手动确认
|
AutoAck bool // ACK确认,true自动确认,false手动确认
|
||||||
HandleFunc func(ctx context.Context, message map[string]interface{}) error
|
HandleFunc func(ctx context.Context, message map[string]interface{}) error
|
||||||
}
|
}
|
||||||
|
|||||||
Reference in New Issue
Block a user