storage_market

Documentation

Index

• type CommpTask
  • func NewCommpTask(sm *CurioStorageDealMarket, db *harmonydb.DB, sc *ffi.SealCalls, api headAPI, ...) *CommpTask
  • func (c *CommpTask) Adder(taskFunc harmonytask.AddTaskFunc)
  • func (c *CommpTask) CanAccept(ids []harmonytask.TaskID, engine *harmonytask.TaskEngine) (*harmonytask.TaskID, error)
  • func (c *CommpTask) Do(taskID harmonytask.TaskID, stillOwned func() bool) (done bool, err error)
  • func (c *CommpTask) TypeDetails() harmonytask.TaskTypeDetails
• type CurioStorageDealMarket
  • func NewCurioStorageDealMarket(miners []address.Address, db *harmonydb.DB, cfg *config.CurioConfig, ...) *CurioStorageDealMarket
  • func (d *CurioStorageDealMarket) StartMarket(ctx context.Context) error
• type FindDealTask
  • func NewFindDealTask(sm *CurioStorageDealMarket, db *harmonydb.DB, api fdealApi, ...) *FindDealTask
  • func (f *FindDealTask) Adder(taskFunc harmonytask.AddTaskFunc)
  • func (f *FindDealTask) CanAccept(ids []harmonytask.TaskID, engine *harmonytask.TaskEngine) (*harmonytask.TaskID, error)
  • func (f *FindDealTask) Do(taskID harmonytask.TaskID, stillOwned func() bool) (done bool, err error)
  • func (f *FindDealTask) TypeDetails() harmonytask.TaskTypeDetails
• type MK12Pipeline
• type MarketDirectDeal
• type MarketMK12Deal
• type PSDTask
  • func NewPSDTask(sm *CurioStorageDealMarket, db *harmonydb.DB, sender *message.Sender, ...) *PSDTask
  • func (p *PSDTask) Adder(taskFunc harmonytask.AddTaskFunc)
  • func (p *PSDTask) CanAccept(ids []harmonytask.TaskID, engine *harmonytask.TaskEngine) (*harmonytask.TaskID, error)
  • func (p *PSDTask) Do(taskID harmonytask.TaskID, stillOwned func() bool) (done bool, err error)
  • func (p *PSDTask) TypeDetails() harmonytask.TaskTypeDetails

Types

type CommpTask

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

func NewCommpTask

func NewCommpTask(sm *CurioStorageDealMarket, db *harmonydb.DB, sc *ffi.SealCalls, api headAPI, max int) *CommpTask

func (*CommpTask) Adder

func (c *CommpTask) Adder(taskFunc harmonytask.AddTaskFunc)

func (*CommpTask) CanAccept

func (c *CommpTask) CanAccept(ids []harmonytask.TaskID, engine *harmonytask.TaskEngine) (*harmonytask.TaskID, error)

func (*CommpTask) Do

func (c *CommpTask) Do(taskID harmonytask.TaskID, stillOwned func() bool) (done bool, err error)

func (*CommpTask) TypeDetails

func (c *CommpTask) TypeDetails() harmonytask.TaskTypeDetails

type CurioStorageDealMarket

type CurioStorageDealMarket struct {
	MK12Handler *mk12.MK12
	// contains filtered or unexported fields
}

func NewCurioStorageDealMarket

func NewCurioStorageDealMarket(miners []address.Address, db *harmonydb.DB, cfg *config.CurioConfig, sc *ffi.SealCalls, mapi storageMarketAPI) *CurioStorageDealMarket

func (*CurioStorageDealMarket) StartMarket

func (d *CurioStorageDealMarket) StartMarket(ctx context.Context) error

type FindDealTask

type FindDealTask struct {
	TF promise.Promise[harmonytask.AddTaskFunc]
	// contains filtered or unexported fields
}

FindDealTask represents a task for finding and identifying on chain deals once deal have been published. Once PublishStorageDeal message has been successfully executed, each proposal is assigned a deal. These deal ID must be matched to the original sent proposals so a local deal can be identified with an on chain deal ID.

func NewFindDealTask

func NewFindDealTask(sm *CurioStorageDealMarket, db *harmonydb.DB, api fdealApi, cfg *config.MK12Config) *FindDealTask

func (*FindDealTask) Adder

func (f *FindDealTask) Adder(taskFunc harmonytask.AddTaskFunc)

func (*FindDealTask) CanAccept

func (f *FindDealTask) CanAccept(ids []harmonytask.TaskID, engine *harmonytask.TaskEngine) (*harmonytask.TaskID, error)

func (*FindDealTask) Do

func (f *FindDealTask) Do(taskID harmonytask.TaskID, stillOwned func() bool) (done bool, err error)

func (*FindDealTask) TypeDetails

func (f *FindDealTask) TypeDetails() harmonytask.TaskTypeDetails

type MK12Pipeline

type MK12Pipeline struct {
	UUID string `db:"uuid"`
	SpID int64  `db:"sp_id"`

	// started after data download
	Started   bool                `db:"started"`
	PieceCid  string              `db:"piece_cid"`
	PieceSize abi.PaddedPieceSize `db:"piece_size"`
	Offline   bool                `db:"offline"` // data is not downloaded before starting the deal
	RawSize   sql.NullInt64       `db:"raw_size"`
	URL       *string             `db:"url"`
	Headers   json.RawMessage     `db:"headers"`

	//DDO
	IsDDO bool `db:"is_ddo"`

	// commP task
	CommTaskID *int64 `db:"commp_task_id"`
	AfterCommp bool   `db:"after_commp"`

	// PSD task
	PSDWaitTime *time.Time `db:"psd_wait_time"` // set in commp to now
	PSDTaskID   *int64     `db:"psd_task_id"`
	AfterPSD    bool       `db:"after_psd"`

	// Find Deal task (just looks at the chain for the deal ID)
	FindDealTaskID *int64 `db:"find_deal_task_id"`
	AfterFindDeal  bool   `db:"after_find_deal"`

	// Sector the deal was assigned into
	Sector *int64 `db:"sector"`
	Offset *int64 `db:"sector_offset"`
}

type MarketDirectDeal

type MarketDirectDeal struct {
	UUID           string    `db:"uuid"`
	SpID           int64     `db:"sp_id"`
	CreatedAt      time.Time `db:"created_at"`
	Client         string    `db:"client"`
	Offline        bool      `db:"offline"`
	Verified       bool      `db:"verified"`
	StartEpoch     int64     `db:"start_epoch"`
	EndEpoch       int64     `db:"end_epoch"`
	AllocationID   int64     `db:"allocation_id"`
	PieceCid       string    `db:"piece_cid"`
	PieceSize      int64     `db:"piece_size"`
	FastRetrieval  bool      `db:"fast_retrieval"`
	AnnounceToIpni bool      `db:"announce_to_ipni"`
}

type MarketMK12Deal

type MarketMK12Deal struct {
	UUID              string    `db:"uuid"`
	CreatedAt         time.Time `db:"created_at"`
	SignedProposalCid string    `db:"signed_proposal_cid"`
	ProposalSignature []byte    `db:"proposal_signature"`
	Proposal          []byte    `db:"proposal"`
	PieceCid          string    `db:"piece_cid"`
	PieceSize         int64     `db:"piece_size"`
	Offline           bool      `db:"offline"`
	Verified          bool      `db:"verified"`
	SpID              int64     `db:"sp_id"`
	StartEpoch        int64     `db:"start_epoch"`
	EndEpoch          int64     `db:"end_epoch"`
	ClientPeerID      string    `db:"client_peer_id"`
	ChainDealID       int64     `db:"chain_deal_id"`
	PublishCid        string    `db:"publish_cid"`
	FastRetrieval     bool      `db:"fast_retrieval"`
	AnnounceToIpni    bool      `db:"announce_to_ipni"`
	Error             *string   `db:"error"`
	Label             []byte    `db:"label"`
}

type PSDTask

type PSDTask struct {
	TF promise.Promise[harmonytask.AddTaskFunc]
	// contains filtered or unexported fields
}

func NewPSDTask

func NewPSDTask(sm *CurioStorageDealMarket, db *harmonydb.DB, sender *message.Sender, as *multictladdr.MultiAddressSelector, cfg *config.MK12Config, api psdApi) *PSDTask

func (*PSDTask) Adder

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

func (*PSDTask) CanAccept

func (p *PSDTask) CanAccept(ids []harmonytask.TaskID, engine *harmonytask.TaskEngine) (*harmonytask.TaskID, error)

func (*PSDTask) Do

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

func (*PSDTask) TypeDetails

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