controller

Documentation

Index

• func AddRequest(c *gin.Context, pod *core.Pod) (result core.Result, err error)
• func ClearQueue(c *gin.Context, pod *core.Pod) (core.Result, error)
• func DeleteQueue(c *gin.Context, pod *core.Pod) (core.Result, error)
• func GetRequest(c *gin.Context, pod *core.Pod) (result core.Result, err error)
• func Info(c *gin.Context, pod *core.Pod) (core.Result, error)
• func Pause(c *gin.Context, pod *core.Pod) (core.Result, error)
• func PauseQueue(c *gin.Context, pod *core.Pod) (core.Result, error)
• func ProcessMemory(c *gin.Context, pod *core.Pod) (core.Result, error)
• func QueueIDFromQuery(q string) (qid core.QueueID, err error)
• func QueueInfo(c *gin.Context, pod *core.Pod) (core.Result, error)
• func Queues(c *gin.Context, pod *core.Pod) (result core.Result, err error)
• func RedisInfo(c *gin.Context, pod *core.Pod) (core.Result, error)
• func RedisMemory(c *gin.Context, pod *core.Pod) (core.Result, error)
• func Resume(c *gin.Context, pod *core.Pod) (core.Result, error)
• func ResumeQueue(c *gin.Context, pod *core.Pod) (core.Result, error)
• func SyncQueue(c *gin.Context, pod *core.Pod) (core.Result, error)
• func ViewQueue(c *gin.Context, pod *core.Pod) (result core.Result, err error)
• func ViewQueues(c *gin.Context, pod *core.Pod) (result core.Result, err error)
• type CallByQueueID
• type CtrlFunc
• type HandlerWrapper
  • func NewHandlerWrapper(pod *core.Pod) *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, pod *core.Pod) (result core.Result, err error)

AddRequest TODO

func ClearQueue

func ClearQueue(c *gin.Context, pod *core.Pod) (core.Result, error)

ClearQueue TODO

func DeleteQueue

func DeleteQueue(c *gin.Context, pod *core.Pod) (core.Result, error)

DeleteQueue TODO

func GetRequest

func GetRequest(c *gin.Context, pod *core.Pod) (result core.Result, err error)

GetRequest TODO

func Info

func Info(c *gin.Context, pod *core.Pod) (core.Result, error)

Info TODO

func Pause

func Pause(c *gin.Context, pod *core.Pod) (core.Result, error)

Pause TODO

func PauseQueue

func PauseQueue(c *gin.Context, pod *core.Pod) (core.Result, error)

PauseQueue TODO

func ProcessMemory

func ProcessMemory(c *gin.Context, pod *core.Pod) (core.Result, error)

ProcessMemory TODO

func QueueIDFromQuery

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

QueueIDFromQuery TODO

func QueueInfo

func QueueInfo(c *gin.Context, pod *core.Pod) (core.Result, error)

QueueInfo TODO

func Queues

func Queues(c *gin.Context, pod *core.Pod) (result core.Result, err error)

Queues TODO

func RedisInfo

func RedisInfo(c *gin.Context, pod *core.Pod) (core.Result, error)

RedisInfo TODO

func RedisMemory

func RedisMemory(c *gin.Context, pod *core.Pod) (core.Result, error)

RedisMemory TODO

func Resume

func Resume(c *gin.Context, pod *core.Pod) (core.Result, error)

Resume TODO

func ResumeQueue

func ResumeQueue(c *gin.Context, pod *core.Pod) (core.Result, error)

ResumeQueue TODO

func SyncQueue

func SyncQueue(c *gin.Context, pod *core.Pod) (core.Result, error)

SyncQueue TODO

func ViewQueue

func ViewQueue(c *gin.Context, pod *core.Pod) (result core.Result, err error)

ViewQueue TODO

func ViewQueues

func ViewQueues(c *gin.Context, pod *core.Pod) (result core.Result, err error)

ViewQueues TODO

Types

type CallByQueueID

type CallByQueueID func(core.QueueID) (core.Result, error)

CallByQueueID TODO

type CtrlFunc

type CtrlFunc func(*gin.Context, *core.Pod) (core.Result, error)

CtrlFunc TODO

type HandlerWrapper

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

HandlerWrapper TODO

func NewHandlerWrapper

func NewHandlerWrapper(pod *core.Pod) *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