.connect()
→ Promise<void>
await workerShardingStrategy.connect();Class
WorkerShardingStrategy
Runs gateway shards in worker_threads. Workers own sockets/heartbeats/JSON.parse; dispatches are posted back to the main thread. Note: the client cache still lives on the main thread — this does not solve the memory wall. Use process-level sharding (@fluxerjs/sharding) for that.
Constructor
new WorkerShardingStrategy(manager: WebSocketManager, options: WorkerShardingStrategyOptions)- manager
WebSocketManager
Methods
.destroy(options?)
options?: { code?: number; } → Promise<void>
await workerShardingStrategy.destroy();.fetchStatus()
→ Promise<Map<number, ShardStatus>>
await workerShardingStrategy.fetchStatus();.getPing()
→ number
workerShardingStrategy.getPing();.send(shardId, payload)
shardId: number, payload: GatewaySendPayload → Promise<void>
await workerShardingStrategy.send(shardId, payload);.spawn(shardIds)
shardIds: number[] → Promise<void>
await workerShardingStrategy.spawn(shardIds);