Documentation ¶
Index ¶
- func Duplicate(a interface{}) (ret []interface{})
- type AppService
- type DiscoverAction
- func (d *DiscoverAction) DiscoverClusters(tenantService, serviceCluster string) (*envoyv1.CDSCluter, *util.APIHandleError)
- func (d *DiscoverAction) DiscoverListeners(tenantService, serviceCluster string) (*envoyv1.LDSListener, *util.APIHandleError)
- func (d *DiscoverAction) DiscoverService(serviceInfo string) (*envoyv1.SDSHost, *util.APIHandleError)
- func (d *DiscoverAction) ToolsGetRainbondResources(namespace, sourceAlias, pluginID string) (*api_model.ResourceSpec, error)
- func (d *DiscoverAction) ToolsGetSourcesEnv(namespace, sourceAlias, envName string) ([]byte, *util.APIHandleError)
- type NodeService
- func (n *NodeService) AddNode(node *client.APIHostNode) (*client.HostNode, *utils.APIHandleError)
- func (n *NodeService) AsynchronousInstall(node *client.HostNode)
- func (n *NodeService) CheckNode(nodeUID string) (*model.InstallStatus, *utils.APIHandleError)
- func (n *NodeService) CordonNode(nodeID string, unschedulable bool) *utils.APIHandleError
- func (n *NodeService) DeleteNode(nodeID string) *utils.APIHandleError
- func (n *NodeService) DownNode(nodeID string) (*client.HostNode, *utils.APIHandleError)
- func (n *NodeService) GetAllNode() ([]*client.HostNode, *utils.APIHandleError)
- func (n *NodeService) GetNode(nodeID string) (*client.HostNode, *utils.APIHandleError)
- func (n *NodeService) GetNodeResource(nodeUID string) (*model.NodePodResource, *utils.APIHandleError)
- func (n *NodeService) GetServicesHealthy() (map[string][]map[string]string, *utils.APIHandleError)
- func (n *NodeService) InitStatus(nodeIP string) (*model.InitStatus, *utils.APIHandleError)
- func (n *NodeService) InstallNode(node *client.HostNode) *utils.APIHandleError
- func (n *NodeService) PutNodeLabel(nodeID string, labels map[string]string) *utils.APIHandleError
- func (n *NodeService) UpNode(nodeID string) (*client.HostNode, *utils.APIHandleError)
- func (n *NodeService) UpdateNodeStatus(nodeID, status string) *utils.APIHandleError
- type PrometheusService
- type TaskGroupService
- func (ts *TaskGroupService) AddTaskGroup(t *model.TaskGroup) *utils.APIHandleError
- func (ts *TaskGroupService) DeleteTaskGroup(taskGroupID string) *utils.APIHandleError
- func (ts *TaskGroupService) ExecTaskGroup(taskGroupID string, nodes []string) *utils.APIHandleError
- func (ts *TaskGroupService) GetTaskGroup(taskGroupID string) (*model.TaskGroup, *utils.APIHandleError)
- func (ts *TaskGroupService) GetTaskGroups() ([]*model.TaskGroup, *utils.APIHandleError)
- type TaskService
- func (ts *TaskService) AddTask(t *model.Task) *utils.APIHandleError
- func (ts *TaskService) DeleteTask(taskID string) *utils.APIHandleError
- func (ts *TaskService) ExecTask(taskID string, nodes []string) *utils.APIHandleError
- func (ts *TaskService) GetTask(taskID string) (*model.Task, *utils.APIHandleError)
- func (ts *TaskService) GetTasks() ([]*model.Task, *utils.APIHandleError)
- func (ts *TaskService) GetTasksByNode(n *client.HostNode) ([]*model.Task, *utils.APIHandleError)
- func (ts *TaskService) ReloadStaticTasks()
- type TaskTempService
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
Types ¶
type AppService ¶
type AppService struct { Prefix string // contains filtered or unexported fields }
AppService app service
func (*AppService) FindAppEndpoints ¶
func (a *AppService) FindAppEndpoints(appName string) []*config.Endpoint
FindAppEndpoints 获取app endpoint
type DiscoverAction ¶
type DiscoverAction struct {
// contains filtered or unexported fields
}
DiscoverAction DiscoverAction
func CreateDiscoverActionManager ¶
func CreateDiscoverActionManager(conf *option.Conf, kubecli kubecache.KubeClient) *DiscoverAction
CreateDiscoverActionManager CreateDiscoverActionManager
func (*DiscoverAction) DiscoverClusters ¶
func (d *DiscoverAction) DiscoverClusters( tenantService, serviceCluster string) (*envoyv1.CDSCluter, *util.APIHandleError)
DiscoverClusters cds discover create cluster by get depend app endpoints from plugin config
func (*DiscoverAction) DiscoverListeners ¶
func (d *DiscoverAction) DiscoverListeners( tenantService, serviceCluster string) (*envoyv1.LDSListener, *util.APIHandleError)
DiscoverListeners lds create listens by get depend app endpoints from plugin config
func (*DiscoverAction) DiscoverService ¶
func (d *DiscoverAction) DiscoverService(serviceInfo string) (*envoyv1.SDSHost, *util.APIHandleError)
DiscoverService sds
func (*DiscoverAction) ToolsGetRainbondResources ¶
func (d *DiscoverAction) ToolsGetRainbondResources(namespace, sourceAlias, pluginID string) (*api_model.ResourceSpec, error)
ToolsGetRainbondResources get plugin configs from etcd if not exist return error
func (*DiscoverAction) ToolsGetSourcesEnv ¶
func (d *DiscoverAction) ToolsGetSourcesEnv( namespace, sourceAlias, envName string) ([]byte, *util.APIHandleError)
ToolsGetSourcesEnv rds envName maybe is plugin id
type NodeService ¶
type NodeService struct {
// contains filtered or unexported fields
}
NodeService node service
func CreateNodeService ¶
func CreateNodeService(c *option.Conf, nodecluster *node.Cluster, kubecli kubecache.KubeClient) *NodeService
CreateNodeService create
func (*NodeService) AddNode ¶
func (n *NodeService) AddNode(node *client.APIHostNode) (*client.HostNode, *utils.APIHandleError)
AddNode add node
func (*NodeService) AsynchronousInstall ¶
func (n *NodeService) AsynchronousInstall(node *client.HostNode)
AsynchronousInstall AsynchronousInstall
func (*NodeService) CheckNode ¶
func (n *NodeService) CheckNode(nodeUID string) (*model.InstallStatus, *utils.APIHandleError)
CheckNode check node install status
func (*NodeService) CordonNode ¶
func (n *NodeService) CordonNode(nodeID string, unschedulable bool) *utils.APIHandleError
CordonNode set node is unscheduler
func (*NodeService) DeleteNode ¶
func (n *NodeService) DeleteNode(nodeID string) *utils.APIHandleError
DeleteNode delete node only node status is offline and node can be deleted
func (*NodeService) DownNode ¶
func (n *NodeService) DownNode(nodeID string) (*client.HostNode, *utils.APIHandleError)
DownNode down node
func (*NodeService) GetAllNode ¶
func (n *NodeService) GetAllNode() ([]*client.HostNode, *utils.APIHandleError)
GetAllNode get all node
func (*NodeService) GetNode ¶
func (n *NodeService) GetNode(nodeID string) (*client.HostNode, *utils.APIHandleError)
GetNode get node info
func (*NodeService) GetNodeResource ¶
func (n *NodeService) GetNodeResource(nodeUID string) (*model.NodePodResource, *utils.APIHandleError)
GetNodeResource get node resource
func (*NodeService) GetServicesHealthy ¶
func (n *NodeService) GetServicesHealthy() (map[string][]map[string]string, *utils.APIHandleError)
GetServicesHealthy get service health
func (*NodeService) InitStatus ¶
func (n *NodeService) InitStatus(nodeIP string) (*model.InitStatus, *utils.APIHandleError)
InitStatus node init status
func (*NodeService) InstallNode ¶
func (n *NodeService) InstallNode(node *client.HostNode) *utils.APIHandleError
InstallNode install node
func (*NodeService) PutNodeLabel ¶
func (n *NodeService) PutNodeLabel(nodeID string, labels map[string]string) *utils.APIHandleError
PutNodeLabel update node label
func (*NodeService) UpNode ¶
func (n *NodeService) UpNode(nodeID string) (*client.HostNode, *utils.APIHandleError)
UpNode up node
func (*NodeService) UpdateNodeStatus ¶
func (n *NodeService) UpdateNodeStatus(nodeID, status string) *utils.APIHandleError
UpdateNodeStatus update node status
type PrometheusService ¶
type PrometheusService struct {
// contains filtered or unexported fields
}
PrometheusService prometheus service
func CreatePrometheusService ¶
func CreatePrometheusService(c *option.Conf, ms *masterserver.MasterServer) *PrometheusService
CreatePrometheusService create prometheus service
func (*PrometheusService) Exec ¶
func (ts *PrometheusService) Exec(expr string) (*model.Prome, *utils.APIHandleError)
Exec exec prometheus query
func (*PrometheusService) ExecRange ¶
func (ts *PrometheusService) ExecRange(expr, start, end, step string) (*model.Prome, *utils.APIHandleError)
ExecRange exec prometheus query range
type TaskGroupService ¶
type TaskGroupService struct { SavePath string // contains filtered or unexported fields }
TaskGroupService task group
func CreateTaskGroupService ¶
func CreateTaskGroupService(c *option.Conf, ms *masterserver.MasterServer) *TaskGroupService
CreateTaskGroupService create Task group service
func (*TaskGroupService) AddTaskGroup ¶
func (ts *TaskGroupService) AddTaskGroup(t *model.TaskGroup) *utils.APIHandleError
AddTaskGroup add task group
func (*TaskGroupService) DeleteTaskGroup ¶
func (ts *TaskGroupService) DeleteTaskGroup(taskGroupID string) *utils.APIHandleError
DeleteTaskGroup delete TaskGroup delete group but do not delete task in this group
func (*TaskGroupService) ExecTaskGroup ¶
func (ts *TaskGroupService) ExecTaskGroup(taskGroupID string, nodes []string) *utils.APIHandleError
ExecTaskGroup exec group task
func (*TaskGroupService) GetTaskGroup ¶
func (ts *TaskGroupService) GetTaskGroup(taskGroupID string) (*model.TaskGroup, *utils.APIHandleError)
GetTaskGroup get Task group
func (*TaskGroupService) GetTaskGroups ¶
func (ts *TaskGroupService) GetTaskGroups() ([]*model.TaskGroup, *utils.APIHandleError)
GetTaskGroups get tasks
type TaskService ¶
type TaskService struct { SavePath string // contains filtered or unexported fields }
TaskService task services
func CreateTaskService ¶
func CreateTaskService(c *option.Conf, ms *masterserver.MasterServer) *TaskService
CreateTaskService create task service
func (*TaskService) AddTask ¶
func (ts *TaskService) AddTask(t *model.Task) *utils.APIHandleError
AddTask add task
func (*TaskService) DeleteTask ¶
func (ts *TaskService) DeleteTask(taskID string) *utils.APIHandleError
DeleteTask delete task by taskID
func (*TaskService) ExecTask ¶
func (ts *TaskService) ExecTask(taskID string, nodes []string) *utils.APIHandleError
ExecTask exec a task in nodes
func (*TaskService) GetTask ¶
func (ts *TaskService) GetTask(taskID string) (*model.Task, *utils.APIHandleError)
GetTask get task by taskID
func (*TaskService) GetTasks ¶
func (ts *TaskService) GetTasks() ([]*model.Task, *utils.APIHandleError)
GetTasks get tasks
func (*TaskService) GetTasksByNode ¶
func (ts *TaskService) GetTasksByNode(n *client.HostNode) ([]*model.Task, *utils.APIHandleError)
GetTasksByNode get tasks by node
func (*TaskService) ReloadStaticTasks ¶
func (ts *TaskService) ReloadStaticTasks()
ReloadStaticTasks reload task
type TaskTempService ¶
type TaskTempService struct { SavePath string // contains filtered or unexported fields }
TaskTempService task temp service
func CreateTaskTempService ¶
func CreateTaskTempService(c *option.Conf) *TaskTempService
CreateTaskTempService create task temp service
func (*TaskTempService) DeleteTaskTemp ¶
func (ts *TaskTempService) DeleteTaskTemp(tempID string) *utils.APIHandleError
DeleteTaskTemp delete task temp
func (*TaskTempService) GetTaskTemp ¶
func (ts *TaskTempService) GetTaskTemp(tempID string) (*model.TaskTemp, *utils.APIHandleError)
GetTaskTemp get task temp
func (*TaskTempService) SaveTaskTemp ¶
func (ts *TaskTempService) SaveTaskTemp(t *model.TaskTemp) *utils.APIHandleError
SaveTaskTemp add task temp