Documentation
¶
Overview ¶
Package memqueue provides an in-memory Queue implementation for testing.
Index ¶
- type Queue
- func (q *Queue) Close() error
- func (q *Queue) Dequeue(ctx context.Context) (*commandqueue.Claim, error)
- func (q *Queue) Enqueue(_ context.Context, cmd commandqueue.EnqueuedCommand) (string, error)
- func (q *Queue) EnqueueAndWait(ctx context.Context, cmd commandqueue.EnqueuedCommand, timeout time.Duration) (*commandqueue.Result, error)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Queue ¶
type Queue struct {
// contains filtered or unexported fields
}
Queue is an in-memory implementation of commandqueue.Queue.
func (*Queue) Enqueue ¶
func (q *Queue) Enqueue(_ context.Context, cmd commandqueue.EnqueuedCommand) (string, error)
func (*Queue) EnqueueAndWait ¶
func (q *Queue) EnqueueAndWait(ctx context.Context, cmd commandqueue.EnqueuedCommand, timeout time.Duration) (*commandqueue.Result, error)
Source Files
Click to show internal directories.
Click to hide internal directories.