Versions in this module Expand all Collapse all v0 v0.0.1 Jul 5, 2020 Changes in this version + const ZeroVersion + var ProtectedCommands *commandRegistry + func Client(version Version, logger *zap.Logger) (res *client) + func Cluster(outbox chan *outboxMessage, id uint16, name string, partitions uint32, ...) (res *cluster) + func Partition() (res *partition) + func Server(name string, logger *zap.Logger) (res *server) + type DataSetStat struct + Bytes uint64 + ID uint16 + Records uint64 + type ICluster interface + Disable func(peer string) (err error) + ID func() crypto.Certificate + Start func(peer string, config interface{}) error + Stop func(peer string) error + type Packet [300]byte + type Peer struct + func (p *Peer) IsAccepted() bool + func (p *Peer) UpdateMetrics(m *metricsCmd) error + type PeerKey [64]byte + func NewPeerKey(id crypto.Certificate, pub crypto.PublicKey) (res PeerKey) + func (pk PeerKey) ID() (res crypto.Certificate) + func (pk PeerKey) Public() (res crypto.PublicKey) + type ProtectedCommand struct + Command uint16 + Payload []byte + type RecordInfo struct + Bytes uint64 + Count uint64 + type SignedMessage struct + Data []byte + Signature []byte + type Version uint32 + func FromString(str string) Version + func NewVersion(major, minor byte, build uint16) (res Version) + func (v Version) Build() uint16 + func (v Version) CompareByMinor(v2 Version) int + func (v Version) Major() byte + func (v Version) Minor() byte + func (v Version) String() string