Class AsterClientWrapper

connected

• get connected(): boolean

  Whether the client is connected.

  Returns boolean

services

• get services(): ServiceSummary[]

  Services discovered during admission.

  Returns ServiceSummary[]

registryNamespace

• get registryNamespace(): string | undefined

  Registry namespace ID for service discovery (set after admission).

  Returns string | undefined

gossipTopic

• get gossipTopic(): string

  Hex-encoded 32-byte gossip topic ID for the producer mesh.

  Returns string

constructor

• new AsterClientWrapper(opts: AsterClientOptions): AsterClientWrapper

  Parameters

  • opts: AsterClientOptions

  Returns AsterClientWrapper

connect

• connect(): Promise<void>

  Connect to the server via consumer admission, then open an RPC transport.

  If the client was created with a transport, this is a no-op. If created with an address, it performs the full admission handshake.

  Returns Promise<void>

client

• client<T extends new (...args: any[]) => any>(
      serviceClass: T,
  ): Promise<AsterClient<InstanceType<T>>>

  Create a typed client proxy for a service class.

  Type Parameters

  • T extends new (...args: any[]) => any

  Parameters

  • serviceClass: T

  Returns Promise<AsterClient<InstanceType<T>>>

service

• service<T extends new (...args: any[]) => any>(
      serviceClass: T,
  ): AsterClient<InstanceType<T>>

  Create a typed client proxy for a service class.

  Type Parameters

  • T extends new (...args: any[]) => any

  Parameters

  • serviceClass: T

  Returns AsterClient<InstanceType<T>>

proxy

• proxy(serviceName: string): ProxyClient

  Create a dynamic proxy client for a service.

  Parameters

  • serviceName: string

  Returns ProxyClient

  Example

  const mc = client.proxy("MissionControl");
  const result = await mc.getStatus({ agentId: "edge-1" });
  console.log(result.status);
  Copy

reconnect

• reconnect(
      connectFn: () => Promise<AsterTransport>,
      maxAttempts?: number,
  ): Promise<void>

  Reconnect with exponential backoff.

  Parameters

  • connectFn: () => Promise<AsterTransport>
  • maxAttempts: number = 5

  Returns Promise<void>

close

• close(): Promise<void>

  Close the client and underlying transport.

  Returns Promise<void>

Readonlyconfig