@terascope/teraslice-messaging / execution-controller/server / Server

Class: Server

Defined in: execution-controller/server.ts:9

Extends

• Server

Constructors

Constructor

new Server(opts): Server

Defined in: execution-controller/server.ts:14

Parameters

Parameter	Type
opts	ServerOptions

Returns

Server

Overrides

Server.constructor

Properties

Property	Modifier	Type	Default value	Inherited from	Defined in
_clients	protected	ConnectedClients	undefined	Server._clients	messenger/server.ts:31
actionTimeout	protected	number	undefined	Server.actionTimeout	messenger/core.ts:16
closed	public	boolean	false	Server.closed	messenger/core.ts:13
executionReady	public	boolean	undefined	-	execution-controller/server.ts:12
httpServer	readonly	Server	undefined	Server.httpServer	messenger/server.ts:28
isShuttingDown	public	boolean	undefined	Server.isShuttingDown	messenger/server.ts:25
logger	protected	Logger	undefined	Server.logger	messenger/core.ts:17
networkLatencyBuffer	protected	number	undefined	Server.networkLatencyBuffer	messenger/core.ts:15
port	readonly	number	undefined	Server.port	messenger/server.ts:26
queue	public	Queue<EnqueuedWorker>	undefined	-	execution-controller/server.ts:11
server	readonly	Server<ClientToServerEvents, ServerToClientEvents>	undefined	Server.server	messenger/server.ts:27
serverName	readonly	string	undefined	Server.serverName	messenger/server.ts:29

Accessors

activeWorkerCount

Get Signature

get activeWorkerCount(): number

Defined in: execution-controller/server.ts:149

Returns

number

---

availableClientCount

Get Signature

get availableClientCount(): number

Defined in: messenger/server.ts:212

Returns

number

Inherited from

Server.availableClientCount

---

availableClients

Get Signature

get availableClients(): ConnectedClient[]

Defined in: messenger/server.ts:208

Returns

ConnectedClient[]

Inherited from

Server.availableClients

---

disconnectedClientCount

Get Signature

get disconnectedClientCount(): number

Defined in: messenger/server.ts:204

Returns

number

Inherited from

Server.disconnectedClientCount

---

disconnectedClients

Get Signature

get disconnectedClients(): ConnectedClient[]

Defined in: messenger/server.ts:200

Returns

ConnectedClient[]

Inherited from

Server.disconnectedClients

---

onlineClientCount

Get Signature

get onlineClientCount(): number

Defined in: messenger/server.ts:196

Returns

number

Inherited from

Server.onlineClientCount

---

onlineClients

Get Signature

get onlineClients(): ConnectedClient[]

Defined in: messenger/server.ts:192

Returns

ConnectedClient[]

Inherited from

Server.onlineClients

---

unavailableClientCount

Get Signature

get unavailableClientCount(): number

Defined in: messenger/server.ts:220

Returns

number

Inherited from

Server.unavailableClientCount

---

unavailableClients

Get Signature

get unavailableClients(): ConnectedClient[]

Defined in: messenger/server.ts:216

Returns

ConnectedClient[]

Inherited from

Server.unavailableClients

---

workerQueueSize

Get Signature

get workerQueueSize(): number

Defined in: execution-controller/server.ts:153

Returns

number

Methods

close()

close(): void

Defined in: messenger/core.ts:39

Returns

void

Inherited from

Server.close

---

dequeueWorker()

dequeueWorker(slice): string | null

Defined in: execution-controller/server.ts:69

Parameters

Parameter	Type
slice	Slice

Returns

string | null

---

dispatchSlice()

dispatchSlice(slice, workerId): Promise<boolean>

Defined in: execution-controller/server.ts:74

Parameters

Parameter	Type
slice	Slice
workerId	string

Returns

Promise<boolean>

---

emit()

emit(eventName, msg): void

Defined in: messenger/core.ts:161

Synchronously calls each of the listeners registered for the event named eventName, in the order they were registered, passing the supplied arguments to each.

Returns true if the event had listeners, false otherwise.

import { EventEmitter } from 'node:events';
const myEmitter = new EventEmitter();

// First listener
myEmitter.on('event', function firstListener() {
  console.log('Helloooo! first listener');
});
// Second listener
myEmitter.on('event', function secondListener(arg1, arg2) {
  console.log(`event with parameters ${arg1}, ${arg2} in second listener`);
});
// Third listener
myEmitter.on('event', function thirdListener(...args) {
  const parameters = args.join(', ');
  console.log(`event with parameters ${parameters} in third listener`);
});

console.log(myEmitter.listeners('event'));

myEmitter.emit('event', 1, 2, 3, 4, 5);

// Prints:
// [
//   [Function: firstListener],
//   [Function: secondListener],
//   [Function: thirdListener]
// ]
// Helloooo! first listener
// event with parameters 1, 2 in second listener
// event with parameters 1, 2, 3, 4, 5 in third listener

Parameters

Parameter	Type
eventName	string
msg	EventMessage

Returns

void

Since

v0.1.26

Inherited from

Server.emit

---

ensureClient()

protected ensureClient(socket): ConnectedClient

Defined in: messenger/server.ts:385

Parameters

Parameter	Type
socket	Socket<ClientToServerEvents, ServerToClientEvents>

Returns

ConnectedClient

Inherited from

Server.ensureClient

---

getClientMetadataFromSocket()

protected getClientMetadataFromSocket(socket): ClientSocketMetadata

Defined in: messenger/server.ts:329

Parameters

Parameter	Type
socket	Socket<ClientToServerEvents, ServerToClientEvents>

Returns

ClientSocketMetadata

Inherited from

Server.getClientMetadataFromSocket

---

getTimeout()

getTimeout(timeout?): number

Defined in: messenger/core.ts:156

Parameters

Parameter	Type
timeout?	number

Returns

number

Inherited from

Server.getTimeout

---

getTimeoutWithMax()

getTimeoutWithMax(maxTimeout): number

Defined in: messenger/core.ts:151

Parameters

Parameter	Type
maxTimeout	number

Returns

number

Inherited from

Server.getTimeoutWithMax

---

handleResponse()

protected handleResponse(socket, eventName, fn): void

Defined in: messenger/core.ts:93

Parameters

Parameter	Type
socket	SocketEmitter
eventName	string
fn	MessageHandler

Returns

void

Inherited from

Server.handleResponse

---

handleSendResponse()

protected handleSendResponse(sent, sendAbortSignal?): Promise<Message | null>

Defined in: messenger/core.ts:44

Parameters

Parameter	Type	Default value
sent	Message	undefined
sendAbortSignal	boolean	false

Returns

Promise<Message | null>

Inherited from

Server.handleSendResponse

---

isClientConnected()

isClientConnected(clientId): boolean

Defined in: messenger/server.ts:323

Parameters

Parameter	Type
clientId	string

Returns

boolean

Inherited from

Server.isClientConnected

---

isClientReady()

isClientReady(clientId): boolean

Defined in: messenger/server.ts:266

Parameters

Parameter	Type
clientId	string

Returns

boolean

Inherited from

Server.isClientReady

---

listen()

listen(): Promise<void>

Defined in: messenger/server.ts:90

Returns

Promise<void>

Inherited from

Server.listen

---

onceWithTimeout()

onceWithTimeout(eventName, timeout?, abortSignal?): Promise<any>

Defined in: messenger/core.ts:168

Parameters

Parameter	Type
eventName	string
timeout?	number
abortSignal?	AbortSignal

Returns

Promise<any>

Inherited from

Server.onceWithTimeout

---

onClientAvailable()

onClientAvailable(fn): this

Defined in: messenger/server.ts:230

Parameters

Parameter	Type
fn	(clientId) => void

Returns

this

Inherited from

Server.onClientAvailable

---

onClientDisconnect()

onClientDisconnect(fn): this

Defined in: messenger/server.ts:242

Parameters

Parameter	Type
fn	(clientId) => void

Returns

this

Inherited from

Server.onClientDisconnect

---

onClientError()

onClientError(fn): this

Defined in: messenger/server.ts:260

Parameters

Parameter	Type
fn	(clientId) => void

Returns

this

Inherited from

Server.onClientError

---

onClientOnline()

onClientOnline(fn): this

Defined in: messenger/server.ts:224

Parameters

Parameter	Type
fn	(clientId) => void

Returns

this

Inherited from

Server.onClientOnline

---

onClientReconnect()

onClientReconnect(fn): this

Defined in: messenger/server.ts:254

Parameters

Parameter	Type
fn	(clientId) => void

Returns

this

Inherited from

Server.onClientReconnect

---

onClientShutdown()

onClientShutdown(fn): this

Defined in: messenger/server.ts:248

Parameters

Parameter	Type
fn	(clientId) => void

Returns

this

Inherited from

Server.onClientShutdown

---

onClientUnavailable()

onClientUnavailable(fn): this

Defined in: messenger/server.ts:236

Parameters

Parameter	Type
fn	(clientId) => void

Returns

this

Inherited from

Server.onClientUnavailable

---

onSliceFailure()

onSliceFailure(fn): void

Defined in: execution-controller/server.ts:132

Parameters

Parameter	Type
fn	(workerId, payload) => void

Returns

void

---

onSliceSuccess()

onSliceSuccess(fn): void

Defined in: execution-controller/server.ts:126

Parameters

Parameter	Type
fn	(workerId, payload) => void

Returns

void

---

onWorkerEnqueue()

onWorkerEnqueue(fn): void

Defined in: execution-controller/server.ts:120

Called synchronously when a worker is enqueued (or re-announces that it is available), before the worker can be dequeued and dispatched a slice.

Parameters

Parameter	Type
fn	(workerId) => void

Returns

void

---

send()

protected send(clientId, eventName, payload?, options?): Promise<Message | null>

Defined in: messenger/server.ts:282

Parameters

Parameter	Type
clientId	string
eventName	string
payload	Payload
options	SendOptions

Returns

Promise<Message | null>

Inherited from

Server.send

---

sendExecutionFinishedToAll()

sendExecutionFinishedToAll(exId): Promise<(Message | null)[]>

Defined in: execution-controller/server.ts:138

Parameters

Parameter	Type
exId	string

Returns

Promise<(Message | null)[]>

---

sendSliceTapRequest()

sendSliceTapRequest(workerId, payload, timeout): Promise<Message | null>

Defined in: execution-controller/server.ts:108

Parameters

Parameter	Type
workerId	string
payload	{ size: number; tapTimeout: number; }
payload.size	number
payload.tapTimeout	number
timeout	number

Returns

Promise<Message | null>

---

sendToAll()

protected sendToAll(eventName, payload?, options?): Promise<(Message | null)[]>

Defined in: messenger/server.ts:271

Parameters

Parameter	Type
eventName	string
payload?	Payload
options?	SendOptions

Returns

Promise<(Message | null)[]>

Inherited from

Server.sendToAll

---

shutdown()

shutdown(): Promise<void>

Defined in: execution-controller/server.ts:59

Returns

Promise<void>

Overrides

Server.shutdown

---

start()

start(): Promise<void>

Defined in: execution-controller/server.ts:34

Returns

Promise<void>

---

updateClientState()

protected updateClientState(clientId, state): boolean

Defined in: messenger/server.ts:352

Parameters

Parameter	Type
clientId	string
state	ClientState

Returns

boolean

Inherited from

Server.updateClientState

---

waitForClientReady()

waitForClientReady(clientId, timeout?): Promise<boolean>

Defined in: messenger/core.ts:137

Parameters

Parameter	Type
clientId	string
timeout?	number

Returns

Promise<boolean>

Inherited from

Server.waitForClientReady