Class OcelloidsAgentApi<T>

Exposes the Ocelloids Agent API.

Type Parameters

T

Implements

Index

Constructors

Methods

allSubscriptions createSubscription deleteSubscription getSubscription health networks query subscribe

Constructors

constructor

new OcelloidsAgentApi<T>(
    config: Required<OcelloidsClientConfig>,
    agentId: string,
    clientApi: OcelloidsClientApi,
): OcelloidsAgentApi<T>
Type Parameters
- T
Parameters
- config: Required<OcelloidsClientConfig>
- agentId: string
- clientApi: OcelloidsClientApi
Returns OcelloidsAgentApi<T>
- Defined in client/src/client.ts:105

Methods

allSubscriptions

allSubscriptions(options?: Options): Promise<Subscription<T>[]>
Lists all subscriptions.
Parameters
- Optionaloptions: Options
  The ky request options (fetch compatible)
Returns Promise<Subscription<T>[]>
A promise that resolves with an array of subscriptions.
Implementation of SubscribableApi.allSubscriptions
- Defined in client/src/client.ts:194

createSubscription

createSubscription(
subscription: Omit<Subscription<T>, "agent">,
options?: Options,
): Promise<unknown>
Creates a subscription.
Parameters
- subscription: Omit<Subscription<T>, "agent">
  The subscription to create.
- Optionaloptions: Options
  The ky request options (fetch compatible)
Returns Promise<unknown>
A promise that resolves when the subscription is created.
Implementation of SubscribableApi.createSubscription
- Defined in client/src/client.ts:151

deleteSubscription

deleteSubscription(id: string, options?: Options): Promise<unknown>
Deletes a subscription.
Parameters
- id: string
  The subscription ID.
- Optionaloptions: Options
  The ky request options (fetch compatible)
Returns Promise<unknown>
Implementation of SubscribableApi.deleteSubscription
- Defined in client/src/client.ts:168

getSubscription

getSubscription(id: string, options?: Options): Promise<Subscription<T>>
Gets a subscription by its ID.
Parameters
- id: string
  The subscription ID.
- Optionaloptions: Options
  The ky request options (fetch compatible)
Returns Promise<Subscription<T>>
A promise that resolves with the subscription or rejects if not found.
Implementation of SubscribableApi.getSubscription
- Defined in client/src/client.ts:183

health

health(options?: Options): Promise<HealthResponse>
Parameters
- Optionaloptions: Options
Returns Promise<HealthResponse>
Implementation of OcelloidsClientApi.health
- Defined in client/src/client.ts:116

networks

networks(options?: Options): Promise<Record<string, string[]>>
Parameters
- Optionaloptions: Options
Returns Promise<Record<string, string[]>>
Implementation of OcelloidsClientApi.networks
- Defined in client/src/client.ts:112

query

query<P = AnyQueryArgs, R = AnyQueryResultItem>(
    args: P,
    pagination?: QueryPagination,
    options?: Options,
): Promise<QueryResult<R>>
Executes a query on the specified agent.
Type Parameters
- P = AnyQueryArgs
- R = AnyQueryResultItem
Parameters
- args: P
  The query arguments.
- Optionalpagination: QueryPagination
  The pagination configuration.
- Optionaloptions: Options
  The ky request options (fetch compatible).
Returns Promise<QueryResult<R>>
A promise that resolves to the results of the query.
Implementation of QueryableApi.query
- Defined in client/src/client.ts:128

subscribe<P = AnyJson>(
    subscription: string | T,
    handlers: WebSocketHandlers<P>,
    onDemandHandlers?: OnDemandSubscriptionHandlers<T>,
): Promise<WebSocket>
Creates an on-demand subscription or connects to an existing one.
Type Parameters
- P = AnyJson
Parameters
- subscription: string | T
  The subscription id or the subscription inputs.
- handlers: WebSocketHandlers<P>
  The WebSocket event handlers.
- OptionalonDemandHandlers: OnDemandSubscriptionHandlers<T>
  The on-demand subscription handlers.
Returns Promise<WebSocket>
A promise that resolves with the WebSocket instance.
Implementation of SubscribableApi.subscribe
- Defined in client/src/client.ts:206