cluster

Documentation

Index

• func NewEtcdClient() *clientv3.Client
• func SendRequest(client *client.Http, user *authentication.User, URL string, data string) *contracts.ResponseImplementation
• type Cluster
  • func New() *Cluster
  • func Restore(config *configuration.Configuration) (*Cluster, error)
  • func (c *Cluster) ConfigureFlannel(network string) error
  • func (c *Cluster) ListenEvents(agent string)
  • func (c *Cluster) ListenObjects(agent string)
  • func (c *Cluster) ListenUpdates(agent string)
  • func (c *Cluster) StartSingleNodeEtcd(config *configuration.Configuration) (e *embed.Etcd, err error)

Functions

func NewEtcdClient

func NewEtcdClient() *clientv3.Client

func SendRequest

func SendRequest(client *client.Http, user *authentication.User, URL string, data string) *contracts.ResponseImplementation

Types

type Cluster

type Cluster struct {
	Node       *node.Node
	Cluster    *node.Nodes
	Client     *client.Http
	EtcdClient *clientv3.Client
	KVStore    *raft.KVStore
	RaftNode   *raft.RaftNode
	Started    bool
}

func New

func New() *Cluster

func Restore

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

func (*Cluster) ConfigureFlannel

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

func (*Cluster) ListenEvents

func (c *Cluster) ListenEvents(agent string)

func (*Cluster) ListenObjects

func (c *Cluster) ListenObjects(agent string)

func (*Cluster) ListenUpdates

func (c *Cluster) ListenUpdates(agent string)

func (*Cluster) StartSingleNodeEtcd

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