15 lines
416 B
Go
15 lines
416 B
Go
|
package redis
|
||
|
|
|
||
|
|
import "context"
|
||
|
|
|
||
|
|
type QueueMessage struct {
|
||
|
|
StreamKey string // Stream 键名
|
||
|
|
GroupName string // 消费者组名称
|
||
|
|
ConsumerName string // 消费者名称
|
||
|
|
Timeout int64 // 阻塞超时时间（毫秒）
|
||
|
|
BatchSize int64 // 最大并发数（信号量容量）
|
||
|
|
BlockMs int64
|
||
|
|
Block bool
|
||
|
|
HandleFunc func(ctx context.Context, message map[string]interface{}) error
|
||
|
|
}
|