node

Documentation

Index

• type Cluster
  • func CreateCluster(kubecli kubecache.KubeClient, node *client.HostNode, ...) *Cluster
  • func (n *Cluster) CacheNode(node *client.HostNode)
  • func (n *Cluster) Collect(ch chan<- prometheus.Metric)
  • func (n *Cluster) Describe(ch chan<- *prometheus.Desc)
  • func (n *Cluster) GetAllNode() (nodes []*client.HostNode)
  • func (n *Cluster) GetLabelsNode(labels map[string]string) []string
  • func (n *Cluster) GetNode(id string) *client.HostNode
  • func (n *Cluster) RemoveNode(nodeID string)
  • func (n *Cluster) Start(errchan chan error) error
  • func (n *Cluster) Stop(i interface{})
  • func (n *Cluster) UpdateNode(node *client.HostNode)

Types

type Cluster

type Cluster struct {
	// contains filtered or unexported fields
}

Cluster node controller

func CreateCluster

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

CreateCluster create node controller

func (*Cluster) CacheNode

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

CacheNode add node to local cache

func (*Cluster) Collect

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

Collect prometheus collect

func (*Cluster) Describe

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

Describe prometheus describe

func (*Cluster) GetAllNode

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

GetAllNode get all node info from local cache

func (*Cluster) GetLabelsNode

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

GetLabelsNode return node ids that matching labels

func (*Cluster) GetNode

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

GetNode get rainbond node info

func (*Cluster) RemoveNode

func (n *Cluster) RemoveNode(nodeID string)

RemoveNode remove node from local cache

func (*Cluster) Start

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

Start 启动

func (*Cluster) Stop

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

Stop 停止

func (*Cluster) UpdateNode

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

UpdateNode update node info