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
- type StorageTask
- type Task
- type TaskEvent
- type UpdateStatus
Constants ¶
This section is empty.
Variables ¶
This section is empty.
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 RetrievalTask ¶
type StorageTask ¶
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) Log ¶
func (t *Task) Log(log *logging.ZapEventLogger)
type UpdateStatus ¶
type UpdateStatus func(msg string, keysAndValues ...interface{})
Click to show internal directories.
Click to hide internal directories.