rootchain

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

type ConsensusManager interface {
	// RequestCertification accepts certification requests with proof of quorum or no-quorum.
	RequestCertification(ctx context.Context, cr consensus.IRChangeRequest) error
	// CertificationResult read the channel to receive certification results
	CertificationResult() <-chan *certification.CertificationResponse
	ShardInfo(partition types.PartitionID, shard types.ShardID) (*storage.ShardInfo, error)
	// Run consensus algorithm
	Run(ctx context.Context) error
}

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

type Observability interface {
	Meter(name string, opts ...metric.MeterOption) metric.Meter
	Tracer(name string, options ...trace.TracerOption) trace.Tracer
	Logger() *slog.Logger
}

type PartitionNet interface {
	Send(ctx context.Context, msg any, receivers ...peer.ID) error
	ReceivedChannel() <-chan any
}

type QuorumInfo interface {
	GetQuorum() uint64
	GetTotalNodes() uint64
}

type QuorumStatus uint8

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