network

May 16, 2019

Changes in this version

type ConfirmMap

+ func (m *ConfirmMap) Store(key crypto.Hash, ts time.Time)

type SyncHandle

+ VerifyAndQueueAppendSnapshot func(peerId crypto.Hash, s *common.Snapshot) error

Apr 30, 2019

Changes in this version

type Peer

+ func (me *Peer) ConfirmTransactionForPeer(idForNetwork crypto.Hash, ver *common.VersionedTransaction)

Mar 5, 2019

Changes in this version

+ type UnixClient struct

+ func (c *UnixClient) Close() error

+ func (c *UnixClient) Receive() ([]byte, error)

+ func (c *UnixClient) Send(data []byte) error

+ type UnixTransport struct

+ func NewUnixClient(addr string) (*UnixTransport, error)

+ func NewUnixServer(addr string) (*UnixTransport, error)

+ func (t *UnixTransport) Accept() (Client, error)

+ func (t *UnixTransport) Dial() (Client, error)

+ func (t *UnixTransport) Listen() error

Feb 27, 2019

Changes in this version

+ const PeerMessageTypeSnapshot

+ type ConfirmMap struct

+ func (m *ConfirmMap) Exist(key crypto.Hash, duration time.Duration) bool

type Peer

+ func (me *Peer) SendSnapshotMessage(idForNetwork crypto.Hash, s *common.Snapshot, finalized byte) error

+ func (p *Peer) SendHigh(key crypto.Hash, data []byte) error

+ func (p *Peer) SendNormal(key crypto.Hash, data []byte) error

type PeerMessage

+ Data []byte

+ Finalized byte

type SyncHandle

+ QueueAppendSnapshot func(peerId crypto.Hash, s *common.Snapshot) error

+ type TcpClient struct

+ func (c *TcpClient) Close() error

+ func (c *TcpClient) Receive() ([]byte, error)

+ func (c *TcpClient) Send(data []byte) error

+ type TcpTransport struct

+ func NewTcpClient(addr string) (*TcpTransport, error)

+ func NewTcpServer(addr string) (*TcpTransport, error)

+ func (t *TcpTransport) Accept() (Client, error)

+ func (t *TcpTransport) Dial() (Client, error)

+ func (t *TcpTransport) Listen() error

Feb 12, 2020

Changes in this version

+ const HandshakeTimeout

+ const IdleTimeout

+ const MaxIncomingStreams

+ const PeerMessageTypeAuthentication

+ const PeerMessageTypeGraph

+ const PeerMessageTypePing

+ const PeerMessageTypeSnapshotAnnoucement

+ const PeerMessageTypeSnapshotCommitment

+ const PeerMessageTypeSnapshotConfirm

+ const PeerMessageTypeSnapshotFinalization

+ const PeerMessageTypeSnapshotResponse

+ const PeerMessageTypeTransaction

+ const PeerMessageTypeTransactionChallenge

+ const PeerMessageTypeTransactionRequest

+ const ReadDeadline

+ const TransportCompressionGzip

+ const TransportCompressionMethod

+ const TransportCompressionZstd

+ const TransportMessageHeaderSize

+ const TransportMessageMaxSize

+ const TransportMessageVersion

+ const WriteDeadline

+ type ChanMsg struct

+ type Client interface

+ Close func() error

+ Receive func() ([]byte, error)

+ RemoteAddr func() net.Addr

+ Send func([]byte) error

+ type Peer struct

+ Address string

+ IdForNetwork crypto.Hash

+ func NewPeer(handle SyncHandle, idForNetwork crypto.Hash, addr string) *Peer

+ func (me *Peer) AddNeighbor(idForNetwork crypto.Hash, addr string) (*Peer, error)

+ func (me *Peer) ConfirmSnapshotForPeer(idForNetwork, snap crypto.Hash)

+ func (me *Peer) ListenNeighbors() error

+ func (me *Peer) SendSnapshotAnnouncementMessage(idForNetwork crypto.Hash, s *common.Snapshot, R crypto.Key) error

+ func (me *Peer) SendSnapshotCommitmentMessage(idForNetwork crypto.Hash, snap crypto.Hash, R crypto.Key, wantTx bool) error

+ func (me *Peer) SendSnapshotConfirmMessage(idForNetwork crypto.Hash, snap crypto.Hash) error

+ func (me *Peer) SendSnapshotFinalizationMessage(idForNetwork crypto.Hash, s *common.Snapshot) error

+ func (me *Peer) SendSnapshotResponseMessage(idForNetwork crypto.Hash, snap crypto.Hash, si [32]byte) error

+ func (me *Peer) SendTransactionChallengeMessage(idForNetwork crypto.Hash, snap crypto.Hash, cosi *crypto.CosiSignature, ...) error

+ func (me *Peer) SendTransactionMessage(idForNetwork crypto.Hash, ver *common.VersionedTransaction) error

+ func (me *Peer) SendTransactionRequestMessage(idForNetwork crypto.Hash, tx crypto.Hash) error

+ type PeerMessage struct

+ Auth []byte

+ Commitment crypto.Key

+ Cosi crypto.CosiSignature

+ FinalCache []*SyncPoint

+ Response [32]byte

+ Snapshot *common.Snapshot

+ SnapshotHash crypto.Hash

+ Transaction *common.VersionedTransaction

+ TransactionHash crypto.Hash

+ Type uint8

+ WantTx bool

+ type QuicClient struct

+ func (c *QuicClient) Close() error

+ func (c *QuicClient) Receive() ([]byte, error)

+ func (c *QuicClient) RemoteAddr() net.Addr

+ func (c *QuicClient) Send(data []byte) error

+ type QuicTransport struct

+ func NewQuicClient(addr string) (*QuicTransport, error)

+ func NewQuicServer(addr string) (*QuicTransport, error)

+ func (t *QuicTransport) Accept() (Client, error)

+ func (t *QuicTransport) Dial() (Client, error)

+ func (t *QuicTransport) Listen() error

+ type SyncHandle interface

+ Authenticate func(msg []byte) (crypto.Hash, string, error)

+ BuildAuthenticationMessage func() []byte

+ BuildGraph func() []*SyncPoint

+ CachePutTransaction func(peerId crypto.Hash, ver *common.VersionedTransaction) error

+ CosiAggregateSelfCommitments func(peerId crypto.Hash, snap crypto.Hash, commitment *crypto.Key, wantTx bool) error

+ CosiAggregateSelfResponses func(peerId crypto.Hash, snap crypto.Hash, response *[32]byte) error

+ CosiQueueExternalAnnouncement func(peerId crypto.Hash, s *common.Snapshot, R *crypto.Key) error

+ CosiQueueExternalChallenge func(peerId crypto.Hash, snap crypto.Hash, cosi *crypto.CosiSignature, ...) error

+ GetCacheStore func() *fastcache.Cache

+ ReadAllNodes func() []crypto.Hash

+ ReadSnapshotsForNodeRound func(nodeIdWithNetwork crypto.Hash, round uint64) ([]*common.SnapshotWithTopologicalOrder, error)

+ ReadSnapshotsSinceTopology func(offset, count uint64) ([]*common.SnapshotWithTopologicalOrder, error)

+ SendTransactionToPeer func(peerId, tx crypto.Hash) error

+ UpdateSyncPoint func(peerId crypto.Hash, points []*SyncPoint)

+ VerifyAndQueueAppendSnapshotFinalization func(peerId crypto.Hash, s *common.Snapshot) error

+ type SyncPoint struct

+ Hash crypto.Hash

+ NodeId crypto.Hash

+ Number uint64

+ type Transport interface

+ Accept func() (Client, error)

+ Dial func() (Client, error)

+ Listen func() error

+ type TransportMessage struct

+ Compression uint8

+ Data []byte

+ Size uint32

+ Version uint8