astore

Documentation

Index

• Variables
• type RetrievalAction
• type StorageAction
• type Store
  • func New(ds datastore.Datastore) *Store
  • func (s *Store) GetRetrievalAction(jid ffs.JobID) (RetrievalAction, error)
  • func (s *Store) GetStorageAction(jid ffs.JobID) (StorageAction, error)
  • func (s *Store) PutRetrievalAction(jid ffs.JobID, a RetrievalAction) error
  • func (s *Store) PutStorageAction(jid ffs.JobID, a StorageAction) error

Variables

var (
	// ErrNotFound indicates the instance doesn't exist.
	ErrNotFound = errors.New("action not found")
)

Types

type RetrievalAction

type RetrievalAction struct {
	APIID         ffs.APIID
	RetrievalID   ffs.RetrievalID
	PayloadCid    cid.Cid
	PieceCid      cid.Cid
	Selector      string
	Miners        []string
	WalletAddress string
	MaxPrice      uint64
}

RetrievalAction contains information necessary to execute a RetrievalJob.

type StorageAction

type StorageAction struct {
	APIID       ffs.APIID
	Cid         cid.Cid
	Cfg         ffs.StorageConfig
	ReplacedCid cid.Cid
}

StorageAction contains information necessary to execute a StorageJob.

type Store

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

Store persists Actions.

func New

func New(ds datastore.Datastore) *Store

New returns a new ActionStore backed by the Datastore.

func (*Store) GetRetrievalAction

func (s *Store) GetRetrievalAction(jid ffs.JobID) (RetrievalAction, error)

GetRetrievalAction returns a the RetrievalAction corresponding to the RetrievalJob id.

func (*Store) GetStorageAction

func (s *Store) GetStorageAction(jid ffs.JobID) (StorageAction, error)

GetStorageAction gets an action for a JobID. If doesn't exist, returns ErrNotFound.

func (*Store) PutRetrievalAction

func (s *Store) PutRetrievalAction(jid ffs.JobID, a RetrievalAction) error

PutRetrievalAction saves the RetrievalAction corresponding to a RetrievalJob.

func (*Store) PutStorageAction

func (s *Store) PutStorageAction(jid ffs.JobID, a StorageAction) error

PutStorageAction saves a new Action for a Job.