cluster

type Cluster interface {
	GetDir(key string) (map[string]string, error)
	GetValue(key string) (string, error)
	SetValue(key, value string) error
	GetValueWithDefault(key string, setter func() (string, error)) (string, error)

	GetSecret(kms security.KMS, name string, bytes int) ([]byte, error)

	Update(desc *PeerDesc) error
	Part()
	Peers() []PeerDesc
	Watch() <-chan PeerEvent
}

type PeerAliveEvent struct {
	PeerDesc
}

type PeerDesc struct {
	ID      string `json:"id"`
	Era     string `json:"era"`
	Version string `json:"version"`
}

type PeerEvent interface {
	Peer() *PeerDesc
}

type PeerJoinedEvent struct {
	PeerDesc
}

type PeerList []PeerDesc

type PeerLostEvent struct {
	PeerDesc
}

type TestCluster struct {
	sync.Mutex
	// contains filtered or unexported fields
}