Skip to content
English

InMemoryTransport

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

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:495

NodeAddress

InMemoryTransport

readonly self: NodeAddress

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

Transport.self

disconnect(_peer): void

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

Close the connection to a peer.

NodeAddress

void

Transport.disconnect


peers(): NodeAddress[]

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

Peers currently connected (either inbound or outbound).

NodeAddress[]

Transport.peers


send(to, message): void

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

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:497

WireHandler

void

Transport.setHandler


shutdown(): Promise<void>

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

Promise<void>

Transport.shutdown


start(): Promise<void>

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

Promise<void>

Transport.start