handler

Documentation

Overview

Package handler contains http handlers.

Index

• func Ack(w http.ResponseWriter, r *http.Request) error
• func BlockQueue(w http.ResponseWriter, r *http.Request) error
• func DeleteQueue(w http.ResponseWriter, r *http.Request) error
• func DequeueJobs(w http.ResponseWriter, r *http.Request) error
• func Func(fn func(w http.ResponseWriter, r *http.Request) error) http.HandlerFunc
• func GetJobByID(w http.ResponseWriter, r *http.Request) error
• func GetQueueByID(w http.ResponseWriter, r *http.Request) error
• func GetQueueByJobID(w http.ResponseWriter, r *http.Request) error
• func ListJobs(w http.ResponseWriter, r *http.Request) error
• func ListQueues(w http.ResponseWriter, r *http.Request) error
• func MarshalResponse(w http.ResponseWriter, r *http.Request, v proto.Message) error
• func MethodNotAllowed(w http.ResponseWriter, r *http.Request) error
• func NotFound(w http.ResponseWriter, r *http.Request) error
• func PauseQueue(w http.ResponseWriter, r *http.Request) error
• func SaveQueue(w http.ResponseWriter, r *http.Request) error
• func Stats(w http.ResponseWriter, r *http.Request) error
• func UnblockQueue(w http.ResponseWriter, r *http.Request) error
• func UnmarshalBody(r *http.Request, v interface{}, required bool) error
• func UnpauseQueue(w http.ResponseWriter, r *http.Request) error
• type EnqueueJobs
  • func (h *EnqueueJobs) ServeHTTP(w http.ResponseWriter, r *http.Request)

Functions

func Ack

func Ack(w http.ResponseWriter, r *http.Request) error

func BlockQueue

func BlockQueue(w http.ResponseWriter, r *http.Request) error

func DeleteQueue

func DeleteQueue(w http.ResponseWriter, r *http.Request) error

func DequeueJobs

func DequeueJobs(w http.ResponseWriter, r *http.Request) error

func Func

func Func(fn func(w http.ResponseWriter, r *http.Request) error) http.HandlerFunc

func GetJobByID

func GetJobByID(w http.ResponseWriter, r *http.Request) error

func GetQueueByID

func GetQueueByID(w http.ResponseWriter, r *http.Request) error

func GetQueueByJobID

func GetQueueByJobID(w http.ResponseWriter, r *http.Request) error

func ListJobs

func ListJobs(w http.ResponseWriter, r *http.Request) error

func ListQueues

func ListQueues(w http.ResponseWriter, r *http.Request) error

func MarshalResponse

func MarshalResponse(w http.ResponseWriter, r *http.Request, v proto.Message) error

func MethodNotAllowed

func MethodNotAllowed(w http.ResponseWriter, r *http.Request) error

func NotFound

func NotFound(w http.ResponseWriter, r *http.Request) error

func PauseQueue

func PauseQueue(w http.ResponseWriter, r *http.Request) error

func SaveQueue

func SaveQueue(w http.ResponseWriter, r *http.Request) error

func Stats

func Stats(w http.ResponseWriter, r *http.Request) error

func UnblockQueue

func UnblockQueue(w http.ResponseWriter, r *http.Request) error

func UnmarshalBody

func UnmarshalBody(r *http.Request, v interface{}, required bool) error

func UnpauseQueue

func UnpauseQueue(w http.ResponseWriter, r *http.Request) error

Types

type EnqueueJobs

type EnqueueJobs struct {
}

func (*EnqueueJobs) ServeHTTP

func (h *EnqueueJobs) ServeHTTP(w http.ResponseWriter, r *http.Request)