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, sigVerifier crypto.Verifier, shardConfHash []byte) error
}

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

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

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

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

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

type Key struct {
	Algorithm  string    `json:"algorithm"`
	PrivateKey hex.Bytes `json:"privateKey"`
}

type KeyConf struct {
	SigKey  Key `json:"sigKey"`
	AuthKey Key `json:"authKey"`
}

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

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

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

type NodeOption func(c *NodeConf)

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
	RoundLogger(curRound func() uint64) *slog.Logger
	Shutdown() error
}

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

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

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

type RoundInfo struct {
	RoundNumber uint64 `json:"roundNumber"`
	EpochNumber uint64 `json:"epochNumber"`
}

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, currentRoundNumber uint64) error
}

type UnicityCertificateValidator interface {
	// Validate validates the given UC. Returns an error if UC is not valid.
	Validate(uc *types.UnicityCertificate, shardConfHash []byte) 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

	PublishBlock(ctx context.Context, block *types.Block) error
	SubscribeToBlocks(ctx context.Context) error
	UnsubscribeFromBlocks()
	RegisterValidatorProtocols() error
	UnregisterValidatorProtocols()

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