node

Documentation

Index

• type Control
• type Health
• type Node
  • func NewNode() *Node
  • func NewNodeDefinition(cluster []*Node, nodeId uint64) *Node
  • func (node *Node) Accepting() bool
  • func (node *Node) Parse(change raftpb.ConfChange) error
  • func (node *Node) SetDrain(drain bool)
  • func (node *Node) SetUpgrade(upgrade bool)
  • func (node *Node) ToJSON() ([]byte, error)
• type Nodes
  • func NewNodes() *Nodes
  • func (nodes *Nodes) Add(node *Node)
  • func (nodes *Nodes) AddOrUpdate(node *Node)
  • func (nodes *Nodes) Find(node *Node) *Node
  • func (nodes *Nodes) FindById(id uint64) *Node
  • func (nodes *Nodes) GenerateID() uint64
  • func (nodes *Nodes) NewNode(nodeName string, url string, API string) *Node
  • func (nodes *Nodes) Remove(node *Node)
  • func (nodes *Nodes) ToString() []string
• type State
  • func NewState() State

Types

type Control

type Control struct {
	Upgrading  bool
	Draining   bool
	Recovering bool
}

type Health

type Health struct {
	Cluster        bool
	Etcd           bool
	Running        bool
	MemoryPressure bool
	CPUPressure    bool
}

type Node

type Node struct {
	NodeID     uint64
	NodeName   string
	API        string
	URL        string
	ConfChange raftpb.ConfChange `yaml:"-" json:"-"`
	State      State
	Version    *version.Version
}

func NewNode

func NewNode() *Node

func NewNodeDefinition

func NewNodeDefinition(cluster []*Node, nodeId uint64) *Node

func (*Node) Accepting

func (node *Node) Accepting() bool

func (*Node) Parse

func (node *Node) Parse(change raftpb.ConfChange) error

func (*Node) SetDrain

func (node *Node) SetDrain(drain bool)

func (*Node) SetUpgrade

func (node *Node) SetUpgrade(upgrade bool)

func (*Node) ToJSON

func (node *Node) ToJSON() ([]byte, error)

type Nodes

type Nodes struct {
	Nodes []*Node
}

func NewNodes

func NewNodes() *Nodes

func (*Nodes) Add

func (nodes *Nodes) Add(node *Node)

func (*Nodes) AddOrUpdate

func (nodes *Nodes) AddOrUpdate(node *Node)

func (*Nodes) Find

func (nodes *Nodes) Find(node *Node) *Node

func (*Nodes) FindById

func (nodes *Nodes) FindById(id uint64) *Node

func (*Nodes) GenerateID

func (nodes *Nodes) GenerateID() uint64

func (*Nodes) NewNode

func (nodes *Nodes) NewNode(nodeName string, url string, API string) *Node

func (*Nodes) Remove

func (nodes *Nodes) Remove(node *Node)

func (*Nodes) ToString

func (nodes *Nodes) ToString() []string

type State

type State struct {
	Health  Health
	Control Control
}

func NewState

func NewState() State