memqserver

Documentation

Index

• Variables
• type Broker
  • func NewBroker() *Broker
  • func (b *Broker) CreateQueue(name string) error
  • func (b *Broker) DeleteQueue(name string) error
  • func (b *Broker) DrainQueue(name string) error
  • func (b *Broker) GetMessage(queue string) (*memq.Message, error)
  • func (b *Broker) PutMessage(queue, body string) (*memq.Message, error)
  • func (b *Broker) Stats() *memq.Stats
• type Queue
• type Server
  • func NewServer(path string) *Server
  • func (s *Server) AddRoutes(router *httprouter.Router)
  • func (s *Server) CreateQueue(w http.ResponseWriter, r *http.Request, p httprouter.Params)
  • func (s *Server) DeleteQueue(w http.ResponseWriter, r *http.Request, p httprouter.Params)
  • func (s *Server) Dequeue(w http.ResponseWriter, r *http.Request, p httprouter.Params)
  • func (s *Server) DrainQueue(w http.ResponseWriter, r *http.Request, p httprouter.Params)
  • func (s *Server) Enqueue(w http.ResponseWriter, r *http.Request, p httprouter.Params)
  • func (s *Server) GetStats(w http.ResponseWriter, r *http.Request, _ httprouter.Params)

Variables

var ErrAlreadyExist = errors.New("already exists")

var ErrEmptyName = errors.New("empty name")

var ErrEmptyQueue = errors.New("empty queue")

var ErrNotExist = errors.New("does not exist")

Types

type Broker

type Broker struct {
	Queues map[string]*Queue
	// contains filtered or unexported fields
}

func NewBroker

func NewBroker() *Broker

func (*Broker) CreateQueue

func (b *Broker) CreateQueue(name string) error

func (*Broker) DeleteQueue

func (b *Broker) DeleteQueue(name string) error

func (*Broker) DrainQueue

func (b *Broker) DrainQueue(name string) error

func (*Broker) GetMessage

func (b *Broker) GetMessage(queue string) (*memq.Message, error)

func (*Broker) PutMessage

func (b *Broker) PutMessage(queue, body string) (*memq.Message, error)

func (*Broker) Stats

func (b *Broker) Stats() *memq.Stats

type Queue

type Queue struct {
	Depth    int64
	Enqueued int64
	Dequeued int64
	Drained  int64
	Messages []*memq.Message
	// contains filtered or unexported fields
}

type Server

type Server struct {
	// contains filtered or unexported fields
}

func NewServer

func NewServer(path string) *Server

func (*Server) AddRoutes

func (s *Server) AddRoutes(router *httprouter.Router)

func (*Server) CreateQueue

func (s *Server) CreateQueue(w http.ResponseWriter, r *http.Request, p httprouter.Params)

func (*Server) DeleteQueue

func (s *Server) DeleteQueue(w http.ResponseWriter, r *http.Request, p httprouter.Params)

func (*Server) Dequeue

func (s *Server) Dequeue(w http.ResponseWriter, r *http.Request, p httprouter.Params)

func (*Server) DrainQueue

func (s *Server) DrainQueue(w http.ResponseWriter, r *http.Request, p httprouter.Params)

func (*Server) Enqueue

func (s *Server) Enqueue(w http.ResponseWriter, r *http.Request, p httprouter.Params)

func (*Server) GetStats

func (s *Server) GetStats(w http.ResponseWriter, r *http.Request, _ httprouter.Params)