Documentation
¶
Index ¶
- type Dealer
- type FilClient
- type Option
- func WithDealMakingFreq(f time.Duration) Option
- func WithDealMakingMaxRetries(max int) Option
- func WithDealMakingRateLim(l int) Option
- func WithDealMakingRetryDelay(delay time.Duration) Option
- func WithDealReportingFreq(f time.Duration) Option
- func WithDealReportingRetryDelay(delay time.Duration) Option
- func WithDealWatchingCheckChainRetryDelay(delay time.Duration) Option
- func WithDealWatchingFreq(f time.Duration) Option
- func WithDealWatchingRateLim(l int) Option
- func WithDealWatchingResolveDealIDRetryDelay(delay time.Duration) Option
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Dealer ¶
type Dealer struct {
// contains filtered or unexported fields
}
Dealer creates, monitors and reports deals in the Filecoin network.
func (*Dealer) ReadyToCreateDeals ¶
ReadyToCreateDeals signal the dealer that new deals are ready to be executed.
type FilClient ¶
type FilClient interface {
ExecuteAuctionDeal(
ctx context.Context,
ad store.AuctionData,
aud store.AuctionDeal,
rw *store.RemoteWallet) (string, bool, error)
GetChainHeight(ctx context.Context) (uint64, error)
ResolveDealIDFromMessage(
ctx context.Context,
publishDealMessage cid.Cid,
spID string,
pieceCid cid.Cid,
startEpoch uint64) (int64, error)
CheckChainDeal(ctx context.Context, dealID int64) (bool, uint64, bool, error)
CheckDealStatusWithStorageProvider(
ctx context.Context,
storageProviderID string,
dealIdentifier string,
rw *store.RemoteWallet) (*cid.Cid, storagemarket.StorageDealStatus, error)
}
FilClient provides functionalities to create and monitor Filecoin deals.
type Option ¶
type Option func(*config) error
Option applies a configuration change.
func WithDealMakingFreq ¶
WithDealMakingFreq configures the frequency of deal making polling.
func WithDealMakingMaxRetries ¶
WithDealMakingMaxRetries specifies the maximum amount of retries on recoverable errros during deal making execution.
func WithDealMakingRateLim ¶
WithDealMakingRateLim configures the max number of parallel execution items.
func WithDealMakingRetryDelay ¶
WithDealMakingRetryDelay specifies how much time retries are delayed for reprocessing.
func WithDealReportingFreq ¶
WithDealReportingFreq configures the frequency of deals reporting polling.
func WithDealReportingRetryDelay ¶
WithDealReportingRetryDelay specifies how much time to delay retrying reporting results to the broker.
func WithDealWatchingCheckChainRetryDelay ¶
WithDealWatchingCheckChainRetryDelay specifies how much time to delay retrying checking on-chain for a deal confirmation.
func WithDealWatchingFreq ¶
WithDealWatchingFreq configures the frequency of deal monitoring polling.
func WithDealWatchingRateLim ¶
WithDealWatchingRateLim configures the max number of parallel execution items.
func WithDealWatchingResolveDealIDRetryDelay ¶
WithDealWatchingResolveDealIDRetryDelay specifies how much time to delay retrying resolving a new deal-id.
Source Files
Directories