VgiRpcServer

Defined in: src/server.ts:47

RPC server that reads Arrow IPC requests from stdin and writes responses to stdout. Supports unary and streaming (producer/exchange) methods.

Constructors

Constructor

new VgiRpcServer(protocol, options?): VgiRpcServer;

Defined in: src/server.ts:68

Parameters

Parameter	Type	Description
protocol	Protocol	-
options?	{ dispatchHook?: DispatchHook; enableDescribe?: boolean; externalLocation?: ExternalLocationConfig; onServeStart?: ServeStartHook; protocolVersion?: string; serverId?: string; }	-
options.dispatchHook?	DispatchHook	-
options.enableDescribe?	boolean	-
options.externalLocation?	ExternalLocationConfig	-
options.onServeStart?	ServeStartHook	Lifecycle hook fired once before the first dispatched request.
options.protocolVersion?	string	-
options.serverId?	string	-

Returns

VgiRpcServer

Methods

run()

run(): Promise<void>;

Defined in: src/server.ts:165

Start the server loop. Reads requests until stdin closes.

Returns

Promise<void>