queue

Documentation

Index

• Variables
• type Queue
  • func Init() (Queue, error)

Variables

var (
	ErrStringAlreadyInQueue = errors.New("string already in queue")
)

Types

type Queue

type Queue interface {
	Cleanup() error
	AddTask(string) error
	GetTask() (string, error)
	IsInQueue(string) (bool, error)
	MarkAsProcessed(string) error
	IsProcessed(string) (bool, error)
}

func Init

func Init() (Queue, error)

Init opens existing queue or creates a new one and returns the queue instance Don't forget to call defer queue.Cleanup() in appropriate place!