blocksprovider

type BFTCensorshipMonitor struct {
	// contains filtered or unexported fields
}

type BFTCensorshipMonitorFactory struct{}

type BFTDeliverer struct {
	ChannelID    string
	BlockHandler BlockHandler
	Ledger       LedgerInfo

	UpdatableBlockVerifier    UpdatableBlockVerifier
	Dialer                    Dialer
	OrderersSourceFactory     OrdererConnectionSourceFactory
	CryptoProvider            bccsp.BCCSP
	DoneC                     chan struct{}
	Signer                    identity.SignerSerializer
	DeliverStreamer           DeliverStreamer
	CensorshipDetectorFactory CensorshipDetectorFactory
	Logger                    *flogging.FabricLogger

	// The initial value of the actual retry interval, which is increased on every failed retry
	InitialRetryInterval time.Duration
	// The maximal value of the actual retry interval, which cannot increase beyond this value
	MaxRetryInterval time.Duration
	// If a certain header from a header receiver is in front of the block receiver for more that this time, a
	// censorship event is declared and the block source is changed.
	BlockCensorshipTimeout time.Duration
	// After this duration, the MaxRetryDurationExceededHandler is called to decide whether to keep trying
	MaxRetryDuration time.Duration
	// This function is called after MaxRetryDuration of failed retries to decide whether to keep trying
	MaxRetryDurationExceededHandler MaxRetryDurationExceededHandler

	// TLSCertHash should be nil when TLS is not enabled
	TLSCertHash []byte // util.ComputeSHA256(b.credSupport.GetClientCertificate().Certificate[0])
	// contains filtered or unexported fields
}

type BFTHeaderReceiver struct {
	// contains filtered or unexported fields
}

type BlockHandler interface {
	// HandleBlock gives the block to the next stage of processing after fetching it from a remote orderer.
	HandleBlock(channelID string, block *common.Block) error
}

type BlockProgressReporter interface {
	// BlockProgress returns the last block fetched from an orderer, and the time it was fetched.
	// If the fetch time IsZero == true, no block had been fetched yet (block number will always be zero in that case).
	BlockProgress() (uint64, time.Time)
}

type BlockReceiver struct {
	// contains filtered or unexported fields
}

type CensorshipDetector interface {
	Monitor()
	Stop()
	ErrorsChannel() <-chan error
}

type CensorshipDetectorFactory interface {
	Create(
		chainID string,
		updatableVerifier UpdatableBlockVerifier,
		requester DeliverClientRequester,
		progressReporter BlockProgressReporter,
		fetchSources []*orderers.Endpoint,
		blockSourceIndex int,
		timeoutConf TimeoutConfig,
	) CensorshipDetector
}

type DeliverAdapter struct{}

type DeliverClientRequester interface {
	SeekInfoHeadersFrom(ledgerHeight uint64) (*common.Envelope, error)
	Connect(seekInfoEnv *common.Envelope, endpoint *orderers.Endpoint) (orderer.AtomicBroadcast_DeliverClient, func(), error)
}

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

type Deliverer struct {
	ChannelID              string
	BlockHandler           BlockHandler
	Ledger                 LedgerInfo
	UpdatableBlockVerifier UpdatableBlockVerifier
	Dialer                 Dialer
	OrderersSourceFactory  OrdererConnectionSourceFactory
	CryptoProvider         bccsp.BCCSP
	DoneC                  chan struct{}
	Signer                 identity.SignerSerializer
	DeliverStreamer        DeliverStreamer
	Logger                 *flogging.FabricLogger

	// The maximal value of the actual retry interval, which cannot increase beyond this value
	MaxRetryInterval time.Duration
	// The initial value of the actual retry interval, which is increased on every failed retry
	InitialRetryInterval time.Duration
	// After this duration, the MaxRetryDurationExceededHandler is called to decide whether to keep trying
	MaxRetryDuration time.Duration
	// This function is called after MaxRetryDuration of failed retries to decide whether to keep trying
	MaxRetryDurationExceededHandler MaxRetryDurationExceededHandler

	// TLSCertHash should be nil when TLS is not enabled
	TLSCertHash []byte // util.ComputeSHA256(b.credSupport.GetClientCertificate().Certificate[0])
	// contains filtered or unexported fields
}

type DeliveryRequester struct {
	// contains filtered or unexported fields
}

type Dialer interface {
	Dial(address string, rootCerts [][]byte) (*grpc.ClientConn, error)
}

type DialerAdapter struct {
	ClientConfig comm.ClientConfig
}

type DurationExceededHandler interface {
	DurationExceededHandler() (stopRetries bool)
}

type ErrCensorship struct {
	Message string
}

type ErrFatal struct {
	Message string
}

type ErrStopping struct {
	Message string
}

type GossipServiceAdapter interface {
	// AddPayload adds payload to the local state sync buffer
	AddPayload(chainID string, payload *gossip.Payload) error

	// Gossip the message across the peers
	Gossip(msg *gossip.GossipMessage)
}

type LedgerInfo interface {
	// LedgerHeight returns current local ledger height
	LedgerHeight() (uint64, error)

	// GetCurrentBlockHash returns the block header hash of the last block in the ledger.
	GetCurrentBlockHash() ([]byte, error)
}

type MaxRetryDurationExceededHandler func() (stopRetries bool)

type OrdererConnectionSource orderers.ConnectionSourcer

type OrdererConnectionSourceFactory orderers.ConnectionSourceCreator

type TimeoutConfig struct {
	// The initial value of the actual retry interval, which is increased on every failed retry
	MinRetryInterval time.Duration
	// The maximal value of the actual retry interval, which cannot increase beyond this value
	MaxRetryInterval time.Duration
	// The value of the bft censorship detection timeout
	BlockCensorshipTimeout time.Duration
}

type UpdatableBlockVerifier deliverclient.CloneableUpdatableBlockVerifier