distributed

Jan 21, 2025

Changes in this version

type Replication

+ NodeName string

+ Replicated *smaps.Smap

Jan 21, 2025

Changes in this version

type Replication

+ NodeID uint64

Jan 17, 2025

Changes in this version

type Replication

+ Node string

Jan 15, 2025

Changes in this version

type KV

+ Node uint64

type Replication

+ DnsUpdatesC chan KV

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

Jan 14, 2025

Changes in this version

+ func EtcDelete(key string) error

+ func EtcdPut(key string, value string) error

+ type KV struct

+ Agent string

+ Category int

+ Key string

+ Local bool

+ Val []byte

+ func NewDecode(decoder *gob.Decoder, agent string) KV

+ func NewEncode(key string, value []byte, agent string, category int) KV

+ func (kv KV) IsLocal() bool

+ type Replication struct

+ Client *client.Client

+ DataC chan KV

+ EventsC chan KV

+ User *authentication.User

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

+ 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