Documentation
¶
Index ¶
- func GenerateNewPeer() ([]byte, []byte, peer.ID, error)
- func HealthCheck(db *gorm.DB, workerID uuid.UUID, getState func() State)
- func StartHealthCheck(ctx context.Context, db *gorm.DB, workerID uuid.UUID, getState func() State)
- func StartHealthCheckCleanup(ctx context.Context, db *gorm.DB)
- type Cid
- type CloserFunc
- type ContentProviderService
- type DatasetListenerService
- type DatasetWorker
- type DatasetWorkerThread
- type Deal
- type DealMakerService
- type DealMakerWorker
- type DealProposal
- type DealState
- type DealTracker
- type ItemInfo
- type SpadeAPI
- type State
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func StartHealthCheck ¶
Types ¶
type CloserFunc ¶
type CloserFunc func() error
func (CloserFunc) Close ¶
func (c CloserFunc) Close() error
type ContentProviderService ¶
type ContentProviderService struct {
Resolver datasource.HandlerResolver
DB *gorm.DB
// contains filtered or unexported fields
}
func (*ContentProviderService) FindPieceAsPieceReader ¶
func (s *ContentProviderService) FindPieceAsPieceReader(ctx context.Context, pieceCid cid.Cid) ( *store.PieceReader, *model.Car, error, )
func (*ContentProviderService) Start ¶
func (s *ContentProviderService) Start()
func (*ContentProviderService) StartBitswap ¶
func (s *ContentProviderService) StartBitswap() error
type DatasetListenerService ¶
type DatasetListenerService struct {
// contains filtered or unexported fields
}
func NewDatasetListenerService ¶
func NewDatasetListenerService(db *gorm.DB, stagingDir string, bind string) DatasetListenerService
func (DatasetListenerService) Start ¶
func (s DatasetListenerService) Start()
type DatasetWorker ¶
type DatasetWorker struct {
// contains filtered or unexported fields
}
func NewDatasetWorker ¶
type DatasetWorkerThread ¶
type DatasetWorkerThread struct {
// contains filtered or unexported fields
}
type Deal ¶
type Deal struct {
Proposal DealProposal
State DealState
}
type DealMakerService ¶
type DealMakerService struct {
// contains filtered or unexported fields
}
func NewDealMakerService ¶
type DealMakerWorker ¶
type DealMakerWorker struct {
// contains filtered or unexported fields
}
func NewDealMakerWorker ¶
func NewDealMakerWorker(db *gorm.DB, dealMaker *replication.DealMaker, walletChooser *replication.WalletChooser, workerID uuid.UUID) *DealMakerWorker
type DealProposal ¶
type DealTracker ¶
type DealTracker struct {
// contains filtered or unexported fields
}
func NewDealTracker ¶
func (*DealTracker) Run ¶
func (d *DealTracker) Run(ctx context.Context)
type ItemInfo ¶
type ItemInfo struct {
Type model.SourceType `json:"type"`
Path string `json:"path"`
SourceID uint32 `json:"sourceId"`
}
type SpadeAPI ¶
type SpadeAPI struct {
// contains filtered or unexported fields
}
func NewSpadeAPIService ¶
func NewSpadeAPIService(db *gorm.DB, dealMaker *replication.DealMaker, walletChooser *replication.WalletChooser, bind string) *SpadeAPI
func (SpadeAPI) GetEligiblePieces ¶
func (SpadeAPI) RequestPiece ¶
Click to show internal directories.
Click to hide internal directories.