controllers

Documentation

Index

• type BaseController
  • func (baseService *BaseController) AccessToken(ctx *fasthttp.RequestCtx) bool
  • func (baseService *BaseController) GetCtxBool(ctx *fasthttp.RequestCtx, key string) bool
  • func (baseService *BaseController) GetCtxFloat64(ctx *fasthttp.RequestCtx, key string) float64
  • func (baseService *BaseController) GetCtxInt(ctx *fasthttp.RequestCtx, key string) int
  • func (baseService *BaseController) GetCtxString(ctx *fasthttp.RequestCtx, key string) string
• type ConsumerController
  • func NewConsumerController() *ConsumerController
  • func (this *ConsumerController) Add(ctx *fasthttp.RequestCtx)
  • func (this *ConsumerController) Delete(ctx *fasthttp.RequestCtx)
  • func (this *ConsumerController) GetConsumerById(ctx *fasthttp.RequestCtx)
  • func (this *ConsumerController) Status(ctx *fasthttp.RequestCtx)
  • func (this *ConsumerController) Update(ctx *fasthttp.RequestCtx)
• type JsonResult
• type LogController
  • func NewLogController() *LogController
  • func (this *LogController) Download(ctx *fasthttp.RequestCtx)
  • func (this *LogController) List(ctx *fasthttp.RequestCtx)
  • func (this *LogController) Search(ctx *fasthttp.RequestCtx)
• type MessageController
  • func NewMessageController() *MessageController
  • func (this *MessageController) Add(ctx *fasthttp.RequestCtx)
  • func (this *MessageController) Delete(ctx *fasthttp.RequestCtx)
  • func (this *MessageController) GetConsumersByName(ctx *fasthttp.RequestCtx)
  • func (this *MessageController) GetMessageByName(ctx *fasthttp.RequestCtx)
  • func (this *MessageController) List(ctx *fasthttp.RequestCtx)
  • func (this *MessageController) Reload(ctx *fasthttp.RequestCtx)
  • func (this *MessageController) Status(ctx *fasthttp.RequestCtx)
  • func (this *MessageController) Update(ctx *fasthttp.RequestCtx)
• type PublishController
  • func NewPublishController() *PublishController
  • func (this *PublishController) Publish(ctx *fasthttp.RequestCtx)
• type SystemController
  • func NewSystemController() *SystemController
  • func (this *SystemController) Index(ctx *fasthttp.RequestCtx)
  • func (this *SystemController) Reload(ctx *fasthttp.RequestCtx)

Types

type BaseController

type BaseController struct {
}

func (*BaseController) AccessToken

func (baseService *BaseController) AccessToken(ctx *fasthttp.RequestCtx) bool

access token

func (*BaseController) GetCtxBool

func (baseService *BaseController) GetCtxBool(ctx *fasthttp.RequestCtx, key string) bool

get request content text bool

func (*BaseController) GetCtxFloat64

func (baseService *BaseController) GetCtxFloat64(ctx *fasthttp.RequestCtx, key string) float64

get request content text float64

func (*BaseController) GetCtxInt

func (baseService *BaseController) GetCtxInt(ctx *fasthttp.RequestCtx, key string) int

get request content text int

func (*BaseController) GetCtxString

func (baseService *BaseController) GetCtxString(ctx *fasthttp.RequestCtx, key string) string

get request content text string

type ConsumerController

type ConsumerController struct {
	BaseController
}

func NewConsumerController

func NewConsumerController() *ConsumerController

return ConsumerController

func (*ConsumerController) Add

func (this *ConsumerController) Add(ctx *fasthttp.RequestCtx)

add a consumer

func (*ConsumerController) Delete

func (this *ConsumerController) Delete(ctx *fasthttp.RequestCtx)

delete a consumer

func (*ConsumerController) GetConsumerById

func (this *ConsumerController) GetConsumerById(ctx *fasthttp.RequestCtx)

get consumer by id

func (*ConsumerController) Status

func (this *ConsumerController) Status(ctx *fasthttp.RequestCtx)

get consumer status

func (*ConsumerController) Update

func (this *ConsumerController) Update(ctx *fasthttp.RequestCtx)

update a consumer

type JsonResult

type JsonResult struct {
	Code    int         `json:"code"`
	Message interface{} `json:"message"`
	Data    interface{} `json:"data"`
}

type LogController

type LogController struct {
	BaseController
}

func NewLogController

func NewLogController() *LogController

return LogController

func (*LogController) Download

func (this *LogController) Download(ctx *fasthttp.RequestCtx)

log download

func (*LogController) List

func (this *LogController) List(ctx *fasthttp.RequestCtx)

log list

func (*LogController) Search

func (this *LogController) Search(ctx *fasthttp.RequestCtx)

log search

type MessageController

type MessageController struct {
	BaseController
}

func NewMessageController

func NewMessageController() *MessageController

return MessageController

func (*MessageController) Add

func (this *MessageController) Add(ctx *fasthttp.RequestCtx)

add a message

func (*MessageController) Delete

func (this *MessageController) Delete(ctx *fasthttp.RequestCtx)

delete a message

func (*MessageController) GetConsumersByName

func (this *MessageController) GetConsumersByName(ctx *fasthttp.RequestCtx)

get consumers by message name

func (*MessageController) GetMessageByName

func (this *MessageController) GetMessageByName(ctx *fasthttp.RequestCtx)

get message by name

func (*MessageController) List

func (this *MessageController) List(ctx *fasthttp.RequestCtx)

get all message list

func (*MessageController) Reload

func (this *MessageController) Reload(ctx *fasthttp.RequestCtx)

reload message by message name

func (*MessageController) Status

func (this *MessageController) Status(ctx *fasthttp.RequestCtx)

get message all consumer status

func (*MessageController) Update

func (this *MessageController) Update(ctx *fasthttp.RequestCtx)

update a message

type PublishController

type PublishController struct {
	BaseController
}

func NewPublishController

func NewPublishController() *PublishController

return PublishController

func (*PublishController) Publish

func (this *PublishController) Publish(ctx *fasthttp.RequestCtx)

publish message

type SystemController

type SystemController struct {
	BaseController
}

func NewSystemController

func NewSystemController() *SystemController

return SystemController

func (*SystemController) Index

func (this *SystemController) Index(ctx *fasthttp.RequestCtx)

func (*SystemController) Reload

func (this *SystemController) Reload(ctx *fasthttp.RequestCtx)

reload wmqx