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

May 9, 2019

Changes in this version

type SyncHandle

+ GetCacheStore func() *bigcache.BigCache

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 HandshakeTimeout

+ const IdleTimeout

+ const MaxIncomingStreams

+ const PeerMessageTypeAuthentication

+ const PeerMessageTypeGraph

+ const PeerMessageTypePing

+ const PeerMessageTypeSnapshot

+ const PeerMessageTypeSnapshotConfirm

+ const PeerMessageTypeTransaction

+ const PeerMessageTypeTransactionRequest

+ const ReadDeadline

+ const TransportMessageHeaderSize

+ const TransportMessageMaxSize

+ const TransportMessageVersion

+ const WriteDeadline

+ type ChanMsg struct

+ type Client interface

+ Close func() error

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

+ Send func([]byte) error

+ type ConfirmMap struct

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

+ 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)

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

+ func (me *Peer) ListenNeighbors() error

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

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

+ func (me *Peer) SendTransactionMessage(idForNetwork crypto.Hash, tx *common.SignedTransaction) error

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

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

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

+ type PeerMessage struct

+ Data []byte

+ FinalCache []*SyncPoint

+ Finalized byte

+ Snapshot *common.Snapshot

+ SnapshotHash crypto.Hash

+ Transaction *common.SignedTransaction

+ TransactionHash crypto.Hash

+ Type uint8

+ type QuicClient struct

+ func (c *QuicClient) Close() error

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

+ 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, error)

+ BuildAuthenticationMessage func() []byte

+ BuildGraph func() []*SyncPoint

+ CachePutTransaction func(tx *common.SignedTransaction) error

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

+ 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)

+ type SyncPoint struct

+ Hash crypto.Hash

+ NodeId crypto.Hash

+ Number uint64

+ 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

+ type Transport interface

+ Accept func() (Client, error)

+ Dial func() (Client, error)

+ Listen func() error

+ type TransportMessage struct

+ Data []byte

+ Size uint32

+ Version uint8