Class: ProposalsBatch

market/proposals_batch.ProposalsBatch

Proposals Batch aggregates initial proposals and returns a set grouped by the provider's key to avoid duplicate offers issued by the provider.

• constructor

• addProposal
• readProposals

• new ProposalsBatch(options?): ProposalsBatch

ProposalsBatch

src/market/proposals_batch.ts:27

▸ addProposal(proposal): Promise<void>

Add proposal to the batch grouped by provider key which consist of providerId, cores, threads, mem and storage

Promise<void>

src/market/proposals_batch.ts:38

▸ readProposals(): AsyncGenerator<Proposal[], any, unknown>

Generates a set of proposals that were collected within the specified releaseTimeoutMs or their size reached the minBatchSize value

AsyncGenerator<Proposal[], any, unknown>

src/market/proposals_batch.ts:54