Documentation

Overview

    Package queue implements a Pub/Sub channel in tsuru. It abstracts which server is being used and handles connection pooling and data transmiting

    Index

    Constants

    This section is empty.

    Variables

    This section is empty.

    Functions

    func Queue

    func Queue() (monsterqueue.Queue, error)

    func ResetQueue

    func ResetQueue()

    func TestingWaitQueueTasks

    func TestingWaitQueueTasks(n int, timeout time.Duration) error

    Types

    This section is empty.

    Source Files