distributed

package

v0.0.127 Latest Latest Go to latest Published: Jan 17, 2025 License: GPL-3.0 Imports: 19 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 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, node string) *Replication

Constants ¶

This section is empty.

Variables ¶

This section is empty.

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
	Node        string
	DataC       chan KV
	EventsC     chan KV
	DnsUpdatesC chan KV
}

func New ¶

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

func (*Replication) HandleDns ¶ added in v0.0.119

func (replication *Replication) HandleDns(data KV)

func (*Replication) HandleEtcd ¶

func (replication *Replication) HandleEtcd(data KV)

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

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

Source Files ¶

View all Source files

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