store

Documentation

Index

• Variables
• type Store
  • func New(ds datastore.TxnDatastore) *Store
  • func (s *Store) GetFinalStorageDeals() ([]deals.StorageDealRecord, error)
  • func (s *Store) GetPendingStorageDeals() ([]deals.StorageDealRecord, error)
  • func (s *Store) GetRetrievals() ([]deals.RetrievalDealRecord, error)
  • func (s *Store) GetUpdatedRetrievalRecordsSince(since time.Time, limit int) ([]deals.RetrievalDealRecord, error)
  • func (s *Store) GetUpdatedStorageDealRecordsSince(since time.Time, limit int) ([]deals.StorageDealRecord, error)
  • func (s *Store) PutRetrieval(rr deals.RetrievalDealRecord) error
  • func (s *Store) PutStorageDeal(dr deals.StorageDealRecord) error

Variables

var (

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

Types

type Store

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

Store stores deal and retrieval records.

func New

func New(ds datastore.TxnDatastore) *Store

New returns a new *Store.

func (*Store) GetFinalStorageDeals

func (s *Store) GetFinalStorageDeals() ([]deals.StorageDealRecord, error)

GetFinalStorageDeals returns all final storage deal records.

func (*Store) GetPendingStorageDeals

func (s *Store) GetPendingStorageDeals() ([]deals.StorageDealRecord, error)

GetPendingStorageDeals returns all the pending storage deal records.

func (*Store) GetRetrievals

func (s *Store) GetRetrievals() ([]deals.RetrievalDealRecord, error)

GetRetrievals returns all retrieval deal records.

func (*Store) GetUpdatedRetrievalRecordsSince

func (s *Store) GetUpdatedRetrievalRecordsSince(since time.Time, limit int) ([]deals.RetrievalDealRecord, error)

GetUpdatedRetrievalRecordsSince returns all the retrieval records that got created or updated since sinceNano.

func (*Store) GetUpdatedStorageDealRecordsSince

func (s *Store) GetUpdatedStorageDealRecordsSince(since time.Time, limit int) ([]deals.StorageDealRecord, error)

GetUpdatedStorageDealRecordsSince returns all the storage deal records that got created or updated since sinceNano.

func (*Store) PutRetrieval

func (s *Store) PutRetrieval(rr deals.RetrievalDealRecord) error

PutRetrieval saves a retrieval deal record.

func (*Store) PutStorageDeal

func (s *Store) PutStorageDeal(dr deals.StorageDealRecord) error

PutStorageDeal saves a storage deal record.