partition

type BlockAndState struct {
	Block *types.Block
	State UnitAndProof
}

type BlockProposalValidator interface {
	// Validate validates the given blockproposal.BlockProposal. Returns an error if given block proposal
	// is not valid.
	Validate(bp *blockproposal.BlockProposal, nodeSignatureVerifier crypto.Verifier) error
}

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

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

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

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

type GenesisOption func(c *genesisConf)

type IndexReader interface {
	GetOwnerUnits(ownerID []byte) ([]types.UnitID, error)
}

type IndexWriter interface {
	LoadState(s txsystem.StateReader) error
	IndexBlock(b *types.Block, s StateProvider) error
}

type LeaderSelector interface {
	UpdateLeader(uc *types.UnicityCertificate, validators []peer.ID)
	LeaderFunc(uc *types.UnicityCertificate, validators []peer.ID) peer.ID
	IsLeader(peer peer.ID) bool
	GetLeader() peer.ID
}

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

type NodeOption func(c *configuration)

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

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

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

type StateProvider interface {
	GetUnit(id types.UnitID, committed bool) (*state.Unit, error)
}

type TxIndex struct {
	RoundNumber  uint64
	TxOrderIndex int
}

type TxValidator interface {
	Validate(tx *types.TransactionOrder, latestBlockNumber uint64) error
}

type UnicityCertificateValidator interface {
	// Validate validates the given certificates.UnicityCertificate. Returns an error if given unicity certificate
	// is not valid.
	Validate(uc *types.UnicityCertificate) error
}

type UnitAndProof interface {
	// GetUnit - access tx system unit state
	GetUnit(id types.UnitID, committed bool) (*state.Unit, error)
	// CreateUnitStateProof - create unit proofs
	CreateUnitStateProof(id types.UnitID, logIndex int) (*types.UnitStateProof, error)
}

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

	AddTransaction(ctx context.Context, tx *types.TransactionOrder) ([]byte, error)
	ForwardTransactions(ctx context.Context, receiver peer.ID)
	ProcessTransactions(ctx context.Context, txProcessor network.TxProcessor)
}