Documentation ¶
Index ¶
- type Queue
- func (q *Queue) Peek(ctx context.Context, queueName string, count int64) ([]*queue.WebRequest, error)
- func (q *Queue) Pop(ctx context.Context, queueName string, timeout time.Duration) (*queue.WebRequest, error)
- func (q *Queue) Push(ctx context.Context, queueName string, webRequests []*queue.WebRequest) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Queue ¶
Queue is a queue
func (*Queue) Peek ¶
func (q *Queue) Peek(ctx context.Context, queueName string, count int64) ([]*queue.WebRequest, error)
Peek show the next few items in the queue
Click to show internal directories.
Click to hide internal directories.