redisqueue

type Consumer struct {
	// Errors 用于上报消费过程中的错误；通道带缓冲，避免无人监听时阻塞主流程。
	Errors chan error
	// contains filtered or unexported fields
}

type ConsumerFunc func(*Message) error

type ConsumerOptions struct {
	Name              string
	GroupName         string
	VisibilityTimeout time.Duration
	BlockingTimeout   time.Duration
	ReclaimInterval   time.Duration
	BufferSize        int
	Concurrency       int
	RedisOptions      *RedisOptions
}

type Message struct {
	ID     string
	Stream string
	Values map[string]interface{}
}

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

type ProducerOptions struct {
	// StreamMaxLength 对应 XADD 的 MAXLEN 配置，用于限制 Stream 总长度，避免消息无限增长占满内存。
	// 这里限制的是 Stream 中的总消息数，而不是“已消费完成”的消息数。
	// 如果消费者全部不可用但生产者仍在持续入队，达到上限后较早的未处理消息也可能被裁剪。
	// 因此生产环境通常建议根据业务峰值将该值设置得更高。
	StreamMaxLength int64
	// ApproximateMaxLength 控制 MAXLEN 是否使用 `~` 近似裁剪，以换取更高的裁剪性能。
	ApproximateMaxLength bool
	// RedisOptions 底层 Redis 连接配置。
	RedisOptions *RedisOptions
}

type RedisOptions = redis.UniversalOptions