pressure

Documentation

Index

• Variables
• type PressureQueue
  • func NewPressureQueue(pool *redis.Pool, prefix string, name string) (*PressureQueue, error)
  • func (pq *PressureQueue) Close() error
  • func (pq *PressureQueue) Create(bound int) error
  • func (pq *PressureQueue) Delete() error
  • func (pq *PressureQueue) Exists() (bool, error)
  • func (pq *PressureQueue) Get() (result []byte, e error)
  • func (pq *PressureQueue) GetBufferedReadChan(bufSize int) <-chan []byte
  • func (pq *PressureQueue) GetBufferedWriteChan(bufSize int) chan<- []byte
  • func (pq *PressureQueue) GetNonExclusively() (result []byte, e error)
  • func (pq *PressureQueue) GetReadChan() <-chan []byte
  • func (pq *PressureQueue) GetWriteChan() chan<- []byte
  • func (pq *PressureQueue) IsClosed() (bool, error)
  • func (pq *PressureQueue) Length() (int, error)
  • func (pq *PressureQueue) Put(buf []byte) error

Variables

var BOUND_NOT_SET int = -1

var ErrCreationFailure = errors.New("Unexpected failure during queue creation.")

var ErrPongFailure = errors.New("pressure: Redis did not return PONG")

var ErrQueueAlreadyExists = errors.New("Queue already exists.")

var ErrQueueDoesNotExist = errors.New("Queue does not exist.")

var ErrQueueIsClosed = errors.New("Queue is closed.")

var UNBOUNDED int = 0

Types

type PressureQueue

type PressureQueue struct {
	Pool       *redis.Pool
	Connection redis.Conn
	// contains filtered or unexported fields
}

func NewPressureQueue

func NewPressureQueue(pool *redis.Pool, prefix string, name string) (*PressureQueue, error)

func (*PressureQueue) Close

func (pq *PressureQueue) Close() error

func (*PressureQueue) Create

func (pq *PressureQueue) Create(bound int) error

func (*PressureQueue) Delete

func (pq *PressureQueue) Delete() error

func (*PressureQueue) Exists

func (pq *PressureQueue) Exists() (bool, error)

func (*PressureQueue) Get

func (pq *PressureQueue) Get() (result []byte, e error)

func (*PressureQueue) GetBufferedReadChan

func (pq *PressureQueue) GetBufferedReadChan(bufSize int) <-chan []byte

func (*PressureQueue) GetBufferedWriteChan

func (pq *PressureQueue) GetBufferedWriteChan(bufSize int) chan<- []byte

func (*PressureQueue) GetNonExclusively

func (pq *PressureQueue) GetNonExclusively() (result []byte, e error)

func (*PressureQueue) GetReadChan

func (pq *PressureQueue) GetReadChan() <-chan []byte

func (*PressureQueue) GetWriteChan

func (pq *PressureQueue) GetWriteChan() chan<- []byte

func (*PressureQueue) IsClosed

func (pq *PressureQueue) IsClosed() (bool, error)

func (*PressureQueue) Length

func (pq *PressureQueue) Length() (int, error)

func (*PressureQueue) Put

func (pq *PressureQueue) Put(buf []byte) error