Versions in this module Expand all Collapse all v1 v1.0.0 Jul 11, 2017 Changes in this version + type GossipAdapter interface + Accept func(acceptor common2.MessageAcceptor, passThrough bool) (<-chan *proto.GossipMessage, <-chan proto.ReceivedMessage) + PeersOfChannel func(common2.ChainID) []discovery.NetworkMember + Send func(msg *proto.GossipMessage, peers ...*comm.RemotePeer) + UpdateChannelMetadata func(metadata []byte, chainID common2.ChainID) + type GossipStateProvider interface + AddPayload func(payload *proto.Payload) error + GetBlock func(index uint64) *common.Block + Stop func() + func NewGossipStateProvider(chainID string, g GossipAdapter, committer committer.Committer, ...) GossipStateProvider + type GossipStateProviderImpl struct + func (s *GossipStateProviderImpl) AddPayload(payload *proto.Payload) error + func (s *GossipStateProviderImpl) GetBlock(index uint64) *common.Block + func (s *GossipStateProviderImpl) Stop() + type NodeMetastate struct + LedgerHeight uint64 + func FromBytes(buf []byte) (*NodeMetastate, error) + func NewNodeMetastate(height uint64) *NodeMetastate + func (n *NodeMetastate) Bytes() ([]byte, error) + func (n *NodeMetastate) Height() uint64 + func (n *NodeMetastate) Update(height uint64) + type PayloadsBuffer interface + Close func() + Next func() uint64 + Pop func() *proto.Payload + Push func(payload *proto.Payload) error + Ready func() chan struct{} + Size func() int + func NewPayloadsBuffer(next uint64) PayloadsBuffer + type PayloadsBufferImpl struct + func (b *PayloadsBufferImpl) Close() + func (b *PayloadsBufferImpl) Next() uint64 + func (b *PayloadsBufferImpl) Pop() *proto.Payload + func (b *PayloadsBufferImpl) Push(payload *proto.Payload) error + func (b *PayloadsBufferImpl) Ready() chan struct{} + func (b *PayloadsBufferImpl) Size() int
Go to main page