distributed

Documentation

Index

• func EtcDelete(key string) error
• func EtcdPut(key string, value string) error
• type KV
  • func NewDecode(decoder *gob.Decoder, node uint64) KV
  • func NewEncode(key string, value []byte, node uint64, category int) KV
  • func (kv KV) IsLocal() bool
• type Replication
  • func New(client *client.Client, user *authentication.User) *Replication
  • func (replication *Replication) HandleDns(data KV)
  • func (replication *Replication) HandleEtcd(data KV)
  • func (replication *Replication) HandleInvalid(data KV)
  • func (replication *Replication) HandleObject(data KV)
  • func (replication *Replication) HandleObjectDelete(data KV)
  • func (replication *Replication) HandlePlain(data KV)
  • func (replication *Replication) HandleSecret(data KV)
  • func (replication *Replication) ListenData(agent string)
  • func (replication *Replication) ListenEtcd(agent string) error

Functions

func EtcDelete

func EtcDelete(key string) error

func EtcdPut

func EtcdPut(key string, value string) error

Types

type KV

type KV struct {
	Key      string
	Val      []byte
	Category int
	Node     uint64
	Local    bool
}

func NewDecode

func NewDecode(decoder *gob.Decoder, node uint64) KV

func NewEncode

func NewEncode(key string, value []byte, node uint64, category int) KV

func (KV) IsLocal

func (kv KV) IsLocal() bool

type Replication

type Replication struct {
	Client      *client.Client
	User        *authentication.User
	DataC       chan KV
	EventsC     chan KV
	DnsUpdatesC chan KV
}

func New

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

func (*Replication) HandleDns

func (replication *Replication) HandleDns(data KV)

func (*Replication) HandleEtcd

func (replication *Replication) HandleEtcd(data KV)

func (*Replication) HandleInvalid

func (replication *Replication) HandleInvalid(data KV)

func (*Replication) HandleObject

func (replication *Replication) HandleObject(data KV)

func (*Replication) HandleObjectDelete

func (replication *Replication) HandleObjectDelete(data KV)

func (*Replication) HandlePlain

func (replication *Replication) HandlePlain(data KV)

func (*Replication) HandleSecret

func (replication *Replication) HandleSecret(data KV)

func (*Replication) ListenData

func (replication *Replication) ListenData(agent string)

func (*Replication) ListenEtcd

func (replication *Replication) ListenEtcd(agent string) error