publish

Documentation

Index

• func New() *queue
• type Message
• type Queue

Functions

func New

func New() *queue

Types

type Message

type Message struct {
	Tenant  string
	Publish *packet.Publish
}

type Queue

type Queue interface {
	Enqueue(p *Message)
	Pop() *Message
}