rainbond: github.com/goodrain/rainbond/node/masterserver/node Index | Files

package node

import "github.com/goodrain/rainbond/node/masterserver/node"


Package Files

cluster.go monitor.go

type Cluster Uses

type Cluster struct {
    // contains filtered or unexported fields

Cluster node controller

func CreateCluster Uses

func CreateCluster(kubecli kubecache.KubeClient, node *client.HostNode, datacenterConfig *config.DataCenterConfig) *Cluster

CreateCluster create node controller

func (*Cluster) CacheNode Uses

func (n *Cluster) CacheNode(node *client.HostNode)

CacheNode add node to local cache

func (*Cluster) Collect Uses

func (n *Cluster) Collect(ch chan<- prometheus.Metric)

Collect prometheus collect

func (*Cluster) Describe Uses

func (n *Cluster) Describe(ch chan<- *prometheus.Desc)

Describe prometheus describe

func (*Cluster) GetAllNode Uses

func (n *Cluster) GetAllNode() (nodes []*client.HostNode)

GetAllNode get all node info from local cache

func (*Cluster) GetLabelsNode Uses

func (n *Cluster) GetLabelsNode(labels map[string]string) []string

GetLabelsNode return node ids that matching labels

func (*Cluster) GetNode Uses

func (n *Cluster) GetNode(id string) *client.HostNode

GetNode get rainbond node info

func (*Cluster) RemoveNode Uses

func (n *Cluster) RemoveNode(nodeID string)

RemoveNode remove node from local cache

func (*Cluster) Start Uses

func (n *Cluster) Start(errchan chan error) error

Start 启动

func (*Cluster) Stop Uses

func (n *Cluster) Stop(i interface{})

Stop 停止

func (*Cluster) UpdateNode Uses

func (n *Cluster) UpdateNode(node *client.HostNode)

UpdateNode update node info

Package node imports 14 packages (graph) and is imported by 3 packages. Updated 2020-03-31. Refresh now. Tools for package owners.