api

Documentation

Index

• Constants
• Variables
• func Authenticate(next http.Handler) http.Handler
• func Handler() *mux.Router
• type QueueManager
  • func (qm *QueueManager) Dispatch(queue string, key string)
  • func (qm *QueueManager) Pop(msgQueue string)

Constants

const (
	BufferedChanLen int = 10
)

Variables

var (
	Hub = hub{
		// contains filtered or unexported fields
	}
)

Functions

func Authenticate

func Authenticate(next http.Handler) http.Handler

func Handler

func Handler() *mux.Router

Types

type QueueManager

type QueueManager struct {
}

just a place holder

func (*QueueManager) Dispatch

func (qm *QueueManager) Dispatch(queue string, key string)

dispatch pops an envelope from shared queue and pushes to all servers' queues. queue is the shared queue

func (*QueueManager) Pop

func (qm *QueueManager) Pop(msgQueue string)