streamredis

type Consumer struct {
	EnableDeadLetter bool //开启死信队列
	DeadLetterQueue  string
	// contains filtered or unexported fields
}

type ConsumerOptions struct {
	DeadLetterQueue   string `json:"deadletter_queue"  yaml:"deadletter_queue"`    //开启死信队列
	Concurrency       int    `json:"concurrency" yaml:"concurrency"`               //并发的消费者数量
	BufferSize        int    `json:"buffer_size" yaml:"buffer_size"`               //队列长度
	BlockingTimeout   int    `json:"blocking_timeout" yaml:"blocking_timeout"`     //获取消息阻塞时间秒
	VisibilityTimeout int    `json:"visibility_timeout" yaml:"visibility_timeout"` //消息保留时间 秒
	ReclaimInterval   int    `json:"reclaim_interval" yaml:"reclaim_interval"`     //失败消息重试周期
	GroupName         string `json:"group_name" yaml:"group_name"`
}

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

type ProductOptions struct {
	StreamMaxLength      int64 `json:"stream_max_len" yaml:"stream_max_len"`           //消息队列长度
	ApproximateMaxLength bool  `json:"approximate_max_len" yaml:"approximate_max_len"` //使用近似队列长度
	DelayInterval        int   `json:"delay_interval" yaml:"delay_interval"`
}

type QueueItem struct {
	QueueName         string
	Concurrency       int
	BufferSize        int
	VisibilityTimeout time.Duration
	// contains filtered or unexported fields
}