Skip to content

InMemoryTransport

Defined in: src/cluster/Transport.ts:294

A transport that keeps everything inside the current process. Useful for tests where we want to simulate a cluster without opening TCP sockets.

new InMemoryTransport(self): InMemoryTransport

Defined in: src/cluster/Transport.ts:301

NodeAddress

InMemoryTransport

readonly self: NodeAddress

Defined in: src/cluster/Transport.ts:301

Transport.self

disconnect(_peer): void

Defined in: src/cluster/Transport.ts:325

Close the connection to a peer.

NodeAddress

void

Transport.disconnect


peers(): NodeAddress[]

Defined in: src/cluster/Transport.ts:327

Peers currently connected (either inbound or outbound).

NodeAddress[]

Transport.peers


send(to, msg): void

Defined in: src/cluster/Transport.ts:314

Best-effort fire-and-forget send. Opens a connection on first use.

NodeAddress

WireMessage

void

Transport.send


setHandler(handler): void

Defined in: src/cluster/Transport.ts:303

WireHandler

void

Transport.setHandler


shutdown(): Promise<void>

Defined in: src/cluster/Transport.ts:309

Promise<void>

Transport.shutdown


start(): Promise<void>

Defined in: src/cluster/Transport.ts:305

Promise<void>

Transport.start