handlers

Documentation

Index

• Constants
• func InitializeRouterForHealthCheckHandler(r *mux.Router, pool *disque.DisquePool)
• func InitializeRouterForMessageHandlers(r *mux.Router, parser *parser.AprsParser, pool *disque.DisquePool)
• func InitializeRouterForQueryHandlers(r *mux.Router, database *db.Database)
• type HealthCheckHandler
  • func NewHealthCheckHandler(pool *disque.DisquePool) *HealthCheckHandler
  • func (h *HealthCheckHandler) HealthCheck(resp http.ResponseWriter, req *http.Request)
• type MessageHandler
  • func NewMessageHandler(parser *parser.AprsParser, pool *disque.DisquePool) *MessageHandler
  • func (m *MessageHandler) SubmitAPRSMessage(resp http.ResponseWriter, req *http.Request)
• type QueryHandler
• type TokenVerificationMiddleware
  • func NewTokenVerificationMiddleware() *TokenVerificationMiddleware
  • func (t *TokenVerificationMiddleware) Initialize()
  • func (t *TokenVerificationMiddleware) Run(rw http.ResponseWriter, r *http.Request, next http.HandlerFunc)

Constants

const (
	APRS_MESSAGES_QUEUE_NAME = "aprs_messages"
)

Functions

func InitializeRouterForHealthCheckHandler

func InitializeRouterForHealthCheckHandler(r *mux.Router, pool *disque.DisquePool)

Add routes to router

func InitializeRouterForMessageHandlers

func InitializeRouterForMessageHandlers(r *mux.Router, parser *parser.AprsParser, pool *disque.DisquePool)

func InitializeRouterForQueryHandlers

func InitializeRouterForQueryHandlers(r *mux.Router, database *db.Database)

Types

type HealthCheckHandler

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

func NewHealthCheckHandler

func NewHealthCheckHandler(pool *disque.DisquePool) *HealthCheckHandler

func (*HealthCheckHandler) HealthCheck

func (h *HealthCheckHandler) HealthCheck(resp http.ResponseWriter, req *http.Request)

Examine and report the health of the component and dependencies

type MessageHandler

type MessageHandler struct {
	PoolTimeout time.Duration
	// contains filtered or unexported fields
}

func NewMessageHandler

func NewMessageHandler(parser *parser.AprsParser, pool *disque.DisquePool) *MessageHandler

func (*MessageHandler) SubmitAPRSMessage

func (m *MessageHandler) SubmitAPRSMessage(resp http.ResponseWriter, req *http.Request)

type QueryHandler

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

type TokenVerificationMiddleware

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

func NewTokenVerificationMiddleware

func NewTokenVerificationMiddleware() *TokenVerificationMiddleware

func (*TokenVerificationMiddleware) Initialize

func (t *TokenVerificationMiddleware) Initialize()

func (*TokenVerificationMiddleware) Run

func (t *TokenVerificationMiddleware) Run(rw http.ResponseWriter, r *http.Request, next http.HandlerFunc)