Class AuctionOrchestrator

Orchestrator side of the capability auction protocol.

Broadcasts a task auction, collects bids within the configured window, selects the winner, writes bids to the SPARQL graph, and publishes the assignment.

Example

const orchestrator = new AuctionOrchestrator(meshNode.transport, graph);
const result = await orchestrator.runAuction({
  taskId: 'task-42',
  requiredCapabilities: ['summarise'],
});
if (result) console.log('Winner:', result.winner);

Index

Constructors

constructor

Methods

runAuction selectWinner

Constructors

constructor

new AuctionOrchestrator(
    transport: MeshTransport,
    graph: MeshGraph,
    config?: AuctionConfig,
): AuctionOrchestrator
Parameters
- transport: MeshTransport
  Raw MeshTransport used for NATS pub/sub.
- graph: MeshGraph
  SPARQL graph for persisting bid records.
- Optionalconfig: AuctionConfig
  Optional auction configuration.
Returns AuctionOrchestrator
- Defined in packages/core/src/core/coordination/auction.ts:151

Methods

runAuction

runAuction(task: AuctionTask): Promise<AuctionResult | null>
Run a full auction for the given task.

Steps:
1. Subscribe to mesh.task.bid.<taskId>.response
2. Publish task details to mesh.task.bid.<taskId>
3. Collect all responses for bidWindowMs
4. Select winner deterministically
5. Publish winner to mesh.task.assign.<taskId>
6. Persist bids to graph; tombstone losers
Parameters
- task: AuctionTask
  Task to auction.
Returns Promise<AuctionResult | null>
AuctionResult with winner + all bids, or null if no bids.
- Defined in packages/core/src/core/coordination/auction.ts:174

selectWinner

selectWinner(bids: BidResponse[]): BidResponse
Select the winning bid from a non-empty array of bids.

Algorithm:
1. Sort by score DESC (highest wins)
2. Ties broken by load ASC when tiebreaker === 'lowest-load'
3. Further ties broken by array order (first-response)
Parameters
- bids: BidResponse[]
Returns BidResponse
- Defined in packages/core/src/core/coordination/auction.ts:290

Class AuctionOrchestrator

Example

Index

Constructors

Methods

Constructors

constructor

Parameters

Returns AuctionOrchestrator

Methods

runAuction

Parameters

Returns Promise<AuctionResult | null>

selectWinner

Parameters

Returns BidResponse

Settings

On This Page