controllers

Documentation

Index

• func ErrorCode(err error) int
• type CallByUpstreamID
• type QueuesController
  • func NewQueuesController(upstreamMgr *upstream.Manager) *QueuesController
  • func (ctrl *QueuesController) Queues(c *gin.Context) (result sth.Result, err error)
• type RequestController
  • func NewRequestController(upstreamMgr *upstream.Manager) *RequestController
  • func (ctrl *RequestController) DequeueRequest(c *gin.Context) (result sth.Result, err error)
• type UpstreamController
  • func NewUpstreamController(upstreamMgr *upstream.Manager) *UpstreamController
  • func (ctrl *UpstreamController) AddUpstream(c *gin.Context) (result sth.Result, err error)
  • func (ctrl *UpstreamController) DeleteUpstream(c *gin.Context) (sth.Result, error)
  • func (ctrl *UpstreamController) PauseUpstream(c *gin.Context) (result sth.Result, err error)
  • func (ctrl *UpstreamController) ResumeUpstream(c *gin.Context) (result sth.Result, err error)
  • func (ctrl *UpstreamController) UpstreamInfo(c *gin.Context) (sth.Result, error)
  • func (ctrl *UpstreamController) Upstreams(c *gin.Context) (result sth.Result, err error)
  • func (ctrl *UpstreamController) UpstreamsInfo(c *gin.Context) (result sth.Result, err error)

Functions

func ErrorCode

func ErrorCode(err error) int

ErrorCode TODO

Types

type CallByUpstreamID

type CallByUpstreamID func(upstream.ID) (sth.Result, error)

CallByUpstreamID TODO

type QueuesController

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

QueuesController TODO

func NewQueuesController

func NewQueuesController(upstreamMgr *upstream.Manager) *QueuesController

NewQueuesController TODO

func (*QueuesController) Queues

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

Queues TODO

type RequestController

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

RequestController TODO

func NewRequestController

func NewRequestController(upstreamMgr *upstream.Manager) *RequestController

NewRequestController TODO

func (*RequestController) DequeueRequest

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

DequeueRequest TODO

type UpstreamController

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

UpstreamController TODO

func NewUpstreamController

func NewUpstreamController(upstreamMgr *upstream.Manager) *UpstreamController

NewUpstreamController TODO

func (*UpstreamController) AddUpstream

func (ctrl *UpstreamController) AddUpstream(c *gin.Context) (result sth.Result, err error)

AddUpstream TODO

func (*UpstreamController) DeleteUpstream

func (ctrl *UpstreamController) DeleteUpstream(c *gin.Context) (sth.Result, error)

DeleteUpstream TODO

func (*UpstreamController) PauseUpstream

func (ctrl *UpstreamController) PauseUpstream(c *gin.Context) (result sth.Result, err error)

PauseUpstream TODO

func (*UpstreamController) ResumeUpstream

func (ctrl *UpstreamController) ResumeUpstream(c *gin.Context) (result sth.Result, err error)

ResumeUpstream TODO

func (*UpstreamController) UpstreamInfo

func (ctrl *UpstreamController) UpstreamInfo(c *gin.Context) (sth.Result, error)

UpstreamInfo TODO

func (*UpstreamController) Upstreams

func (ctrl *UpstreamController) Upstreams(c *gin.Context) (result sth.Result, err error)

Upstreams TODO

func (*UpstreamController) UpstreamsInfo

func (ctrl *UpstreamController) UpstreamsInfo(c *gin.Context) (result sth.Result, err error)

UpstreamsInfo TODO