bdb

package
v0.0.0-...-aba326a Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jun 26, 2017 License: Apache-2.0 Imports: 9 Imported by: 0

Documentation

Overview

Package bdb provides a FIFO queue backed by a BoltDB database.

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func New

func New(db *bolt.DB, o ...Option) (q.Queue, error)

New creates a new BoltDB backed FIFO queue.

func Open

func Open(db *bolt.DB, id uuid.UUID) (q.Queue, error)

Open an existing BoltDB backed FIFO queue.

Types

type Option

type Option func(*bdb)

An Option represents an optional argument to a new BoltDB queue.

func Limit

func Limit(l int) Option

Limit specifies the maximum number of messages that may exist in a queue. Unbounded queues will accept messages until they exhaust available resources.

func Tagged

func Tagged(t ...q.Tag) Option

Tagged applies the provided tags to a new queue.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL