sealing

type AddressSelector interface {
	AddressFor(ctx context.Context, a ctladdr.NodeApi, mi api.MinerInfo, use api.AddrUse, goodFunds, minFunds abi.TokenAmount) (address.Address, abi.TokenAmount, error)
}

type AggregateInput struct {
	Spt   abi.RegisteredSealProof
	Info  proof.AggregateSealVerifyInfo
	Proof []byte
}

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

type Chain interface {
	ChainHead(context.Context) (*types.TipSet, error)
	StateNetworkVersion(ctx context.Context, tsk types.TipSetKey) (network.Version, error)
}

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

type CommitBatcherApi interface {
	MpoolPushMessage(context.Context, *types.Message, *api.MessageSendSpec) (*types.SignedMessage, error)
	StateMinerInfo(context.Context, address.Address, types.TipSetKey) (api.MinerInfo, error)
	ChainHead(ctx context.Context) (*types.TipSet, error)

	StateSectorPreCommitInfo(ctx context.Context, maddr address.Address, sectorNumber abi.SectorNumber, tsk types.TipSetKey) (*miner.SectorPreCommitOnChainInfo, error)
	StateMinerInitialPledgeCollateral(context.Context, address.Address, miner.SectorPreCommitInfo, types.TipSetKey) (big.Int, error)
	StateNetworkVersion(ctx context.Context, tsk types.TipSetKey) (network.Version, error)
	StateMinerAvailableBalance(context.Context, address.Address, types.TipSetKey) (big.Int, error)

	// Address selector
	WalletBalance(context.Context, address.Address) (types.BigInt, error)
	WalletHas(context.Context, address.Address) (bool, error)
	StateAccountKey(context.Context, address.Address, types.TipSetKey) (address.Address, error)
	StateLookupID(context.Context, address.Address, types.TipSetKey) (address.Address, error)
}

type Context interface {
	Context() context.Context
	Send(evt interface{}) error
}

type CurrentDealInfo struct {
	DealID           abi.DealID
	MarketDeal       *api.MarketDeal
	PublishMsgTipSet types.TipSetKey
}

type CurrentDealInfoAPI interface {
	ChainGetMessage(context.Context, cid.Cid) (*types.Message, error)
	StateLookupID(context.Context, address.Address, types.TipSetKey) (address.Address, error)
	StateMarketStorageDeal(context.Context, abi.DealID, types.TipSetKey) (*api.MarketDeal, error)
	StateSearchMsg(ctx context.Context, from types.TipSetKey, msg cid.Cid, limit abi.ChainEpoch, allowReplaced bool) (*api.MsgLookup, error)
	StateNetworkVersion(ctx context.Context, tsk types.TipSetKey) (network.Version, error)
}

type CurrentDealInfoManager struct {
	CDAPI CurrentDealInfoAPI
}

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

type Events interface {
	ChainAt(ctx context.Context, hnd events.HeightHandler, rev events.RevertHandler, confidence int, h abi.ChainEpoch) error
}

type Ignorable interface {
	Ignore()
}

type Log struct {
	Timestamp uint64
	Trace     string // for errors

	Message string

	// additional data (Event info)
	Kind string
}

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

type PreCommitBatcherApi interface {
	MpoolPushMessage(context.Context, *types.Message, *api.MessageSendSpec) (*types.SignedMessage, error)
	StateMinerInfo(context.Context, address.Address, types.TipSetKey) (api.MinerInfo, error)
	StateMinerAvailableBalance(context.Context, address.Address, types.TipSetKey) (big.Int, error)
	ChainHead(ctx context.Context) (*types.TipSet, error)
	StateNetworkVersion(ctx context.Context, tsk types.TipSetKey) (network.Version, error)
	StateGetAllocationForPendingDeal(ctx context.Context, dealId abi.DealID, tsk types.TipSetKey) (*verifregtypes.Allocation, error)

	// Address selector
	WalletBalance(context.Context, address.Address) (types.BigInt, error)
	WalletHas(context.Context, address.Address) (bool, error)
	StateAccountKey(context.Context, address.Address, types.TipSetKey) (address.Address, error)
	StateLookupID(context.Context, address.Address, types.TipSetKey) (address.Address, error)
}

type PreCommitPolicy interface {
	Expiration(ctx context.Context, ps ...api.SectorPiece) (abi.ChainEpoch, error)
}

type ReturnState string

type Sealing struct {
	Api      SealingAPI
	DealInfo *CurrentDealInfoManager
	// contains filtered or unexported fields
}

type SealingAPI interface {
	StateWaitMsg(ctx context.Context, cid cid.Cid, confidence uint64, limit abi.ChainEpoch, allowReplaced bool) (*api.MsgLookup, error)
	StateSearchMsg(ctx context.Context, from types.TipSetKey, msg cid.Cid, limit abi.ChainEpoch, allowReplaced bool) (*api.MsgLookup, error)

	StateSectorPreCommitInfo(ctx context.Context, maddr address.Address, sectorNumber abi.SectorNumber, tsk types.TipSetKey) (*miner.SectorPreCommitOnChainInfo, error)
	StateComputeDataCID(ctx context.Context, maddr address.Address, sectorType abi.RegisteredSealProof, deals []abi.DealID, tsk types.TipSetKey) (cid.Cid, error)
	StateSectorGetInfo(ctx context.Context, maddr address.Address, sectorNumber abi.SectorNumber, tsk types.TipSetKey) (*miner.SectorOnChainInfo, error)
	StateSectorPartition(ctx context.Context, maddr address.Address, sectorNumber abi.SectorNumber, tsk types.TipSetKey) (*lminer.SectorLocation, error)
	StateLookupID(context.Context, address.Address, types.TipSetKey) (address.Address, error)
	StateMinerPreCommitDepositForPower(context.Context, address.Address, miner.SectorPreCommitInfo, types.TipSetKey) (big.Int, error)
	StateMinerInitialPledgeCollateral(context.Context, address.Address, miner.SectorPreCommitInfo, types.TipSetKey) (big.Int, error)
	StateMinerInfo(context.Context, address.Address, types.TipSetKey) (api.MinerInfo, error)
	StateMinerAvailableBalance(context.Context, address.Address, types.TipSetKey) (big.Int, error)
	StateMinerSectorAllocated(context.Context, address.Address, abi.SectorNumber, types.TipSetKey) (bool, error)
	StateMarketStorageDeal(context.Context, abi.DealID, types.TipSetKey) (*api.MarketDeal, error)
	StateNetworkVersion(ctx context.Context, tsk types.TipSetKey) (network.Version, error)
	StateMinerProvingDeadline(context.Context, address.Address, types.TipSetKey) (*dline.Info, error)
	StateMinerDeadlines(context.Context, address.Address, types.TipSetKey) ([]api.Deadline, error)
	StateMinerPartitions(ctx context.Context, m address.Address, dlIdx uint64, tsk types.TipSetKey) ([]api.Partition, error)
	MpoolPushMessage(context.Context, *types.Message, *api.MessageSendSpec) (*types.SignedMessage, error)
	ChainHead(ctx context.Context) (*types.TipSet, error)
	ChainGetMessage(ctx context.Context, mc cid.Cid) (*types.Message, error)
	StateGetRandomnessFromBeacon(ctx context.Context, personalization crypto.DomainSeparationTag, randEpoch abi.ChainEpoch, entropy []byte, tsk types.TipSetKey) (abi.Randomness, error)
	StateGetRandomnessFromTickets(ctx context.Context, personalization crypto.DomainSeparationTag, randEpoch abi.ChainEpoch, entropy []byte, tsk types.TipSetKey) (abi.Randomness, error)
	ChainReadObj(context.Context, cid.Cid) ([]byte, error)
	StateMinerAllocated(context.Context, address.Address, types.TipSetKey) (*bitfield.BitField, error)
	StateGetAllocationForPendingDeal(ctx context.Context, dealId abi.DealID, tsk types.TipSetKey) (*verifregtypes.Allocation, error)

	// Address selector
	WalletBalance(context.Context, address.Address) (types.BigInt, error)
	WalletHas(context.Context, address.Address) (bool, error)
	StateAccountKey(context.Context, address.Address, types.TipSetKey) (address.Address, error)
}

type SealingStateEvt struct {
	SectorNumber abi.SectorNumber
	SectorType   abi.RegisteredSealProof
	From         SectorState
	After        SectorState
	Error        string
}

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

type SectorAddPiece struct{}

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

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

type SectorCommitAggregateSent struct {
	Message cid.Cid
}

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

type SectorCommitSubmitted struct {
	Message cid.Cid
}

type SectorCommitted struct {
	Proof []byte
}

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

type SectorDeadlineImmutable struct{}

type SectorDeadlineMutable struct{}

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

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

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

type SectorFaultedFinal struct{}

type SectorFaulty struct{}

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

type SectorFinalized struct{}

type SectorFinalizedAvailable struct{}

type SectorForceState struct {
	State SectorState
}

type SectorInfo struct {
	State        SectorState
	SectorNumber abi.SectorNumber

	SectorType abi.RegisteredSealProof

	// Packing
	CreationTime int64 // unix seconds
	Pieces       []api.SectorPiece

	// PreCommit1
	TicketValue   abi.SealRandomness
	TicketEpoch   abi.ChainEpoch
	PreCommit1Out storiface.PreCommit1Out

	// PreCommit2
	CommD *cid.Cid
	CommR *cid.Cid // SectorKey
	Proof []byte

	PreCommitDeposit big.Int
	PreCommitMessage *cid.Cid
	PreCommitTipSet  types.TipSetKey

	PreCommit2Fails uint64

	// WaitSeed
	SeedValue abi.InteractiveSealRandomness
	SeedEpoch abi.ChainEpoch

	// Committing
	CommitMessage *cid.Cid
	InvalidProofs uint64 // failed proof computations (doesn't validate with proof inputs; can't compute)

	// CCUpdate
	CCUpdate             bool
	CCPieces             []api.SectorPiece
	UpdateSealed         *cid.Cid
	UpdateUnsealed       *cid.Cid
	ReplicaUpdateProof   storiface.ReplicaUpdateProof
	ReplicaUpdateMessage *cid.Cid

	// Faults
	FaultReportMsg *cid.Cid

	// Recovery / Import
	Return ReturnState

	// Termination
	TerminateMessage *cid.Cid
	TerminatedAt     abi.ChainEpoch

	// Remote import
	RemoteDataUnsealed        *storiface.SectorLocation
	RemoteDataSealed          *storiface.SectorLocation
	RemoteDataCache           *storiface.SectorLocation
	RemoteCommit1Endpoint     string
	RemoteCommit2Endpoint     string
	RemoteSealingDoneEndpoint string
	RemoteDataFinalized       bool

	// Debug
	LastErr string

	Log []Log
}

type SectorInvalidDealIDs struct {
	Return ReturnState
}

type SectorKeyReleased struct{}

type SectorMarkForUpdate struct{}

type SectorOldTicket struct{}

type SectorPacked struct{ FillerPieces []abi.PieceInfo }

type SectorPieceAdded struct {
	NewPieces []api.SectorPiece
}

type SectorPreCommit1 struct {
	PreCommit1Out storiface.PreCommit1Out
}

type SectorPreCommit2 struct {
	Sealed   cid.Cid
	Unsealed cid.Cid
}

type SectorPreCommitBatch struct{}

type SectorPreCommitBatchSent struct {
	Message cid.Cid
}

type SectorPreCommitLanded struct {
	TipSet types.TipSetKey
}

type SectorPreCommitted struct {
	Message          cid.Cid
	PreCommitDeposit big.Int
	PreCommitInfo    miner.SectorPreCommitInfo
}

type SectorProofReady struct {
	Proof []byte
}

type SectorProveReplicaUpdate struct {
	Proof storiface.ReplicaUpdateProof
}

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

type SectorProving struct{}

type SectorReceive struct {
	State SectorInfo
}

type SectorReceived struct{}

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

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

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

type SectorRemove struct{}

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

type SectorRemoved struct{}

type SectorReplicaUpdate struct {
	Out storiface.ReplicaUpdateOut
}

type SectorReplicaUpdateLanded struct{}

type SectorReplicaUpdateSubmitted struct {
	Message cid.Cid
}

type SectorRestart struct{}

type SectorRetryCommitWait struct{}

type SectorRetryComputeProof struct{}

type SectorRetryFinalize struct{}

type SectorRetryInvalidProof struct{}

type SectorRetryPreCommit struct{}

type SectorRetryPreCommitWait struct{}

type SectorRetryProveReplicaUpdate struct{}

type SectorRetryReplicaUpdate struct{}

type SectorRetrySealPreCommit1 struct{}

type SectorRetrySealPreCommit2 struct{}

type SectorRetrySubmitCommit struct{}

type SectorRetrySubmitReplicaUpdate struct{}

type SectorRetrySubmitReplicaUpdateWait struct{}

type SectorRetryWaitDeals struct{}

type SectorRetryWaitSeed struct{}

type SectorRevertUpgradeToProving struct{}

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

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

type SectorSeedReady struct {
	SeedValue abi.InteractiveSealRandomness
	SeedEpoch abi.ChainEpoch
}

type SectorStart struct {
	ID         abi.SectorNumber
	SectorType abi.RegisteredSealProof
}

type SectorStartCC struct {
	ID         abi.SectorNumber
	SectorType abi.RegisteredSealProof
}

type SectorStartCCUpdate struct{}

type SectorStartPacking struct{}

type SectorState string

type SectorStateNotifee func(before, after SectorInfo)

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

type SectorSubmitCommitAggregate struct{}

type SectorSubmitReplicaUpdateFailed struct{}

type SectorTerminate struct{}

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

type SectorTerminated struct{ TerminatedAt abi.ChainEpoch }

type SectorTerminating struct{ Message *cid.Cid }

type SectorTicket struct {
	TicketValue abi.SealRandomness
	TicketEpoch abi.ChainEpoch
}

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

type SectorUpdateActive struct{}

type SectorUpdateDealIDs struct {
	Updates map[int]abi.DealID
}

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

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

type TerminateBatcherApi interface {
	StateSectorPartition(ctx context.Context, maddr address.Address, sectorNumber abi.SectorNumber, tsk types.TipSetKey) (*lminer.SectorLocation, error)
	MpoolPushMessage(context.Context, *types.Message, *api.MessageSendSpec) (*types.SignedMessage, error)
	StateMinerInfo(context.Context, address.Address, types.TipSetKey) (api.MinerInfo, error)
	StateMinerProvingDeadline(context.Context, address.Address, types.TipSetKey) (*dline.Info, error)
	StateMinerPartitions(ctx context.Context, m address.Address, dlIdx uint64, tsk types.TipSetKey) ([]api.Partition, error)

	// Address selector
	WalletBalance(context.Context, address.Address) (types.BigInt, error)
	WalletHas(context.Context, address.Address) (bool, error)
	StateAccountKey(context.Context, address.Address, types.TipSetKey) (address.Address, error)
	StateLookupID(context.Context, address.Address, types.TipSetKey) (address.Address, error)
}