distributed

package
v0.0.135 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jan 21, 2025 License: GPL-3.0 Imports: 20 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Replication

type Replication struct {
	Client      *client.Client
	User        *authentication.User
	NodeName    string
	DataC       chan KV.KV
	EventsC     chan KV.KV
	DnsUpdatesC chan KV.KV
	Replicated  *smaps.Smap
}

func New

func New(client *client.Client, user *authentication.User, nodeName string) *Replication

func (*Replication) HandleDns added in v0.0.119

func (replication *Replication) HandleDns(data KV.KV)

func (*Replication) HandleEtcd

func (replication *Replication) HandleEtcd(data KV.KV)

HandleEtcd handles the case when data is entered into etcd via other means than simplecontainer - flannel only

func (*Replication) HandleInvalid

func (replication *Replication) HandleInvalid(data KV.KV)

func (*Replication) HandleObject

func (replication *Replication) HandleObject(data KV.KV)

func (*Replication) HandleObjectDelete

func (replication *Replication) HandleObjectDelete(data KV.KV)

func (*Replication) HandlePlain

func (replication *Replication) HandlePlain(data KV.KV)

func (*Replication) HandleSecret

func (replication *Replication) HandleSecret(data KV.KV)

func (*Replication) ListenData

func (replication *Replication) ListenData(agent string)

func (*Replication) ListenEtcd

func (replication *Replication) ListenEtcd(agent string)

Jump to

Keyboard shortcuts

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