distributed

Documentation

Index

• type Replication
  • func New(client *client.Client, user *authentication.User, nodeName string) *Replication
  • func (replication *Replication) HandleDns(format contracts.Format, data KV.KV)
  • func (replication *Replication) HandleObject(format contracts.Format, data KV.KV)
  • func (replication *Replication) HandleOutside(data KV.KV)
  • func (replication *Replication) HandlePlain(format contracts.Format, data KV.KV)
  • func (replication *Replication) HandleSecret(format contracts.Format, data KV.KV)
  • func (replication *Replication) ListenData(agent string)
  • func (replication *Replication) ListenOutside(agent string)

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

func (replication *Replication) HandleDns(format contracts.Format, data KV.KV)

func (*Replication) HandleObject

func (replication *Replication) HandleObject(format contracts.Format, data KV.KV)

func (*Replication) HandleOutside

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

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

func (*Replication) HandlePlain

func (replication *Replication) HandlePlain(format contracts.Format, data KV.KV)

func (*Replication) HandleSecret

func (replication *Replication) HandleSecret(format contracts.Format, data KV.KV)

func (*Replication) ListenData

func (replication *Replication) ListenData(agent string)

func (*Replication) ListenOutside

func (replication *Replication) ListenOutside(agent string)