pdp

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

type DataSetCreate struct {
	CreateMessageHash string `db:"tx_hash"`
	ID                string `db:"id"`
	Client            string `db:"client"`
}

type DataSetDelete struct {
	DeleteMessageHash string `db:"tx_hash"`
	ID                string `db:"id"`
	PID               int64  `db:"set_id"`
}

type DataSetPieceAdd struct {
	ID              string `db:"id"`
	Client          string `db:"client"`
	PieceCID2       string `db:"piece_cid_v2"` // pieceCIDV2
	DataSet         uint64 `db:"data_set_id"`
	PieceRef        int64  `db:"piece_ref"`
	AddMessageHash  string `db:"add_message_hash"`
	AddMessageIndex int64  `db:"add_message_index"`
}

type DataSetPieceDelete struct {
	ID      string  `db:"id"`
	DataSet uint64  `db:"set_id"`
	Pieces  []int64 `db:"pieces"`
	Hash    string  `db:"tx_hash"`
}

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

type InitProvingPeriodTaskChainApi interface {
	ChainHead(context.Context) (*chainTypes.TipSet, error)
}

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

type NextProvingPeriodTaskChainApi interface {
	ChainHead(context.Context) (*chainTypes.TipSet, error)
}

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

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

type PDPServiceNodeApi interface {
	ChainHead(ctx context.Context) (*types2.TipSet, error)
}

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

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

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

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

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

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

type ProveTaskChainApi interface {
	StateGetRandomnessDigestFromBeacon(ctx context.Context, randEpoch abi.ChainEpoch, tsk chainTypes.TipSetKey) (abi.Randomness, error) //perm:read
	ChainHead(context.Context) (*chainTypes.TipSet, error)                                                                              //perm:read
}

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