server

Documentation

Index

• func NotFoundHandler() http.Handler
• type Application
• type Server
  • func New(app Application) *Server
  • func (s *Server) BatchTopicHandler(w http.ResponseWriter, r *http.Request)
  • func (s *Server) HealthHandler(w http.ResponseWriter, r *http.Request)
  • func (s *Server) ServeHTTP(w http.ResponseWriter, r *http.Request)
  • func (s *Server) TopicHandler(w http.ResponseWriter, r *http.Request)

Functions

func NotFoundHandler

func NotFoundHandler() http.Handler

NotFoundHandler returns a 404.

Types

type Application

type Application interface {
	// Get the next message from the queue.
	GetNextMessage(ctx context.Context, topic string) ([]byte, error)
	// GetNextBatch gets the next count messages from the queue.
	GetNextBatch(ctx context.Context, topic string, count int) ([][]byte, error)
	// IsHealthy checks the health of the Application.
	IsHealthy() error
}

Application represents the main application.

type Server

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

Server represents a http server handler.

func New

func New(app Application) *Server

New creates a new Server instance.

func (*Server) BatchTopicHandler

func (s *Server) BatchTopicHandler(w http.ResponseWriter, r *http.Request)

TopicHandler handles requests to for messages.

func (*Server) HealthHandler

func (s *Server) HealthHandler(w http.ResponseWriter, r *http.Request)

HealthHandler handles health requests.

func (*Server) ServeHTTP

func (s *Server) ServeHTTP(w http.ResponseWriter, r *http.Request)

ServeHTTP dispatches the request to the handler whose pattern most closely matches the request URL.

func (*Server) TopicHandler

func (s *Server) TopicHandler(w http.ResponseWriter, r *http.Request)

TopicHandler handles requests to for messages.