deliverclient

Documentation

Index

• type BlocksDelivererFactory
• type DeliverService
  • func NewDeliverService(gossip blocksprovider.GossipServiceAdapter, endpoints []string, ...) (DeliverService, error)
  • func NewFactoryDeliverService(gossip blocksprovider.GossipServiceAdapter, factory BlocksDelivererFactory, ...) DeliverService

Types

type BlocksDelivererFactory

type BlocksDelivererFactory interface {
	// Create capable to instantiate new BlocksDeliverer
	Create() (blocksprovider.BlocksDeliverer, error)
}

BlocksDelivererFactory the factory interface to create instance of BlocksDeliverer interface which capable to bring blocks from the ordering service

type DeliverService

type DeliverService interface {
	// StartDeliverForChannel dynamically starts delivery of new blocks from ordering service
	// to channel peers.
	StartDeliverForChannel(chainID string, ledgerInfo blocksprovider.LedgerInfo) error

	// StopDeliverForChannel dynamically stops delivery of new blocks from ordering service
	// to channel peers.
	StopDeliverForChannel(chainID string) error

	// Stop terminates delivery service and closes the connection
	Stop()
}

DeliverService used to communicate with orderers to obtain new block and send the to the committer service

func NewDeliverService

func NewDeliverService(gossip blocksprovider.GossipServiceAdapter, endpoints []string, mcs api.MessageCryptoService) (DeliverService, error)

NewDeliverService construction function to create and initialize delivery service instance. It tries to establish connection to the specified in the configuration ordering service, in case it fails to dial to it, return nil

func NewFactoryDeliverService

func NewFactoryDeliverService(gossip blocksprovider.GossipServiceAdapter, factory BlocksDelivererFactory, conn *grpc.ClientConn, mcs api.MessageCryptoService) DeliverService

NewFactoryDeliverService construction function to create and initialize delivery service instance, with gossip service adapter and customized factory to create blocks deliverers.