controller

Documentation

Index

• func APPDiscover(w http.ResponseWriter, r *http.Request)
• func APPList(w http.ResponseWriter, r *http.Request)
• func APPRegister(w http.ResponseWriter, r *http.Request)
• func AddNode(w http.ResponseWriter, r *http.Request)
• func CapRes(w http.ResponseWriter, r *http.Request)
• func CheckNode(w http.ResponseWriter, r *http.Request)
• func ClusterDiscover(w http.ResponseWriter, r *http.Request)
• func ClusterInfo(w http.ResponseWriter, r *http.Request)
• func Cordon(w http.ResponseWriter, r *http.Request)
• func CreateLocalVolume(w http.ResponseWriter, r *http.Request)
• func CreateTask(w http.ResponseWriter, r *http.Request)
• func CreateTaskGroup(w http.ResponseWriter, r *http.Request)
• func CreateTaskTemp(w http.ResponseWriter, r *http.Request)
• func DeleteRainbondNode(w http.ResponseWriter, r *http.Request)
• func DeleteTask(w http.ResponseWriter, r *http.Request)
• func DeleteTaskGroup(w http.ResponseWriter, r *http.Request)
• func DeleteTaskTemp(w http.ResponseWriter, r *http.Request)
• func DownNode(w http.ResponseWriter, r *http.Request)
• func ExecTask(w http.ResponseWriter, r *http.Request)
• func ExecTaskGroup(w http.ResponseWriter, r *http.Request)
• func Exist(i interface{})
• func GetAllJobLog(w http.ResponseWriter, r *http.Request)
• func GetAllNodeHealth(w http.ResponseWriter, r *http.Request)
• func GetCpu(w http.ResponseWriter, r *http.Request)
• func GetCpuRange(w http.ResponseWriter, r *http.Request)
• func GetDatacenterConfig(w http.ResponseWriter, r *http.Request)
• func GetDisk(w http.ResponseWriter, r *http.Request)
• func GetDiskRange(w http.ResponseWriter, r *http.Request)
• func GetExpr(w http.ResponseWriter, r *http.Request)
• func GetLabel(w http.ResponseWriter, r *http.Request)
• func GetLoad1(w http.ResponseWriter, r *http.Request)
• func GetLoad1Range(w http.ResponseWriter, r *http.Request)
• func GetLogById(w http.ResponseWriter, r *http.Request)
• func GetMem(w http.ResponseWriter, r *http.Request)
• func GetMemRange(w http.ResponseWriter, r *http.Request)
• func GetNode(w http.ResponseWriter, r *http.Request)
• func GetNodeBasic(w http.ResponseWriter, r *http.Request)
• func GetNodeDetails(w http.ResponseWriter, r *http.Request)
• func GetNodeResource(w http.ResponseWriter, r *http.Request)
• func GetNodes(w http.ResponseWriter, r *http.Request)
• func GetRuleNodes(w http.ResponseWriter, r *http.Request)
• func GetServicesHealthy(w http.ResponseWriter, r *http.Request)
• func GetTask(w http.ResponseWriter, r *http.Request)
• func GetTaskGroup(w http.ResponseWriter, r *http.Request)
• func GetTaskGroupStatus(w http.ResponseWriter, r *http.Request)
• func GetTaskGroups(w http.ResponseWriter, r *http.Request)
• func GetTaskStatus(w http.ResponseWriter, r *http.Request)
• func GetTasks(w http.ResponseWriter, r *http.Request)
• func Init(c *option.Conf, ms *masterserver.MasterServer, kube kubecache.KubeClient)
• func InitStatus(w http.ResponseWriter, r *http.Request)
• func InstallNode(w http.ResponseWriter, r *http.Request)
• func Instances(w http.ResponseWriter, r *http.Request)
• func ListenerDiscover(w http.ResponseWriter, r *http.Request)
• func Ping(w http.ResponseWriter, r *http.Request)
• func PutDatacenterConfig(w http.ResponseWriter, r *http.Request)
• func PutLabel(w http.ResponseWriter, r *http.Request)
• func ReloadStaticTasks(w http.ResponseWriter, r *http.Request)
• func Resource(w http.ResponseWriter, r *http.Request)
• func Resources(w http.ResponseWriter, r *http.Request)
• func ResourcesEnv(w http.ResponseWriter, r *http.Request)
• func RoutesDiscover(w http.ResponseWriter, r *http.Request)
• func ServiceDiscover(w http.ResponseWriter, r *http.Request)
• func UnCordon(w http.ResponseWriter, r *http.Request)
• func UpNode(w http.ResponseWriter, r *http.Request)
• func UpdateNodeStatus(w http.ResponseWriter, r *http.Request)
• func UpdateTaskTemp(w http.ResponseWriter, r *http.Request)
• func UserDefineResources(w http.ResponseWriter, r *http.Request)

Functions

func APPDiscover

func APPDiscover(w http.ResponseWriter, r *http.Request)

APPDiscover 服务发现 用于实时性要求不高的场景，例如docker发现event_log地址 请求API返回可用地址

func APPList

func APPList(w http.ResponseWriter, r *http.Request)

APPList 列出已注册应用

func APPRegister

func APPRegister(w http.ResponseWriter, r *http.Request)

APPRegister 服务注册

func AddNode

func AddNode(w http.ResponseWriter, r *http.Request)

AddNode add a node

func CapRes

func CapRes(w http.ResponseWriter, r *http.Request)

CapRes CapRes

func CheckNode

func CheckNode(w http.ResponseWriter, r *http.Request)

UpNode 节点上线，计算节点操作

func ClusterDiscover

func ClusterDiscover(w http.ResponseWriter, r *http.Request)

ClusterDiscover ClusterDiscover

func ClusterInfo

func ClusterInfo(w http.ResponseWriter, r *http.Request)

ClusterInfo ClusterInfo

func Cordon

func Cordon(w http.ResponseWriter, r *http.Request)

Cordon 不可调度

func CreateLocalVolume

func CreateLocalVolume(w http.ResponseWriter, r *http.Request)

CreateLocalVolume crete local volume dir

func CreateTask

func CreateTask(w http.ResponseWriter, r *http.Request)

CreateTask 创建任务

func CreateTaskGroup

func CreateTaskGroup(w http.ResponseWriter, r *http.Request)

CreateTaskGroup 创建任务

func CreateTaskTemp

func CreateTaskTemp(w http.ResponseWriter, r *http.Request)

CreateTaskTemp 创建任务模版

func DeleteRainbondNode

func DeleteRainbondNode(w http.ResponseWriter, r *http.Request)

DeleteRainbondNode 节点删除

func DeleteTask

func DeleteTask(w http.ResponseWriter, r *http.Request)

DeleteTask 删除某个任务

func DeleteTaskGroup

func DeleteTaskGroup(w http.ResponseWriter, r *http.Request)

DeleteTaskGroup 删除某个任务组

func DeleteTaskTemp

func DeleteTaskTemp(w http.ResponseWriter, r *http.Request)

DeleteTaskTemp 删除任务模版

func DownNode

func DownNode(w http.ResponseWriter, r *http.Request)

DownNode 节点下线，计算节点操作

func ExecTask

func ExecTask(w http.ResponseWriter, r *http.Request)

ExecTask 执行某个任务

func ExecTaskGroup

func ExecTaskGroup(w http.ResponseWriter, r *http.Request)

ExecTaskGroup 执行某组任务

func Exist

func Exist(i interface{})

Exist 退出

func GetAllJobLog

func GetAllJobLog(w http.ResponseWriter, r *http.Request)

func GetAllNodeHealth

func GetAllNodeHealth(w http.ResponseWriter, r *http.Request)

GetAllNodeHealth get all node health

func GetCpu

func GetCpu(w http.ResponseWriter, r *http.Request)

func GetCpuRange

func GetCpuRange(w http.ResponseWriter, r *http.Request)

func GetDatacenterConfig

func GetDatacenterConfig(w http.ResponseWriter, r *http.Request)

GetDatacenterConfig 获取数据中心配置

func GetDisk

func GetDisk(w http.ResponseWriter, r *http.Request)

func GetDiskRange

func GetDiskRange(w http.ResponseWriter, r *http.Request)

func GetExpr

func GetExpr(w http.ResponseWriter, r *http.Request)

func GetLabel

func GetLabel(w http.ResponseWriter, r *http.Request)

GetLabel get node label

func GetLoad1

func GetLoad1(w http.ResponseWriter, r *http.Request)

func GetLoad1Range

func GetLoad1Range(w http.ResponseWriter, r *http.Request)

func GetLogById

func GetLogById(w http.ResponseWriter, r *http.Request)

func GetMem

func GetMem(w http.ResponseWriter, r *http.Request)

GetNode 获取一个节点详情

func GetMemRange

func GetMemRange(w http.ResponseWriter, r *http.Request)

func GetNode

func GetNode(w http.ResponseWriter, r *http.Request)

GetNode 获取一个节点详情

func GetNodeBasic

func GetNodeBasic(w http.ResponseWriter, r *http.Request)

GetNodeBasic GetNodeBasic

func GetNodeDetails

func GetNodeDetails(w http.ResponseWriter, r *http.Request)

GetNodeDetails GetNodeDetails

func GetNodeResource

func GetNodeResource(w http.ResponseWriter, r *http.Request)

GetNodeResource

func GetNodes

func GetNodes(w http.ResponseWriter, r *http.Request)

GetNodes 获取全部节点

func GetRuleNodes

func GetRuleNodes(w http.ResponseWriter, r *http.Request)

GetRuleNodes 获取分角色节点

func GetServicesHealthy

func GetServicesHealthy(w http.ResponseWriter, r *http.Request)

func GetTask

func GetTask(w http.ResponseWriter, r *http.Request)

GetTask 获取某个任务

func GetTaskGroup

func GetTaskGroup(w http.ResponseWriter, r *http.Request)

GetTaskGroup 获取某组任务

func GetTaskGroupStatus

func GetTaskGroupStatus(w http.ResponseWriter, r *http.Request)

GetTaskGroupStatus 获取某组任务 状态

func GetTaskGroups

func GetTaskGroups(w http.ResponseWriter, r *http.Request)

GetTaskGroups 获取TaskGroups

func GetTaskStatus

func GetTaskStatus(w http.ResponseWriter, r *http.Request)

GetTaskStatus 获取某个任务状态

func GetTasks

func GetTasks(w http.ResponseWriter, r *http.Request)

GetTasks 获取tasks

func Init

func Init(c *option.Conf, ms *masterserver.MasterServer, kube kubecache.KubeClient)

Init 初始化

func InitStatus

func InitStatus(w http.ResponseWriter, r *http.Request)

func InstallNode

func InstallNode(w http.ResponseWriter, r *http.Request)

InstallNode install a node

func Instances

func Instances(w http.ResponseWriter, r *http.Request)

UpNode 节点实例，计算节点操作

func ListenerDiscover

func ListenerDiscover(w http.ResponseWriter, r *http.Request)

ListenerDiscover ListenerDiscover

func Ping

func Ping(w http.ResponseWriter, r *http.Request)

Ping Ping

func PutDatacenterConfig

func PutDatacenterConfig(w http.ResponseWriter, r *http.Request)

PutDatacenterConfig 更新数据中心配置

func PutLabel

func PutLabel(w http.ResponseWriter, r *http.Request)

PutLabel 更新节点标签

func ReloadStaticTasks

func ReloadStaticTasks(w http.ResponseWriter, r *http.Request)

ReloadStaticTasks 重新加载静态文件

func Resource

func Resource(w http.ResponseWriter, r *http.Request)

func Resources

func Resources(w http.ResponseWriter, r *http.Request)

Resources specified node scheduler resources info

func ResourcesEnv

func ResourcesEnv(w http.ResponseWriter, r *http.Request)

ResourcesEnv ResourcesEnv

func RoutesDiscover

func RoutesDiscover(w http.ResponseWriter, r *http.Request)

RoutesDiscover RoutesDiscover

func ServiceDiscover

func ServiceDiscover(w http.ResponseWriter, r *http.Request)

ServiceDiscover service discover service

func UnCordon

func UnCordon(w http.ResponseWriter, r *http.Request)

UnCordon 可调度

func UpNode

func UpNode(w http.ResponseWriter, r *http.Request)

UpNode 节点上线，计算节点操作

func UpdateNodeStatus

func UpdateNodeStatus(w http.ResponseWriter, r *http.Request)

UpdateNodeStatus update node status `{"status":"installing"}`

func UpdateTaskTemp

func UpdateTaskTemp(w http.ResponseWriter, r *http.Request)

UpdateTaskTemp 更新任务模版

func UserDefineResources

func UserDefineResources(w http.ResponseWriter, r *http.Request)

UserDefineResources UserDefineResources