Class AsyncServer

Async server for source operations.

Wraps a Sourcer implementation and handles communication with the Numaflow platform.

Index

Constructors

Methods

Constructors

constructor

new AsyncServer(sourcer: Sourcer): source.AsyncServer
Create a new source server.
Parameters
- sourcer: Sourcer
  Implementation of the Sourcer interface
Returns source.AsyncServer
- Defined in index.ts:2566

Methods

start

start(socketPath?: string | null, serverInfoPath?: string | null): Promise<void>
Start the source server.
Parameters
- OptionalsocketPath: string | null
  Optional custom Unix socket path
- OptionalserverInfoPath: string | null
  Optional path for server info file
Returns Promise<void>
- Defined in index.ts:2601

stop

stop(): void
Stop the server gracefully.

Returns void
- Defined in index.ts:2608