blocksprovider

Documentation

Index

• type BlocksDeliverer
• type BlocksProvider
  • func NewBlocksProvider(chainID string, client streamClient, gossip GossipServiceAdapter, ...) BlocksProvider
• type GossipServiceAdapter
• type LedgerInfo

Types

type BlocksDeliverer

type BlocksDeliverer interface {
	Recv() (*orderer.DeliverResponse, error)

	Send(*common.Envelope) error
}

type BlocksProvider

type BlocksProvider interface {
	DeliverBlocks()

	UpdateOrderingEndpoints(endpoints []string)

	Stop()
}

func NewBlocksProvider

func NewBlocksProvider(chainID string, client streamClient, gossip GossipServiceAdapter, mcs api.MessageCryptoService) BlocksProvider

type GossipServiceAdapter

type GossipServiceAdapter interface {
	PeersOfChannel(gossipcommon.ChannelID) []discovery.NetworkMember

	AddPayload(chainID string, payload *gossip_proto.Payload) error

	Gossip(msg *gossip_proto.GossipMessage)
}

type LedgerInfo

type LedgerInfo interface {
	LedgerHeight() (uint64, error)
}