cluster

Documentation

Index

• func NewEtcdClient() *clientv3.Client
• type Cluster
  • func New(body io.ReadCloser) (*Cluster, error)
  • func Restore(config *configuration.Configuration) (*Cluster, error)
  • func (c *Cluster) Add(node *Node)
  • func (c *Cluster) ConfigureFlannel(network string) error
  • func (c *Cluster) ListenEvents()
  • func (c *Cluster) Remove(node *Node)
  • func (c *Cluster) Start(body io.ReadCloser)
  • func (c *Cluster) StartSingleNodeEtcd(config *configuration.Configuration) (e *embed.Etcd, err error)
• type Node
  • func NewNode(nodeID string, URL string) (*Node, error)
  • func NewNodeRequest(body io.ReadCloser) (*Node, error)

Functions

func NewEtcdClient

func NewEtcdClient() *clientv3.Client

Types

type Cluster

type Cluster struct {
	Node       *Node
	Cluster    []string
	EtcdClient *clientv3.Client
	KVStore    *raft.KVStore
	RaftNode   *raft.RaftNode
}

func New

func New(body io.ReadCloser) (*Cluster, error)

func Restore

func Restore(config *configuration.Configuration) (*Cluster, error)

func (*Cluster) Add

func (c *Cluster) Add(node *Node)

func (*Cluster) ConfigureFlannel

func (c *Cluster) ConfigureFlannel(network string) error

func (*Cluster) ListenEvents

func (c *Cluster) ListenEvents()

func (*Cluster) Remove

func (c *Cluster) Remove(node *Node)

func (*Cluster) Start

func (c *Cluster) Start(body io.ReadCloser)

func (*Cluster) StartSingleNodeEtcd

func (c *Cluster) StartSingleNodeEtcd(config *configuration.Configuration) (e *embed.Etcd, err error)

type Node

type Node struct {
	NodeID uint64
	URL    string
}

func NewNode

func NewNode(nodeID string, URL string) (*Node, error)

func NewNodeRequest

func NewNodeRequest(body io.ReadCloser) (*Node, error)