Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
Types ¶
type CloserFunc ¶
type CloserFunc func() error
func (CloserFunc) Close ¶
func (c CloserFunc) Close() error
type ContentProviderConfig ¶ added in v0.2.10
type ContentProviderService ¶
type ContentProviderService struct {
Resolver datasource.HandlerResolver
DB *gorm.DB
// contains filtered or unexported fields
}
func NewContentProviderService ¶
func NewContentProviderService(db *gorm.DB, config ContentProviderConfig) (*ContentProviderService, error)
func (*ContentProviderService) Start ¶
func (s *ContentProviderService) Start(ctx context.Context)
func (*ContentProviderService) StartBitswap ¶
func (s *ContentProviderService) StartBitswap(ctx context.Context) 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 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 ¶
Source Files
¶
Click to show internal directories.
Click to hide internal directories.