Documentation ¶
Index ¶
- type FileQueue
- type MemoryQueue
- func (sq *MemoryQueue) Add(ctx context.Context, element string) error
- func (sq *MemoryQueue) Close(ctx context.Context) error
- func (sq *MemoryQueue) Len(ctx context.Context) (int, error)
- func (sq *MemoryQueue) Open(ctx context.Context) error
- func (sq *MemoryQueue) Remove(ctx context.Context) (string, error)
- type Queue
- type RabbitMQQueue
- func (sq *RabbitMQQueue) Add(ctx context.Context, element string) error
- func (sq *RabbitMQQueue) Close(ctx context.Context) error
- func (sq *RabbitMQQueue) Len(ctx context.Context) (int, error)
- func (sq *RabbitMQQueue) Open(ctx context.Context) error
- func (sq *RabbitMQQueue) Remove(ctx context.Context) (string, error)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type FileQueue ¶
type FileQueue struct { MemoryQueue // contains filtered or unexported fields }
func NewFileQueue ¶
type MemoryQueue ¶
type MemoryQueue struct {
// contains filtered or unexported fields
}
func NewMemoryQueueFromFile ¶
func NewMemoryQueueFromFile(fileName string) (*MemoryQueue, error)
type RabbitMQQueue ¶
type RabbitMQQueue struct {
// contains filtered or unexported fields
}
func NewRabbitMQQueue ¶
func NewRabbitMQQueue(uri, queue string) (*RabbitMQQueue, error)
Click to show internal directories.
Click to hide internal directories.