Documentation ¶
Index ¶
- func Convert_name2ID(name string) string
- func Delete_container(id string, wg *sync.WaitGroup)
- func Delete_container_file_list(path string)
- func Delete_containers_on_host(hostname string)
- func Get_all_docker_containers() ([]dc.APIContainers, error)
- func Get_container_name(longname string) string
- func Get_docker_status(cluster_names []string)
- func Get_nodemanager_host(longname string) string
- func Get_running_docker_containers() ([]dc.APIContainers, error)
- func Get_swarm_nodes_status()
- func Lookup(hostname string, all bool)
- func Scale_yarn_cluster(clustername string, numInstances int)
- func Swarm_client() (*dc.Client, error)
- type Node
- type ScaleResult
- type Yarn_docker_container
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func Convert_name2ID ¶
Convert yarn name to short container ID.
func Delete_container ¶
Delete a docker container.
func Delete_container_file_list ¶
func Delete_container_file_list(path string)
Delete the containers of the file list
func Delete_containers_on_host ¶
func Delete_containers_on_host(hostname string)
Delete all the yarn docker containers on the host.
func Get_all_docker_containers ¶
func Get_all_docker_containers() ([]dc.APIContainers, error)
Get all the docker containers of swarm cluster
func Get_container_name ¶
Get container name for example: yarn1-20141231-nm1
func Get_docker_status ¶
func Get_docker_status(cluster_names []string)
Get the yarn docker cluster status
func Get_nodemanager_host ¶
Get nodemanager local machine's hostname for example:bj-dc-datanode-006.tendcloud.com
func Get_running_docker_containers ¶
func Get_running_docker_containers() ([]dc.APIContainers, error)
Get all the running docker containers of swarm cluster
func Scale_yarn_cluster ¶
Scale yarn cluster with the base container
Types ¶
type Node ¶
type Node struct { ID string `json:"id,omitempty" gorethink:"id,omitempty"` Name string `json:"name,omitempty" gorethink:"name,omitempty"` Addr string `json:"addr,omitempty" gorethink:"addr,omitempty"` Containers string `json:"containers,omitempty"` ReservedCPUs string `json:"reserved_cpus,omitempty"` ReservedMemory string `json:"reserved_memory,omitempty"` Labels []string `json:"labels,omitempty"` ResponseTime float64 `json:"response_time" gorethink:"response_time,omitempty"` }
type ScaleResult ¶
type Yarn_docker_container ¶
type Yarn_docker_container struct { ID string Clustername string //yarn1 Name string //yarn1-20160912-nm1 Status string //exited State string //Exited (0) 3 hours ago Ip string //172.18.12.31 Host string //bj-dc-datanode-078.tendcloud.com }
Yarn nodemanager docker container
func Convert_yarn_docker_container ¶
func Convert_yarn_docker_container(docker_container dc.APIContainers) Yarn_docker_container
Convert the swarm docker struct to yarn_docker_container struct
func Get_all_yarn_containers ¶
func Get_all_yarn_containers() []Yarn_docker_container
Get yarn docker containers list
Click to show internal directories.
Click to hide internal directories.