controllers

Nov 12, 2020

Changes in this version

type QueuesController

+ func (ctrl *QueuesController) ClearQueues(c *gin.Context) (result sth.Result, err error)

+ func (ctrl *QueuesController) DeleteQueues(c *gin.Context) (result sth.Result, err error)

+ func (ctrl *QueuesController) ViewTopNQueues(c *gin.Context) (result sth.Result, err error)

Aug 18, 2020

Changes in this version

type RequestController

+ func (ctrl *RequestController) DequeueRequest(c *gin.Context) (result sth.Result, err error)

+ func (ctrl *RequestController) EnqueueRequest(c *gin.Context) (result sth.Result, err error)

Apr 13, 2020

Changes in this version

type ConfigController

+ func (ctrl *ConfigController) SetConfig(c *gin.Context) (result sth.Result, err error)

Apr 9, 2020

Changes in this version

+ func ErrorCode(err error) int

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

+ type CallByQueueID func(sth.QueueID) (sth.Result, error)

+ type ConfigController struct

+ func NewConfigController(serv *serv.Serv) *ConfigController

+ func (ctrl *ConfigController) GetConfig(c *gin.Context) (result sth.Result, err error)

+ type InvalidBody string

+ func (e InvalidBody) Error() string

+ type InvalidQuery string

+ func (e InvalidQuery) Error() string

+ type QueueController struct

+ func NewQueueController(queueBox *queuebox.QueueBox) *QueueController

+ func (ctrl *QueueController) ClearQueue(c *gin.Context) (sth.Result, error)

+ func (ctrl *QueueController) DeleteQueue(c *gin.Context) (sth.Result, error)

+ func (ctrl *QueueController) PauseQueue(c *gin.Context) (sth.Result, error)

+ func (ctrl *QueueController) QueueInfo(c *gin.Context) (sth.Result, error)

+ func (ctrl *QueueController) ResumeQueue(c *gin.Context) (sth.Result, error)

+ func (ctrl *QueueController) SyncQueue(c *gin.Context) (sth.Result, error)

+ func (ctrl *QueueController) ViewQueue(c *gin.Context) (result sth.Result, err error)

+ type QueuesController struct

+ func NewQueuesController(queueBox *queuebox.QueueBox) *QueuesController

+ func (ctrl *QueuesController) Queues(c *gin.Context) (result sth.Result, err error)

+ func (ctrl *QueuesController) QueuesInfo(c *gin.Context) (sth.Result, error)

+ func (ctrl *QueuesController) ViewQueues(c *gin.Context) (result sth.Result, err error)

+ type RedisController struct

+ func NewRedisController(client *redis.Client) *RedisController

+ func (ctrl *RedisController) RedisInfo(c *gin.Context) (sth.Result, error)

+ type RequestController struct

+ func NewRequestController(queueBox *queuebox.QueueBox) *RequestController

+ func (ctrl *RequestController) PopRequest(c *gin.Context) (result sth.Result, err error)

+ func (ctrl *RequestController) PushRequest(c *gin.Context) (result sth.Result, err error)

+ type RequestWrapperController struct

+ func NewRequestWrapperController(wrapper *reqwrap.RequestWrapper) *RequestWrapperController

+ func (ctrl *RequestWrapperController) AddRequestConfig(c *gin.Context) (result sth.Result, err error)

+ func (ctrl *RequestWrapperController) DeleteRequestConfig(c *gin.Context) (result sth.Result, err error)

+ func (ctrl *RequestWrapperController) GetRequestConfig(c *gin.Context) (result sth.Result, err error)

+ func (ctrl *RequestWrapperController) MatchRequestConfig(c *gin.Context) (result sth.Result, err error)

+ func (ctrl *RequestWrapperController) TryRequestConfig(c *gin.Context) (result sth.Result, err error)

+ type ServController struct

+ func NewServController(serv *serv.Serv) *ServController

+ func (ctrl *ServController) Info(c *gin.Context) (sth.Result, error)

+ func (ctrl *ServController) Pause(c *gin.Context) (sth.Result, error)

+ func (ctrl *ServController) Resume(c *gin.Context) (sth.Result, error)