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从订购服务检索响应
	Recv() (*orderer.DeliverResponse, error)

	//发送将信封发送到订购服务
	Send(*common.Envelope) error
}

BlocksDeliverer定义了实际上有助于 只使用 块提供程序所需的方法。 这也使GRPC流的生产实现脱钩 为了使代码更加模块化和可测试性。

type BlocksProvider

type BlocksProvider interface {
	//传递块开始传递和传播块
	DeliverBlocks()

	//UpdateClientEndpoints更新终结点
	UpdateOrderingEndpoints(endpoints []string)

	//停止关闭块提供程序并停止传递新块
	Stop()
}

blocksProvider用于从订购服务读取块 对于它订阅的指定链

func NewBlocksProvider

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

NewblocksProvider构造函数用于创建块交付器实例的函数

type GossipServiceAdapter

type GossipServiceAdapter interface {
	//PeerSofChannel返回具有指定通道成员的切片
	PeersOfChannel(gossipcommon.ChainID) []discovery.NetworkMember

	//AddPayload将负载添加到本地状态同步缓冲区
	AddPayload(chainID string, payload *gossip_proto.Payload) error

	//在同龄人之间闲聊信息
	Gossip(msg *gossip_proto.GossipMessage)
}

GossipsServiceAdapter提供基本功能 送货服务需要八卦服务

type LedgerInfo

type LedgerInfo interface {
	//LedgerHeight返回当前本地分类帐高度
	LedgerHeight() (uint64, error)
}

提供查询接口的适配器 当前分类帐高度的分类帐提交者