snap

package

v1.28.2 Latest Latest Go to latest Published: Jun 11, 2026 License: Apache-2.0, MIT Imports: 45 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/filecoin-project/curio

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
Variables
func DropSectorPieceRefsSnap(ctx context.Context, db *harmonydb.DB, sid abi.SectorID) error
type EncodeTask
- func NewEncodeTask(sc *ffi.SealCalls, db *harmonydb.DB, max int, bindToData bool, ...) *EncodeTask
type MoveStorageTask
- func NewMoveStorageTask(sc *ffi.SealCalls, db *harmonydb.DB, max int) *MoveStorageTask
type ProveTask
- func NewProveTask(sc *ffi.SealCalls, db *harmonydb.DB, paramck func() (bool, error), ...) *ProveTask
type SubmitTask
- func NewSubmitTask(db *harmonydb.DB, api SubmitTaskNodeAPI, bstore curiochain.CurioBlockstore, ...) *SubmitTask
type SubmitTaskNodeAPI

Constants ¶

View Source

const MinSnapSchedInterval = 10 * time.Second

Variables ¶

View Source

var ImmutableSubmitGate = abi.ChainEpoch(2) // don't submit more than 2 minutes before the deadline becomes immutable

View Source

var (
	// Tags for snap metrics
	MinerTag, _ = tag.NewKey("miner")
)

View Source

var SnapMeasures = struct {
	EncodeCompleted      *stats.Int64Measure
	ProveCompleted       *stats.Int64Measure
	SubmitCompleted      *stats.Int64Measure
	MoveStorageCompleted *stats.Int64Measure
}{
	EncodeCompleted:      stats.Int64(pre+"encode_completed_total", "Snap encodes completed.", stats.UnitDimensionless),
	ProveCompleted:       stats.Int64(pre+"prove_completed_total", "Snap proves completed.", stats.UnitDimensionless),
	SubmitCompleted:      stats.Int64(pre+"submit_completed_total", "Snap submissions completed.", stats.UnitDimensionless),
	MoveStorageCompleted: stats.Int64(pre+"movestorage_completed_total", "Snap move storage operations completed.", stats.UnitDimensionless),
}

SnapMeasures groups all snap pipeline metrics.

Functions ¶

func DropSectorPieceRefsSnap ¶ added in v1.23.1

func DropSectorPieceRefsSnap(ctx context.Context, db *harmonydb.DB, sid abi.SectorID) error

Types ¶

type EncodeTask ¶

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

func NewEncodeTask ¶

func NewEncodeTask(sc *ffi.SealCalls, db *harmonydb.DB, max int, bindToData bool, allowEncodeGPUOverprovision bool) *EncodeTask

func (*EncodeTask) Adder ¶

func (e *EncodeTask) Adder(taskFunc harmonytask.AddTaskFunc)

func (*EncodeTask) CanAccept ¶

func (e *EncodeTask) CanAccept(ids []harmonytask.TaskID, _ *harmonytask.TaskEngine) ([]harmonytask.TaskID, error)

func (*EncodeTask) Do ¶

func (e *EncodeTask) Do(taskID harmonytask.TaskID, stillOwned func() bool) (done bool, err error)

func (*EncodeTask) GetSectorID ¶ added in v1.23.1

func (e *EncodeTask) GetSectorID(db *harmonydb.DB, taskID int64) (*abi.SectorID, error)

func (*EncodeTask) GetSpid ¶

func (e *EncodeTask) GetSpid(db *harmonydb.DB, taskID int64) string

func (*EncodeTask) TypeDetails ¶

func (e *EncodeTask) TypeDetails() harmonytask.TaskTypeDetails

type MoveStorageTask ¶

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

func NewMoveStorageTask ¶

func NewMoveStorageTask(sc *ffi.SealCalls, db *harmonydb.DB, max int) *MoveStorageTask

func (*MoveStorageTask) Adder ¶

func (m *MoveStorageTask) Adder(taskFunc harmonytask.AddTaskFunc)

func (*MoveStorageTask) CanAccept ¶

func (m *MoveStorageTask) CanAccept(ids []harmonytask.TaskID, _ *harmonytask.TaskEngine) ([]harmonytask.TaskID, error)

func (*MoveStorageTask) Do ¶

func (m *MoveStorageTask) Do(taskID harmonytask.TaskID, stillOwned func() bool) (done bool, err error)

func (*MoveStorageTask) GetSectorID ¶ added in v1.23.1

func (m *MoveStorageTask) GetSectorID(db *harmonydb.DB, taskID int64) (*abi.SectorID, error)

func (*MoveStorageTask) GetSpid ¶

func (m *MoveStorageTask) GetSpid(db *harmonydb.DB, taskID int64) string

func (*MoveStorageTask) TypeDetails ¶

func (m *MoveStorageTask) TypeDetails() harmonytask.TaskTypeDetails

type ProveTask ¶

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

func NewProveTask ¶

func NewProveTask(sc *ffi.SealCalls, db *harmonydb.DB, paramck func() (bool, error), enableRemoteProofs bool, max int, cuzkClient *cuzk.Client) *ProveTask

func (*ProveTask) Adder ¶

func (p *ProveTask) Adder(taskFunc harmonytask.AddTaskFunc)

func (*ProveTask) CanAccept ¶

func (p *ProveTask) CanAccept(ids []harmonytask.TaskID, _ *harmonytask.TaskEngine) ([]harmonytask.TaskID, error)

func (*ProveTask) Do ¶

func (p *ProveTask) Do(taskID harmonytask.TaskID, stillOwned func() bool) (done bool, err error)

func (*ProveTask) GetSectorID ¶ added in v1.23.1

func (p *ProveTask) GetSectorID(db *harmonydb.DB, taskID int64) (*abi.SectorID, error)

func (*ProveTask) GetSpid ¶

func (p *ProveTask) GetSpid(db *harmonydb.DB, taskID int64) string

func (*ProveTask) TypeDetails ¶

func (p *ProveTask) TypeDetails() harmonytask.TaskTypeDetails

type SubmitTask ¶

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

func NewSubmitTask ¶

func NewSubmitTask(db *harmonydb.DB, api SubmitTaskNodeAPI, bstore curiochain.CurioBlockstore,
	sender *message.Sender, as *multictladdr.MultiAddressSelector, cfg *config.CurioConfig) *SubmitTask

func (*SubmitTask) Adder ¶

func (s *SubmitTask) Adder(taskFunc harmonytask.AddTaskFunc)

func (*SubmitTask) CanAccept ¶

func (s *SubmitTask) CanAccept(ids []harmonytask.TaskID, _ *harmonytask.TaskEngine) ([]harmonytask.TaskID, error)

func (*SubmitTask) Do ¶

func (s *SubmitTask) Do(taskID harmonytask.TaskID, stillOwned func() bool) (done bool, err error)

func (*SubmitTask) GetSectorID ¶ added in v1.23.1

func (s *SubmitTask) GetSectorID(db *harmonydb.DB, taskID int64) (*abi.SectorID, error)

func (*SubmitTask) GetSpid ¶

func (s *SubmitTask) GetSpid(db *harmonydb.DB, taskID int64) string

func (*SubmitTask) TypeDetails ¶

func (s *SubmitTask) TypeDetails() harmonytask.TaskTypeDetails

type SubmitTaskNodeAPI ¶

type SubmitTaskNodeAPI interface {
	StateSectorPartition(ctx context.Context, maddr address.Address, sectorNumber abi.SectorNumber, tsk types.TipSetKey) (*miner.SectorLocation, error)
	StateGetAllocation(ctx context.Context, clientAddr address.Address, allocationId verifregtypes9.AllocationId, tsk types.TipSetKey) (*verifregtypes9.Allocation, error)
	ChainHead(ctx context.Context) (*types.TipSet, error)

	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)
	StateSectorGetInfo(ctx context.Context, maddr address.Address, sectorNumber abi.SectorNumber, tsk types.TipSetKey) (*miner.SectorOnChainInfo, error)

	StateMinerInfo(context.Context, address.Address, types.TipSetKey) (api.MinerInfo, error)
	StateMinerAvailableBalance(context.Context, address.Address, types.TipSetKey) (big.Int, error)
	StateMinerInitialPledgeForSector(ctx context.Context, sectorDuration abi.ChainEpoch, sectorSize abi.SectorSize, verifiedSize uint64, tsk types.TipSetKey) (types.BigInt, error)
	StateGetActor(ctx context.Context, actor address.Address, tsk types.TipSetKey) (*types.Actor, error)
	StateVMCirculatingSupplyInternal(ctx context.Context, tsk types.TipSetKey) (api.CirculatingSupply, error)

	StateMinerProvingDeadline(context.Context, address.Address, types.TipSetKey) (*dline.Info, error)
}

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL