queue

Documentation

Index

• func Close(k QueueKey) error
• func Pop(k QueueKey) (error, []byte)
• func PopTimeout(k QueueKey, timeoutInSeconds time.Duration) (error, []byte)
• func Push(k QueueKey, v []byte) error
• func ReadChan(k QueueKey) chan []byte
• func Register(h Queue)
• type Queue
• type QueueKey

Functions

func Close

func Close(k QueueKey) error

func Pop

func Pop(k QueueKey) (error, []byte)

func PopTimeout

func PopTimeout(k QueueKey, timeoutInSeconds time.Duration) (error, []byte)

func Push

func Push(k QueueKey, v []byte) error

func ReadChan

func ReadChan(k QueueKey) chan []byte

func Register

func Register(h Queue)

Types

type Queue

type Queue interface {
	Push(QueueKey, []byte) error
	Pop(QueueKey, time.Duration) (error, []byte)
	ReadChan(k QueueKey) chan []byte
	Close(QueueKey) error
}

type QueueKey

type QueueKey string