sjstore

Dec 8, 2020

Changes in this version

type Store

+ func (s *Store) CancelQueued(jid ffs.JobID) (bool, error)

Nov 4, 2020

Changes in this version

type Store

+ func (s *Store) ExecutingJobs(iid ffs.APIID, cids ...cid.Cid) []ffs.StorageJob

+ func (s *Store) GetExecutingJobIDs() []ffs.JobID

+ func (s *Store) LatestFinalJobs(iid ffs.APIID, cids ...cid.Cid) []ffs.StorageJob

+ func (s *Store) LatestSuccessfulJobs(iid ffs.APIID, cids ...cid.Cid) []ffs.StorageJob

+ func (s *Store) MonitorJob(j ffs.StorageJob) chan deals.StorageDealInfo

+ func (s *Store) QueuedJobs(iid ffs.APIID, cids ...cid.Cid) []ffs.StorageJob

Oct 2, 2020

Changes in this version

+ type Stats struct

+ TotalExecuting int

+ TotalQueued int

type Store

+ func (s *Store) GetExecutingJob(c cid.Cid) *ffs.JobID

+ func (s *Store) GetStats() Stats

Sep 21, 2020

Changes in this version

+ var ErrNotFound = errors.New("job not found")

+ type StartedDeals struct

+ Cid cid.Cid

+ ProposalCids []cid.Cid

+ type Store struct

+ func New(ds datastore.Datastore) (*Store, error)

+ func (s *Store) AddStartedDeals(c cid.Cid, proposals []cid.Cid) error

+ func (s *Store) Close() error

+ func (s *Store) Dequeue() (*ffs.StorageJob, error)

+ func (s *Store) Enqueue(j ffs.StorageJob) error

+ func (s *Store) Finalize(jid ffs.JobID, st ffs.JobStatus, jobError error, dealErrors []ffs.DealError) error

+ func (s *Store) Get(jid ffs.JobID) (ffs.StorageJob, error)

+ func (s *Store) GetExecutingJobs() []ffs.JobID

+ func (s *Store) GetStartedDeals(c cid.Cid) ([]cid.Cid, error)

+ func (s *Store) RemoveStartedDeals(c cid.Cid) error

+ func (s *Store) Watch(ctx context.Context, c chan<- ffs.StorageJob, iid ffs.APIID) error