dirq

Documentation

Overview

Packge dirq provides a directory+files based multiple provider, single consumer persistent queue.

Index

• Variables
• type Queue
  • func New(dir string) (Queue, error)
  • func (Q Queue) Dequeue(ctx context.Context, f func(context.Context, []byte) error) error
  • func (Q Queue) Enqueue(p []byte) error
  • func (Q Queue) Watch(ctx context.Context, f func(context.Context, []byte) error) error

Variables

var ErrEmpty = errors.New("queue is empty")

Types

type Queue

type Queue struct {
	Dir string
}

func New

func New(dir string) (Queue, error)

func (Queue) Dequeue

func (Q Queue) Dequeue(ctx context.Context, f func(context.Context, []byte) error) error

DequeueOne will call f on the first dequeueable message. The message will be deleted iff f returns nil, otherwise it remains in the queue.

func (Queue) Enqueue

func (Q Queue) Enqueue(p []byte) error

func (Queue) Watch

func (Q Queue) Watch(ctx context.Context, f func(context.Context, []byte) error) error

Dequeue all the incoming messages, continuously.

Calls DequeueOne when a new message arrives (based on notification).