nodeserver

Documentation

Index

• func CreateNode(cfg *conf.Conf, nodeID, ip string) model.HostNode
• func GetCurrentNode(cfg *conf.Conf) (*model.HostNode, error)
• type Config
• type Jobs
• type NodeServer
  • func NewNodeServer(cfg *conf.Conf) (*NodeServer, error)
  • func (n *NodeServer) Regist() error
  • func (n *NodeServer) Run(errchan chan error) (err error)
  • func (n *NodeServer) Stop(i interface{})

Functions

func CreateNode

func CreateNode(cfg *conf.Conf, nodeID, ip string) model.HostNode

CreateNode 创建节点信息

func GetCurrentNode

func GetCurrentNode(cfg *conf.Conf) (*model.HostNode, error)

GetCurrentNode 获取当前节点

Types

type Config

type Config struct {
	EtcdEndPoints        []string
	EtcdTimeout          int
	EtcdPrefix           string
	ClusterName          string
	APIAddr              string
	K8SConfPath          string
	EventServerAddress   []string
	PrometheusMetricPath string
	TTL                  int64
}

Config config server

type Jobs

type Jobs map[string]*corejob.Job

Jobs jobs

type NodeServer

type NodeServer struct {
	*store.Client
	*model.HostNode
	*cron.Cron

	//Config
	*conf.Conf
	// contains filtered or unexported fields
}

NodeServer node manager server

func NewNodeServer

func NewNodeServer(cfg *conf.Conf) (*NodeServer, error)

NewNodeServer new server

func (*NodeServer) Regist

func (n *NodeServer) Regist() error

Regist 节点注册

func (*NodeServer) Run

func (n *NodeServer) Run(errchan chan error) (err error)

Run 启动

func (*NodeServer) Stop

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

Stop 停止服务