queue

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

• func Queue() (monsterqueue.Queue, error)
• func ResetQueue()
• func TestingWaitQueueTasks(n int, timeout time.Duration) error

Functions

func Queue

func Queue() (monsterqueue.Queue, error)

func ResetQueue

func ResetQueue()

func TestingWaitQueueTasks

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