handlers

Documentation

Index

• Constants
• func EventHandler(rw http.ResponseWriter, r *http.Request)
• func GetRouter() *pat.Router
• func HealthHandler(rw http.ResponseWriter, r *http.Request)
• func RegisterCreateHandler(rw http.ResponseWriter, r *http.Request)
• func RegisterDeleteHandler(rw http.ResponseWriter, r *http.Request)
• type BaseResponse
• type EventDependencies
• type EventRequest
• type HealthDependencies
• type RegisterDependencies
• type RegisterRequest

Constants

const (
	GET                 = ".get"
	POST                = ".post"
	PUT                 = ".put"
	DELETE              = ".delete"
	CALLED              = ".called"
	SUCCESS             = ".success"
	STARTED             = ".started"
	PROCESS_REDELIVERY  = ".process_redelivery"
	DELETE_REGISTRATION = ".delete_registration"
	NO_ENDPOINT         = ".no_registered_endpoint"
	HANDLE              = ".handle"
	DISPATCH            = ".dispatch"
	NOT_FOUND           = ".not_found"
	ERROR               = ".server_error"
	INVALID_REQUEST     = ".request.invalid_request"
	BAD_REQUEST         = ".request.bad_request"
	VALID_REQUEST       = ".request.valid"
	INVALID_TOKEN       = ".auth.invalid_token"
	NOT_AUTHORISED      = ".auth.not_authorised"
	TOKEN_OK            = ".auth.token_ok"
	HEALTH_HANDLER      = "event_sauce.health"
	EVENT_HANDLER       = "event_sauce.event"
	REGISTER_HANDLER    = "event_sauce.register"
	EVENT_QUEUE         = "event_sauce.event_queue"
	DEAD_LETTER_QUEUE   = "event_sauce.dead_letter_queue"
	WORKER              = ".worker"
)

const EHTAGNAME = "EventHandler: "

const HHTAGNAME = "HealthHandler: "

const RHTAGNAME = "RegisterHandler: "

Functions

func EventHandler

func EventHandler(rw http.ResponseWriter, r *http.Request)

func GetRouter

func GetRouter() *pat.Router

func HealthHandler

func HealthHandler(rw http.ResponseWriter, r *http.Request)

func RegisterCreateHandler

func RegisterCreateHandler(rw http.ResponseWriter, r *http.Request)

func RegisterDeleteHandler

func RegisterDeleteHandler(rw http.ResponseWriter, r *http.Request)

Types

type BaseResponse

type BaseResponse struct {
	StatusEvent string `json:"status_event"`
}

type EventDependencies

type EventDependencies struct {
	// statsD interface must use a name type as injection cannot infer ducktypes
	Stats logging.StatsD `inject:"statsd"`
	Queue queue.Queue    `inject:"eventqueue"`
	Log   *log.Logger    `inject:""`
}

var EventHandlerDependencies *EventDependencies = &EventDependencies{}

type EventRequest

type EventRequest struct {
	EventName string          `json:"event_name"`
	Payload   json.RawMessage `json:"payload"`
}

type HealthDependencies

type HealthDependencies struct {
	// statsD interface must use a name type as injection cannot infer ducktypes
	Stats logging.StatsD `inject:"statsd"`
	Log   *log.Logger    `inject:""`
}

var HealthHandlerDependencies *HealthDependencies = &HealthDependencies{}

type RegisterDependencies

type RegisterDependencies struct {
	// statsD interface must use a name type as injection cannot infer ducktypes
	Stats logging.StatsD `inject:"statsd"`
	Dal   data.Dal       `inject:"dal"`
	Log   *log.Logger    `inject:""`
}

var RegisterHandlerDependencies *RegisterDependencies = &RegisterDependencies{}

type RegisterRequest

type RegisterRequest struct {
	EventName   string `json:"event_name"`
	CallbackUrl string `json:"callback_url"`
}