controllers

package
v0.0.0-...-8110dd7 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jul 10, 2020 License: GPL-3.0 Imports: 26 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var Api = new(ApiController)
View Source 
var Config = new(ConfigController)
View Source 
var Machine = new(MachineController)
View Source 
var Push = new(PushController)
View Source 
var Queue = new(QueueController)
View Source 
var Storage = new(StorageController)
View Source 
var System = new(SystemController)
View Source 
var Task = new(TaskController)
View Source 
var Topic = new(TopicController)
View Source 
var User = new(UserController)

Functions

This section is empty.

Types

type ApiController 

type ApiController struct {
}

func (ApiController) AlarmHandler 

func (c ApiController) AlarmHandler(req *ginp.Request) *ginp.Response

func (ApiController) Group 

func (c ApiController) Group() string

func (ApiController) TokenRequired 

func (c ApiController) TokenRequired(string) bool

type ConfigController 

type ConfigController struct {
}

func (ConfigController) GetTagsHandler 

func (c ConfigController) GetTagsHandler(_ *ginp.Request) *ginp.Response

func (ConfigController) Group 

func (c ConfigController) Group() string

func (ConfigController) ListHandler 

func (c ConfigController) ListHandler(req *ginp.Request) *ginp.Response

func (ConfigController) TokenRequired 

func (c ConfigController) TokenRequired(string) bool

type CronNodeConfig 

type CronNodeConfig struct {
	Tags string `json:"tags"`
}

type DelForm 

type DelForm struct {
	Id uint64 `binding:"required" form:"id" json:"id"`
}

type MachineConfig 

type MachineConfig struct {
	SharedId uint64
	Tags     []string
}

type MachineController 

type MachineController struct {
}

func (MachineController) AddHandlerPostAction 

func (c MachineController) AddHandlerPostAction(req *ginp.Request) *ginp.Response

func (MachineController) DeleteHandlerPostAction 

func (c MachineController) DeleteHandlerPostAction(req *ginp.Request) *ginp.Response

func (MachineController) Group 

func (c MachineController) Group() string

func (MachineController) ListHandler 

func (c MachineController) ListHandler(req *ginp.Request) *ginp.Response

func (MachineController) TokenRequired 

func (c MachineController) TokenRequired(path string) bool

type MachineForm 

type MachineForm struct {
	Cron bool `json:"cron" form:"cron"`
}

type PageData 

type PageData struct {
	Items interface{} `json:"items"`
	Total int         `json:"total"`
}

type PushController 

type PushController struct {
}

func (PushController) Group 

func (c PushController) Group() string

func (PushController) ListHandler 

func (c PushController) ListHandler(ctx *gin.Context)

func (PushController) TokenRequired 

func (c PushController) TokenRequired(string) bool

type QueueConfig 

type QueueConfig struct {
	QueueName string                  `json:"queue_name"`
	Password  string                  `json:"password"`
	Topic     map[string]*TopicConfig `json:"topic"`
}

type QueueController 

type QueueController struct {
}

func (QueueController) AddHandlerPostAction 

func (c QueueController) AddHandlerPostAction(req *ginp.Request) *ginp.Response

func (QueueController) DeleteHandlerPostAction 

func (c QueueController) DeleteHandlerPostAction(req *ginp.Request) *ginp.Response

func (QueueController) ExportHandlerPostAction 

func (c QueueController) ExportHandlerPostAction(req *ginp.Request) *ginp.Response

func (QueueController) Group 

func (c QueueController) Group() string

func (QueueController) ImportHandlerPostAction 

func (c QueueController) ImportHandlerPostAction(req *ginp.Request) *ginp.Response

已存在的不会被覆盖 依赖的system和storage如果不存在则报错

func (QueueController) ListHandler 

func (c QueueController) ListHandler(_ *ginp.Request) *ginp.Response

func (QueueController) ListSystemHandler 

func (c QueueController) ListSystemHandler(_ *ginp.Request) *ginp.Response

func (QueueController) TokenRequired 

func (c QueueController) TokenRequired(string) bool

func (QueueController) UpdateHandlerPostAction 

func (c QueueController) UpdateHandlerPostAction(req *ginp.Request) *ginp.Response

更新queue 只有名下topic不为空才能修改name和password

type StorageConfig 

type StorageConfig struct {
	Type           string        `json:"type"`
	Address        string        `json:"address"`
	Auth           string        `json:"auth"`
	MaxConnNum     int           `json:"max_conn_num"`
	MaxIdleNum     int           `json:"max_idle_num"`
	MaxIdleSeconds time.Duration `json:"max_idle_seconds"`
}

type StorageController 

type StorageController struct {
}

func (StorageController) AddHandlerPostAction 

func (c StorageController) AddHandlerPostAction(req *ginp.Request) *ginp.Response

func (StorageController) Group 

func (c StorageController) Group() string

func (StorageController) ListHandler 

func (c StorageController) ListHandler(_ *ginp.Request) *ginp.Response

func (StorageController) TokenRequired 

func (c StorageController) TokenRequired(string) bool

func (StorageController) UpdateHandlerPostAction 

func (c StorageController) UpdateHandlerPostAction(req *ginp.Request) *ginp.Response

type SystemController 

type SystemController struct {
}

func (SystemController) AddHandlerPostAction 

func (c SystemController) AddHandlerPostAction(req *ginp.Request) *ginp.Response

func (SystemController) Group 

func (c SystemController) Group() string

func (SystemController) ListHandler 

func (c SystemController) ListHandler(req *ginp.Request) *ginp.Response

func (SystemController) TokenRequired 

func (c SystemController) TokenRequired(string) bool

type TaskController 

type TaskController struct {
}

func (TaskController) AddHandlerPostAction 

func (c TaskController) AddHandlerPostAction(req *ginp.Request) (res *ginp.Response)

TODO: check circle dependency

func (TaskController) Group 

func (c TaskController) Group() string

func (TaskController) ListHandlerGetAction 

func (c TaskController) ListHandlerGetAction(_ *ginp.Request) (res *ginp.Response)

func (TaskController) NodeListHandlerGetAction 

func (c TaskController) NodeListHandlerGetAction(_ *ginp.Request) (res *ginp.Response)

func (TaskController) NodeLogHandlerGetAction 

func (c TaskController) NodeLogHandlerGetAction(req *ginp.Request) (res *ginp.Response)

func (TaskController) NodeLogTotalHandlerGetAction 

func (c TaskController) NodeLogTotalHandlerGetAction(req *ginp.Request) (res *ginp.Response)

func (TaskController) NodesHandlerGetAction 

func (c TaskController) NodesHandlerGetAction(req *ginp.Request) (res *ginp.Response)

func (TaskController) PauseHandlerPostAction 

func (c TaskController) PauseHandlerPostAction(req *ginp.Request) (res *ginp.Response)

func (TaskController) RemoveHandlerPostAction 

func (c TaskController) RemoveHandlerPostAction(req *ginp.Request) (res *ginp.Response)

TODO 完善删除任务的和停止任务的依赖检查

func (TaskController) StartHandlerPostAction 

func (c TaskController) StartHandlerPostAction(req *ginp.Request) (res *ginp.Response)

func (TaskController) TaskHandlerGetAction 

func (c TaskController) TaskHandlerGetAction(req *ginp.Request) (res *ginp.Response)

func (TaskController) TestHandlerGetAction 

func (c TaskController) TestHandlerGetAction(req *ginp.Request) (res *ginp.Response)

func (TaskController) TestLogHandlerGetAction 

func (c TaskController) TestLogHandlerGetAction(req *ginp.Request) (res *ginp.Response)

func (TaskController) TokenRequired 

func (c TaskController) TokenRequired(string) bool

func (TaskController) TreeHandlerGetAction 

func (c TaskController) TreeHandlerGetAction(req *ginp.Request) (res *ginp.Response)

func (TaskController) UpdateHandlerPostAction 

func (c TaskController) UpdateHandlerPostAction(req *ginp.Request) (res *ginp.Response)

TODO: check circle dependency

type TaskD 

type TaskD struct {
	*dao.Task
	Statics map[string]string
}

type TaskN 

type TaskN struct {
	dao.TaskDetail
	Statics map[string]string
}

type TimeRetry 

type TimeRetry struct {
	IsRetry   bool  `json:"switch"`
	RetryTime int64 `json:"durTime"`
}

type TopicConfig 

type TopicConfig struct {
	Name           string         `json:"name"`
	Password       string         `json:"password"`
	RetryTimes     int            `json:"retry_times"`
	MaxQueueLength int            `json:"max_queue_length"`
	RunType        int            `json:"run_type"`
	Storage        *StorageConfig `json:"storage"`
	NumOfWorkers   uint64         `json:"num_of_workers"`
	ScriptEntry    string         `json:"script_entry"`
	CgiConfigKey   string         `json:"cgi_config_key"`
	HttpConfig     string         `json:"http_config"`
	IsRetry        bool           `json:"is_retry"`
	RetryTime      int64          `json:"retry_time"`
}

type TopicController 

type TopicController struct {
}

func (TopicController) AddHandlerPostAction 

func (c TopicController) AddHandlerPostAction(req *ginp.Request) *ginp.Response

func (TopicController) CleanRetryHandlerPostAction 

func (c TopicController) CleanRetryHandlerPostAction(req *ginp.Request) *ginp.Response

func (TopicController) CleanStatisticsHandlerPostAction 

func (c TopicController) CleanStatisticsHandlerPostAction(req *ginp.Request) *ginp.Response

func (TopicController) DefaultThresholdHandler 

func (c TopicController) DefaultThresholdHandler(_ *ginp.Request) *ginp.Response

func (TopicController) DeleteHandlerPostAction 

func (c TopicController) DeleteHandlerPostAction(req *ginp.Request) *ginp.Response

func (TopicController) GetLengthHandler 

func (c TopicController) GetLengthHandler(req *ginp.Request) *ginp.Response

func (TopicController) GetRetryErrorsHandler 

func (c TopicController) GetRetryErrorsHandler(req *ginp.Request) *ginp.Response

func (TopicController) Group 

func (c TopicController) Group() string

func (TopicController) HistoryHandlerPostAction 

func (c TopicController) HistoryHandlerPostAction(req *ginp.Request) *ginp.Response

func (TopicController) QueueSummaryHandler 

func (c TopicController) QueueSummaryHandler(req *ginp.Request) *ginp.Response

func (TopicController) RecoverRetryHandlerPostAction 

func (c TopicController) RecoverRetryHandlerPostAction(req *ginp.Request) *ginp.Response

func (TopicController) SearchHandler 

func (c TopicController) SearchHandler(req *ginp.Request) *ginp.Response

func (TopicController) SendHandlerPostAction 

func (c TopicController) SendHandlerPostAction(req *ginp.Request) *ginp.Response

func (TopicController) SystemSummaryHandler 

func (c TopicController) SystemSummaryHandler(req *ginp.Request) *ginp.Response

func (TopicController) TokenRequired 

func (c TopicController) TokenRequired(string) bool

func (TopicController) UpdateHandlerPostAction 

func (c TopicController) UpdateHandlerPostAction(req *ginp.Request) *ginp.Response

type TopicSummary 

type TopicSummary struct {
	Id          uint64      `json:"id"`
	Queue       string      `json:"queue"`
	Name        string      `json:"name"`
	Describe    string      `json:"desc"`
	File        string      `json:"file"`
	Workers     int         `json:"workers"`
	Storage     string      `json:"storage"`
	Length      int64       `json:"length"`
	RetryLen    int64       `json:"retry"`
	TimeoutLen  int64       `json:"timeout"`
	Machines    interface{} `json:"machines"`
	System      string      `json:"system"`
	Status      uint8       `json:"status"`
	RunType     int         `json:"run_type"`
	Alarm       int         `json:"alarm"`
	AlarmRetry  int         `json:"alarm_retry"`
	HttpConfig  string      `json:"http_config"`
	TopicConfig string      `json:"topic_config"`
}

type UserController 

type UserController struct {
}

func (UserController) DelHandlerPostAction 

func (c UserController) DelHandlerPostAction(req *ginp.Request) *ginp.Response

func (UserController) EditrolesHandlerPostAction 

func (c UserController) EditrolesHandlerPostAction(req *ginp.Request) *ginp.Response

func (UserController) Group 

func (c UserController) Group() string

func (UserController) InfoHandler 

func (c UserController) InfoHandler(req *ginp.Request) *ginp.Response

func (UserController) ListHandler 

func (c UserController) ListHandler(req *ginp.Request) *ginp.Response

func (*UserController) LoginHandlerPostAction 

func (c *UserController) LoginHandlerPostAction(req *ginp.Request) *ginp.Response

func (*UserController) TestLoginHandler 

func (c *UserController) TestLoginHandler(_ *ginp.Request) *ginp.Response

func (UserController) TokenRequired 

func (c UserController) TokenRequired(path string) bool

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.