redisqueue

type DeadQueueInfo struct {
	Stop bool
}

type HandleFunc func(stream, key, val, msgId string) error

type IQueue interface {
	Info() *QueueInfo
	Handle(stream, key, val, msgId string) error
}

type QueueInfo struct {
	UserQueueInfo  *UserQueueInfo
	RetryQueueInfo *RetryQueueInfo
	DeadQueueInfo  *DeadQueueInfo
	NotifyErr      func(stream, key string, err error)
	NotifyPanic    func(pnc any, stack string)
	// contains filtered or unexported fields
}

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

type RetryQueueInfo struct {
	Stop        bool
	Tick        time.Duration
	MinRetry    int64
	MinIdleTime time.Duration
	BatchSize   int64
	NotifyDead  func(stream, key, val, msgId string)
	// contains filtered or unexported fields
}

type TrimInfo struct {
	Streams     []string
	Tick        time.Duration
	MaxLen      int64
	MaxDuration time.Duration
	Limit       int64
}

type UserQueueInfo struct {
	Streams       []string
	Group         string
	ConsumerSize  int
	BatchSize     int64
	NewGroupStart string
	// contains filtered or unexported fields
}