cluster

package

v0.0.72 Latest Latest Go to latest Published: Dec 13, 2024 License: GPL-3.0 Imports: 20 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/simplecontainer/smr

Links

Open Source Insights

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)

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func NewEtcdClient ¶

func NewEtcdClient() *clientv3.Client

func SendRequest ¶ added in v0.0.69

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 ¶ added in v0.0.69

func (c *Cluster) ListenObjects(agent string)

func (*Cluster) ListenUpdates ¶ added in v0.0.65

func (c *Cluster) ListenUpdates(agent string)

func (*Cluster) StartSingleNodeEtcd ¶

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

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL