batcher

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

type BAFCreator interface {
	CreateBAF(seq types.BatchSequence, primary types.PartyID, shard types.ShardID, digest []byte) types.BatchAttestationFragment
}

type BAFSender interface {
	SendBAF(baf types.BatchAttestationFragment)
}

type BatchAcker interface {
	Ack(seq types.BatchSequence, to types.PartyID)
}

type BatchLedgeReader interface {
	Height(partyID types.PartyID) uint64
	RetrieveBatchByNumber(partyID types.PartyID, seq uint64) types.Batch
}

type BatchLedger interface {
	BatchLedgerWriter
	BatchLedgeReader
}

type BatchLedgerWriter interface {
	Append(partyID types.PartyID, batchSeq types.BatchSequence, batchedRequests types.BatchedRequests)
}

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

type BatchedRequestsVerifier interface {
	VerifyBatchedRequests(types.BatchedRequests) error
}

type Batcher struct {
	Net    Net
	Ledger *node_ledger.BatchLedgerArray
	// contains filtered or unexported fields
}

type BatcherDeliverService struct {
	LedgerArray *ledger.BatchLedgerArray
	Logger      types.Logger
}

type BatcherRole struct {
	Batchers                []types.PartyID
	BatchTimeout            time.Duration
	RequestInspector        RequestInspector
	ID                      types.PartyID
	Shard                   types.ShardID
	Threshold               int
	N                       uint16
	Logger                  types.Logger
	Ledger                  BatchLedger
	BatchPuller             BatchesPuller
	StateProvider           StateProvider
	BAFCreator              BAFCreator
	BAFSender               BAFSender
	BatchAcker              BatchAcker
	Complainer              Complainer
	BatchedRequestsVerifier BatchedRequestsVerifier
	MemPool                 MemPool
	BatchSequenceGap        types.BatchSequence
	// contains filtered or unexported fields
}

type BatchesPuller interface {
	PullBatches(from types.PartyID) <-chan types.Batch
	Stop()
}

type ClientRequestSigVerifier interface {
	VerifyClientRequestSig(req []byte) error
}

type Complainer interface {
	Complain(string)
}

type ConsensusStateReplicatorCreator interface {
	CreateStateConsensusReplicator(conf *node_config.BatcherNodeConfig, logger types.Logger) StateReplicator
}

type ConsensusStateReplicatorFactory struct{}

type ConsenterControlEventSender interface {
	SendControlEvent(ce state.ControlEvent) error
}

type ConsenterControlEventSenderCreator interface {
	CreateConsenterControlEventSender(TLSPrivateKeyFile config.RawBytes, TLSCertificateFile config.RawBytes, consenterInfo config.ConsenterInfo) ConsenterControlEventSender
}

type ConsenterControlEventSenderFactory struct{}

type ConsenterControlEventStream struct {
	ConsenterInfo  config.ConsenterInfo
	TLSPrivateKey  config.RawBytes
	TLSCertificate config.RawBytes
	// contains filtered or unexported fields
}

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

type EndpointAndCerts struct {
	Endpoint   string
	TLSCACerts []config.RawBytes
}

type MemPool interface {
	NextRequests(ctx context.Context) [][]byte
	RemoveRequests(requests ...string)
	Submit(request []byte) error
	Restart(bool)
	Close()
}

type Net interface {
	Stop()
}

type NoopClientRequestSigVerifier struct{}

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

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

type RequestInspector interface {
	RequestID(req []byte) string
}

type RequestVerifier interface {
	VerifyRequest(req []byte) error
}

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

type SeqAcker interface {
	Stop()
	HandleAck(seq types.BatchSequence, from types.PartyID)
	WaitForSecondaries(seq types.BatchSequence) chan struct{}
}

type Signer interface {
	Sign([]byte) ([]byte, error)
}

type StateProvider interface {
	GetLatestStateChan() <-chan *state.State
}

type StateReplicator interface {
	ReplicateState() <-chan *state.State
	Stop()
}