node

Documentation

Index

• Variables
• type Cfg
  • func NewCfg() *Cfg
• type Node
  • func NewNode(clientAddr string, cfg *Cfg, drivers []storage.Driver) (*Node, error)
  • func (n *Node) Start() *raftstore.Store
  • func (n *Node) Stop() error

Variables

var (
	// ErrNodeAndPDNotMatch error for node and pd server are not match
	ErrNodeAndPDNotMatch = errors.New("Node and pd server are not match")
)

Types

type Cfg

type Cfg struct {
	ClusterID   uint64
	StoreLables []metapb.Label
	PDEndpoints []string

	RaftStore *raftstore.Cfg
}

Cfg node cfg

func NewCfg

func NewCfg() *Cfg

NewCfg returns default cfg

type Node

type Node struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

Node node

func NewNode

func NewNode(clientAddr string, cfg *Cfg, drivers []storage.Driver) (*Node, error)

NewNode create a node instance, then init store, pd connection and init the cluster ID

func (*Node) Start

func (n *Node) Start() *raftstore.Store

Start start the node. if cluster is not bootstrapped, bootstrap cluster and create the first cell.

func (*Node) Stop

func (n *Node) Stop() error

Stop the node