tasks

Documentation

Index

• func MakeRetrievalDeal(ctx context.Context, config NodeConfig, node api.FullNode, task RetrievalTask, ...) error
• func MakeStorageDeal(ctx context.Context, config NodeConfig, node api.FullNode, task StorageTask, ...) error
• type NodeConfig
• type RetrievalTask
• type Status
  • func (s Status) String() string
• type StorageTask
• type Task
  • func (t Task) Bytes() []byte
  • func (t *Task) Log(log *logging.ZapEventLogger)
  • func (t *Task) Sign(privKey crypto.PrivKey) error
• type TaskEvent
• type UpdateStatus

Functions

func MakeRetrievalDeal

func MakeRetrievalDeal(ctx context.Context, config NodeConfig, node api.FullNode, task RetrievalTask, log UpdateStatus) error

func MakeStorageDeal

func MakeStorageDeal(ctx context.Context, config NodeConfig, node api.FullNode, task StorageTask, log UpdateStatus) error

Types

type NodeConfig

type NodeConfig struct {
	DataDir       string
	NodeDataDir   string
	WalletAddress address.Address
}

type RetrievalTask

type RetrievalTask struct {
	Miner      string `json:"miner"`
	PayloadCID string `json:"payload_cid"`
	CARExport  bool   `json:"car_export"`
}

type Status

type Status int

const (
	Available Status = iota + 1
	InProgress
	Successful
	Failed
)

func (Status) String

func (s Status) String() string

type StorageTask

type StorageTask struct {
	Miner           string `json:"miner"`
	MaxPriceAttoFIL uint64 `json:"max_price_attofil"`
	Size            uint64 `json:"size"`
	StartOffset     uint64 `json:"start_offset"`
	FastRetrieval   bool   `json:"fast_retrieval"`
	Verified        bool   `json:"verified"`
}

type Task

type Task struct {
	UUID          string         `json:"uuid"`
	Status        Status         `json:"status"`
	WorkedBy      string         `json:"worked_by,omitempty"`  // which dealbot works on that task
	StartedAt     time.Time      `json:"started_at,omitempty"` // the time the task was assigned first assigned to the dealbot
	RetrievalTask *RetrievalTask `json:"retrieval_task,omitempty"`
	StorageTask   *StorageTask   `json:"storage_task,omitempty"`
	Signature     []byte         `json:"signature,omitempty"` // signature of Task with this field set to nil

}

func (Task) Bytes

func (t Task) Bytes() []byte

func (*Task) Log

func (t *Task) Log(log *logging.ZapEventLogger)

func (*Task) Sign

func (t *Task) Sign(privKey crypto.PrivKey) error

type TaskEvent

type TaskEvent struct {
	Status Status
	At     time.Time
}

type UpdateStatus

type UpdateStatus func(msg string, keysAndValues ...interface{})