queue

Documentation

Overview

Package queue implements a task queue.

Index

• type DomainAccessMessage
• type Queue
  • func OpenQueue() (*Queue, error)
  • func (q *Queue) Pop() (string, error)
  • func (q *Queue) Push(msg string) error

Types

type DomainAccessMessage

type DomainAccessMessage struct {
	Domain      string          `json:"domain"`
	RequestType dnsmessage.Type `json:"request_type"`
}

type Queue

type Queue struct {
	// contains filtered or unexported fields
}

Queue is a task queue.

func OpenQueue

func OpenQueue() (*Queue, error)

OpenQueue creates a new task queue.

func (*Queue) Pop

func (q *Queue) Pop() (string, error)

Pop pops a task and blocks if the queue is empty.

func (*Queue) Push

func (q *Queue) Push(msg string) error

Push pushes a new task to the queue.