controllers

Documentation

Index

• func AddRequest(c *gin.Context, rq *requestq.RQ) (result requestq.Result, err error)
• func ClearQueue(c *gin.Context, rq *requestq.RQ) (requestq.Result, error)
• func DeleteQueue(c *gin.Context, rq *requestq.RQ) (requestq.Result, error)
• func GetRequest(c *gin.Context, rq *requestq.RQ) (requestq.Result, error)
• func Info(c *gin.Context, rq *requestq.RQ) (requestq.Result, error)
• func Pause(c *gin.Context, rq *requestq.RQ) (requestq.Result, error)
• func PauseQueue(c *gin.Context, rq *requestq.RQ) (requestq.Result, error)
• func ProcessMemory(c *gin.Context, rq *requestq.RQ) (requestq.Result, error)
• func QueueIDFromQuery(q string) (qid requestq.QueueID, err error)
• func QueueInfo(c *gin.Context, rq *requestq.RQ) (requestq.Result, error)
• func Queues(c *gin.Context, rq *requestq.RQ) (result requestq.Result, err error)
• func RedisInfo(c *gin.Context, rq *requestq.RQ) (requestq.Result, error)
• func RedisMemory(c *gin.Context, rq *requestq.RQ) (requestq.Result, error)
• func Resume(c *gin.Context, rq *requestq.RQ) (requestq.Result, error)
• func ResumeQueue(c *gin.Context, rq *requestq.RQ) (requestq.Result, error)
• func SyncQueue(c *gin.Context, rq *requestq.RQ) (requestq.Result, error)
• func ViewQueue(c *gin.Context, rq *requestq.RQ) (result requestq.Result, err error)
• type CtrlFunc
• type HandlerWrapper
  • func NewHandlerWrapper(rq *requestq.RQ) *HandlerWrapper
  • func (wp *HandlerWrapper) Wrap(f CtrlFunc) gin.HandlerFunc
• type InvalidBody
  • func (e InvalidBody) Error() string
• type InvalidQuery
  • func (e InvalidQuery) Error() string

Functions

func AddRequest

func AddRequest(c *gin.Context, rq *requestq.RQ) (result requestq.Result, err error)

AddRequest TODO

func ClearQueue

func ClearQueue(c *gin.Context, rq *requestq.RQ) (requestq.Result, error)

ClearQueue TODO

func DeleteQueue

func DeleteQueue(c *gin.Context, rq *requestq.RQ) (requestq.Result, error)

DeleteQueue TODO

func GetRequest

func GetRequest(c *gin.Context, rq *requestq.RQ) (requestq.Result, error)

GetRequest TODO

func Info

func Info(c *gin.Context, rq *requestq.RQ) (requestq.Result, error)

Info TODO

func Pause

func Pause(c *gin.Context, rq *requestq.RQ) (requestq.Result, error)

Pause TODO

func PauseQueue

func PauseQueue(c *gin.Context, rq *requestq.RQ) (requestq.Result, error)

PauseQueue TODO

func ProcessMemory

func ProcessMemory(c *gin.Context, rq *requestq.RQ) (requestq.Result, error)

ProcessMemory TODO

func QueueIDFromQuery

func QueueIDFromQuery(q string) (qid requestq.QueueID, err error)

QueueIDFromQuery TODO

func QueueInfo

func QueueInfo(c *gin.Context, rq *requestq.RQ) (requestq.Result, error)

QueueInfo TODO

func Queues

func Queues(c *gin.Context, rq *requestq.RQ) (result requestq.Result, err error)

Queues TODO

func RedisInfo

func RedisInfo(c *gin.Context, rq *requestq.RQ) (requestq.Result, error)

RedisInfo TODO

func RedisMemory

func RedisMemory(c *gin.Context, rq *requestq.RQ) (requestq.Result, error)

RedisMemory TODO

func Resume

func Resume(c *gin.Context, rq *requestq.RQ) (requestq.Result, error)

Resume TODO

func ResumeQueue

func ResumeQueue(c *gin.Context, rq *requestq.RQ) (requestq.Result, error)

ResumeQueue TODO

func SyncQueue

func SyncQueue(c *gin.Context, rq *requestq.RQ) (requestq.Result, error)

SyncQueue TODO

func ViewQueue

func ViewQueue(c *gin.Context, rq *requestq.RQ) (result requestq.Result, err error)

ViewQueue TODO

Types

type CtrlFunc

type CtrlFunc func(*gin.Context, *requestq.RQ) (requestq.Result, error)

CtrlFunc TODO

type HandlerWrapper

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

HandlerWrapper TODO

func NewHandlerWrapper

func NewHandlerWrapper(rq *requestq.RQ) *HandlerWrapper

NewHandlerWrapper TODO

func (*HandlerWrapper) Wrap

func (wp *HandlerWrapper) Wrap(f CtrlFunc) gin.HandlerFunc

Wrap TODO

type InvalidBody

type InvalidBody string

InvalidBody TODO

func (InvalidBody) Error

func (e InvalidBody) Error() string

type InvalidQuery

type InvalidQuery string

InvalidQuery TODO

func (InvalidQuery) Error

func (e InvalidQuery) Error() string