rdp

Documentation

Index

• Constants
• Variables
• 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
• type ICluster
• type Packet
• type Peer
  • func (p *Peer) IsAccepted() bool
  • func (p *Peer) UpdateMetrics(m *metricsCmd) error
• type PeerKey
  • 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
• type RecordInfo
• type SignedMessage
• type Version
  • 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

Constants

const (
	ZeroVersion = Version(0)
)

Variables

var ProtectedCommands *commandRegistry

Protected Encrypted ProtectedCommands over channels

Functions

func Client

func Client(version Version, logger *zap.Logger) (res *client)

func Cluster

func Cluster(outbox chan *outboxMessage, id uint16, name string, partitions uint32, logger *zap.Logger) (res *cluster)

func Partition

func Partition() (res *partition)

func Server

func Server(name string, logger *zap.Logger) (res *server)

Types

type DataSetStat

type DataSetStat struct {
	ID      uint16
	Records uint64
	Bytes   uint64
}

18 bytes

type ICluster

type ICluster interface {
	ID() crypto.Certificate
	Start(peer string, config interface{}) error
	Stop(peer string) error
	Disable(peer string) (err error)
}

type Packet

type Packet [300]byte

type Peer

type Peer struct {
	// contains filtered or unexported fields
}

func (*Peer) IsAccepted

func (p *Peer) IsAccepted() bool

func (*Peer) UpdateMetrics

func (p *Peer) UpdateMetrics(m *metricsCmd) error

type PeerKey

type PeerKey [64]byte

func NewPeerKey

func NewPeerKey(id crypto.Certificate, pub crypto.PublicKey) (res PeerKey)

func (PeerKey) ID

func (pk PeerKey) ID() (res crypto.Certificate)

func (PeerKey) Public

func (pk PeerKey) Public() (res crypto.PublicKey)

type ProtectedCommand

type ProtectedCommand struct {
	Command uint16
	Payload []byte
}

type RecordInfo

type RecordInfo struct {
	Count uint64
	Bytes uint64
}

type SignedMessage

type SignedMessage struct {
	Data      []byte
	Signature []byte
}

type Version

type Version uint32

func FromString

func FromString(str string) Version

func NewVersion

func NewVersion(major, minor byte, build uint16) (res Version)

func (Version) Build

func (v Version) Build() uint16

func (Version) CompareByMinor

func (v Version) CompareByMinor(v2 Version) int

func (Version) Major

func (v Version) Major() byte

func (Version) Minor

func (v Version) Minor() byte

func (Version) String

func (v Version) String() string