Versions in this module Expand all Collapse all v0 v0.1.0 Apr 19, 2020 Changes in this version + const Accepted + const AcceptedFrontier + const Chits + const CurrentVersion + const Data + const DecidedTx + const Get + const GetAccepted + const GetAcceptedFrontier + const GetPeerList + const GetVersion + const GetVersionTimeout + const IssueTx + const MaxClockDifference + const PeerList + const PeerListGossipSize + const PeerListGossipSpacing + const PeerListStakerGossipFraction + const Ping + const Pong + const PullQuery + const PushQuery + const Put + const ReconnectTimeout + const Version + var HandshakeNet = Handshake + var Messages = map[salticidae.Opcode][]Field + var VotingNet = Voting + func ToIPDesc(addr salticidae.NetAddr) (utils.IPDesc, error) + type Builder struct + func (m Builder) Accepted(chainID ids.ID, requestID uint32, containerIDs ids.Set) (Msg, error) + func (m Builder) AcceptedFrontier(chainID ids.ID, requestID uint32, containerIDs ids.Set) (Msg, error) + func (m Builder) Chits(chainID ids.ID, requestID uint32, containerIDs ids.Set) (Msg, error) + func (m Builder) Data(b []byte) (Msg, error) + func (m Builder) DecidedTx(txID ids.ID, status choices.Status) (Msg, error) + func (m Builder) Get(chainID ids.ID, requestID uint32, containerID ids.ID) (Msg, error) + func (m Builder) GetAccepted(chainID ids.ID, requestID uint32, containerIDs ids.Set) (Msg, error) + func (m Builder) GetAcceptedFrontier(chainID ids.ID, requestID uint32) (Msg, error) + func (m Builder) GetPeerList() (Msg, error) + func (m Builder) GetVersion() (Msg, error) + func (m Builder) IssueTx(chainID ids.ID, tx []byte) (Msg, error) + func (m Builder) PeerList(ipDescs []utils.IPDesc) (Msg, error) + func (m Builder) Ping() (Msg, error) + func (m Builder) Pong() (Msg, error) + func (m Builder) PullQuery(chainID ids.ID, requestID uint32, containerID ids.ID) (Msg, error) + func (m Builder) PushQuery(chainID ids.ID, requestID uint32, containerID ids.ID, container []byte) (Msg, error) + func (m Builder) Put(chainID ids.ID, requestID uint32, containerID ids.ID, container []byte) (Msg, error) + func (m Builder) Version(networkID uint32, myTime uint64, ip utils.IPDesc, myVersion string) (Msg, error) + type Codec struct + func (Codec) Pack(op salticidae.Opcode, fields map[Field]interface{}) (Msg, error) + func (Codec) Parse(op salticidae.Opcode, ds salticidae.DataStream) (Msg, error) + type Connections interface + Add func(salticidae.PeerID, ids.ShortID, utils.IPDesc) + Conns func() ([]salticidae.PeerID, []ids.ShortID, []utils.IPDesc) + ContainsID func(ids.ShortID) bool + ContainsIP func(utils.IPDesc) bool + ContainsPeerID func(salticidae.PeerID) bool + GetID func(salticidae.PeerID) (ids.ShortID, bool) + GetPeerID func(ids.ShortID) (salticidae.PeerID, bool) + IDs func() ids.ShortSet + IPs func() []utils.IPDesc + Len func() int + PeerIDs func() []salticidae.PeerID + Remove func(salticidae.PeerID, ids.ShortID) + RemoveID func(ids.ShortID) + RemovePeerID func(salticidae.PeerID) + func NewConnections() Connections + type Field uint32 + const Bytes + const ChainID + const ContainerBytes + const ContainerID + const ContainerIDs + const IP + const MyTime + const NetworkID + const Peers + const RequestID + const Status + const Tx + const TxID + const VersionStr + func (f Field) Packer() func(*wrappers.Packer, interface{}) + func (f Field) String() string + func (f Field) Unpacker() func(*wrappers.Packer) interface{} + type Handshake struct + func (nm *Handshake) AwaitConnections(awaiting *networking.AwaitingConnections) + func (nm *Handshake) Connect(addr salticidae.NetAddr) + func (nm *Handshake) Connections() Connections + func (nm *Handshake) Initialize(log logging.Logger, vdrs validators.Set, myAddr salticidae.NetAddr, ...) + func (nm *Handshake) SendGetVersion(peer salticidae.PeerID) + func (nm *Handshake) SendPeerList(peers ...salticidae.PeerID) error + func (nm *Handshake) SendVersion(peer salticidae.PeerID) error + func (nm *Handshake) Shutdown() + type Msg interface + DataStream func() salticidae.DataStream + Get func(Field) interface{} + Op func() salticidae.Opcode + type Voting struct + func (s *Voting) Accept(chainID, containerID ids.ID, container []byte) error + func (s *Voting) Accepted(validatorID ids.ShortID, chainID ids.ID, requestID uint32, ...) + func (s *Voting) AcceptedFrontier(validatorID ids.ShortID, chainID ids.ID, requestID uint32, ...) + func (s *Voting) Chits(validatorID ids.ShortID, chainID ids.ID, requestID uint32, votes ids.Set) + func (s *Voting) Get(validatorID ids.ShortID, chainID ids.ID, requestID uint32, containerID ids.ID) + func (s *Voting) GetAccepted(validatorIDs ids.ShortSet, chainID ids.ID, requestID uint32, ...) + func (s *Voting) GetAcceptedFrontier(validatorIDs ids.ShortSet, chainID ids.ID, requestID uint32) + func (s *Voting) Initialize(log logging.Logger, vdrs validators.Set, peerNet salticidae.PeerNetwork, ...) + func (s *Voting) PullQuery(validatorIDs ids.ShortSet, chainID ids.ID, requestID uint32, ...) + func (s *Voting) PushQuery(validatorIDs ids.ShortSet, chainID ids.ID, requestID uint32, ...) + func (s *Voting) Put(validatorID ids.ShortID, chainID ids.ID, requestID uint32, containerID ids.ID, ...) + func (s *Voting) Shutdown()
Go to main page