blocksprovider

Documentation

Index

• type BlockVerifier
• type DeliverStreamer
• type Deliverer
  • func (d *Deliverer) DeliverBlocks()
  • func (d *Deliverer) Stop()
• type Dialer
• type GossipServiceAdapter
• type LedgerInfo
• type OrdererConnectionSource

Types

type BlockVerifier

type BlockVerifier interface {
	VerifyBlock(channelID gossipcommon.ChannelID, blockNum uint64, block *common.Block) error
}

type DeliverStreamer

type DeliverStreamer interface {
	Deliver(context.Context, *grpc.ClientConn) (orderer.AtomicBroadcast_DeliverClient, error)
}

type Deliverer

type Deliverer struct {
	ChannelID       string
	Gossip          GossipServiceAdapter
	Ledger          LedgerInfo
	BlockVerifier   BlockVerifier
	Dialer          Dialer
	Orderers        OrdererConnectionSource
	DoneC           chan struct{}
	Signer          identity.SignerSerializer
	DeliverStreamer DeliverStreamer
	Logger          *flogging.FabricLogger

	MaxRetryDelay     time.Duration
	InitialRetryDelay time.Duration
	MaxRetryDuration  time.Duration

	TLSCertHash []byte
	// contains filtered or unexported fields
}

func (*Deliverer) DeliverBlocks

func (d *Deliverer) DeliverBlocks()

func (*Deliverer) Stop

func (d *Deliverer) Stop()

type Dialer

type Dialer interface {
	Dial(address string, certPool *x509.CertPool) (*grpc.ClientConn, error)
}

type GossipServiceAdapter

type GossipServiceAdapter interface {
	AddPayload(chainID string, payload *gossip.Payload) error

	Gossip(msg *gossip.GossipMessage)
}

type LedgerInfo

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

type OrdererConnectionSource

type OrdererConnectionSource interface {
	RandomEndpoint() (*orderers.Endpoint, error)
}