memqueue

Documentation

Index

• func NewClient(cfg config.Configuration) (queue.Storage, taskq.Factory, error)
• func NewQueue(opts queue.QueueOptions) queue.Queuer
• type MemQueue
  • func (q *MemQueue) Close() error
  • func (q *MemQueue) Consumer() taskq.QueueConsumer
  • func (q *MemQueue) Length() (int, error)
  • func (q *MemQueue) WriteEvent(ctx context.Context, name convoy.TaskName, e *datastore.Event, ...) error
  • func (q *MemQueue) WriteEventDelivery(ctx context.Context, name convoy.TaskName, e *datastore.EventDelivery, ...) error

Functions

func NewClient

func NewClient(cfg config.Configuration) (queue.Storage, taskq.Factory, error)

func NewQueue

func NewQueue(opts queue.QueueOptions) queue.Queuer

Types

type MemQueue

type MemQueue struct {
	Name string
	// contains filtered or unexported fields
}

func (*MemQueue) Close

func (q *MemQueue) Close() error

func (*MemQueue) Consumer

func (q *MemQueue) Consumer() taskq.QueueConsumer

func (*MemQueue) Length

func (q *MemQueue) Length() (int, error)

func (*MemQueue) WriteEvent

func (q *MemQueue) WriteEvent(ctx context.Context, name convoy.TaskName, e *datastore.Event, delay time.Duration) error

func (*MemQueue) WriteEventDelivery

func (q *MemQueue) WriteEventDelivery(ctx context.Context, name convoy.TaskName, e *datastore.EventDelivery, delay time.Duration) error