models

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: 16 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	DefaultFrontPort = ":12306"
	DefaultAdminPort = ":12307"
)

Variables

This section is empty.

Functions

func Login 

func Login(user, password string) (*ginp.UserInfo, error)

Types

type ImportQueueResItem 

type ImportQueueResItem struct {
	Queue string `json:"queue"`
	Topic string `json:"topic"`
	Res   string `json:"res"`
}

type Queue 

type Queue struct {
}

func NewQueue 

func NewQueue() *Queue

func (Queue) ImportQueue 

func (m Queue) ImportQueue(qItem dao.TransModelQueue, operator string) []ImportQueueResItem

func (Queue) ImportTopic 

func (m Queue) ImportTopic(qItem dao.TransModelQueue, tItem dao.TransModelTopic, operator string) ImportQueueResItem

type Task 

type Task struct {
}

func NewTask 

func NewTask() *Task

func (Task) Add 

func (m Task) Add(task *dao.Task) error

func (Task) AddJob 

func (m Task) AddJob(leaderIp string, job *logic.JobConfig) error

func (Task) AddTest 

func (m Task) AddTest(task *dao.Task, username string) error

func (Task) DeleteJob 

func (m Task) DeleteJob(leaderIp string, jobName string) error

func (Task) GetDependency 

func (m Task) GetDependency() map[string][]string

func (Task) GetInfo 

func (m Task) GetInfo(task *dao.Task) map[string]string

func (Task) GetLeaderIp 

func (m Task) GetLeaderIp(task *dao.Task) string

func (Task) GetMachineIp 

func (m Task) GetMachineIp(task *dao.Task) []string

func (Task) GetNode 

func (m Task) GetNode(task *dao.Task) (map[string]interface{}, error)

func (Task) GetNodeWorkInfo 

func (m Task) GetNodeWorkInfo(task *dao.Task, node string) (ret map[string]string)

func (Task) StopTask 

func (m Task) StopTask(task *dao.Task) error

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.