Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Loader ¶
type Loader interface {
// LoadConfig load the task config
LoadConfig() (*TaskConfig, error)
// LoadContent load the specified task item content
LoadContent(conf string) (string, error)
}
Loader a task config loader interface
func NewLoader ¶
NewLoader return a task config loader instance and currently support file, memory, redis, buntdb memory, buntdb, etcd. Examples like the following: file://task.yaml memory: redis://127.0.0.1:6379 buntdb://:memory: or buntdb://buntdb.db etcd://127.0.0.1:2379?dial_timeout=5s
type TaskConfig ¶
type TaskConfig struct {
// Tasks the task list
Tasks []*TaskItem `json:"tasks" yaml:"tasks"`
}
TaskConfig the config of tasks
func (*TaskConfig) Verify ¶
func (c *TaskConfig) Verify() error
type TaskItem ¶
type TaskItem struct {
// Name a unique task name
Name string `json:"name" yaml:"name"`
// Conf the source of task config
Conf string `json:"conf" yaml:"conf"`
// Labels it can only acquire the current task if the client matches all the labels
Labels []string `json:"labels" yaml:"labels"`
// AllowIP the current task only allows the specified ip to access
AllowIP []string `json:"allow_ip" yaml:"allow_ip"`
}
TaskItem a task item
Click to show internal directories.
Click to hide internal directories.