Documentation ¶
Index ¶
- Constants
- type BucketItem
- type DelayRedisQueue
- func (q *DelayRedisQueue) Get(ctx context.Context, jobId string) (*Job, error)
- func (q *DelayRedisQueue) Pop(ctx context.Context, topics []string) (*Job, error)
- func (q *DelayRedisQueue) Push(ctx context.Context, job Job) error
- func (q *DelayRedisQueue) Remove(ctx context.Context, jobId string) error
- type Job
Constants ¶
View Source
const (
DefaultQueueBlockTimeout = 10 * time.Second
)
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type BucketItem ¶
type BucketItem struct {
// contains filtered or unexported fields
}
BucketItem bucket中的元素
type DelayRedisQueue ¶
type DelayRedisQueue struct {
// contains filtered or unexported fields
}
func New ¶
func New(ctx context.Context, name string, bucketCnt int, redisClient *redis.Client) *DelayRedisQueue
Click to show internal directories.
Click to hide internal directories.