Interface ICluster

The cluster interface.

Hierarchy (view full)

IClusterEventEmitter
- ICluster

Properties

on

on: ClusterOnFunction

Allows listening to events published on the cluster.

Type Param: U

Any of the events defined in IClusterEvents.

Param: event

One of the events defined in IClusterEvents.

Param: listener

The callback when the event is received. Listeners' payload are defined in IClusterEvents.

Methods

getExternalStorageConnections

getExternalStorageConnections(strategy?): IExternalStorageConnection[]
Get an array of opened external storage connections.
Parameters
- Optionalstrategy: ((item: IExternalStorageConnection) => boolean)
  The strategy to use to filter the external storage connections.
  - - (item): boolean
    - Parameters
      item: IExternalStorageConnection
      Returns boolean
Returns IExternalStorageConnection[]

getGenerativeAIContexts

getGenerativeAIContexts(strategy?): IGenerativeAIContext[]
Get an array of opened generative AI contexts.
Parameters
- Optionalstrategy: ((item: IGenerativeAIContext) => boolean)
  The strategy to use to filter the job dispatchers.
  - - (item): boolean
    - Parameters
      item: IGenerativeAIContext
      Returns boolean
Returns IGenerativeAIContext[]

getGenerativeAIWorkers

getGenerativeAIWorkers(strategy?): IGenerativeAIWorker[]
Get an array of opened generative AI workers.
Parameters
- Optionalstrategy: ((item: IGenerativeAIWorker) => boolean)
  The strategy to use to filter the job workers.
  - - (item): boolean
    - Parameters
      item: IGenerativeAIWorker
      Returns boolean
Returns IGenerativeAIWorker[]

getGraphDatabases

getGraphDatabases(strategy?): IGraphDatabase[]
Get an array of opened graph databases.
Parameters
- Optionalstrategy: ((item: IGraphDatabase) => boolean)
  The strategy to use to filter the graph databases.
  - - (item): boolean
    - Parameters
      item: IGraphDatabase
      Returns boolean
Returns IGraphDatabase[]

getKeyValueDatabases

getKeyValueDatabases(strategy?): IKeyValueDatabase[]
Get an array of opened key-value databases.
Parameters
- Optionalstrategy: ((item: IKeyValueDatabase) => boolean)
  The strategy to use to filter the key-value databases.
  - - (item): boolean
    - Parameters
      item: IKeyValueDatabase
      Returns boolean
Returns IKeyValueDatabase[]

getLocalMediaStreams

getLocalMediaStreams(strategy?): ILocalMediaStream[]
Get an array of published local media streams.
Parameters
- Optionalstrategy: ((item: ILocalMediaStream) => boolean)
  The strategy to use to filter the media streams.
  - - (item): boolean
    - Parameters
      item: ILocalMediaStream
      Returns boolean
Returns ILocalMediaStream[]

getLocalNode

getLocalNode(): LocalNode
Get the local node for this cluster.

Returns LocalNode

getObjectStoreBuckets

getObjectStoreBuckets(strategy?): IObjectStoreBucket[]
Get an array of opened object store buckets.
Parameters
- Optionalstrategy: ((item: IObjectStoreBucket) => boolean)
  The strategy to use to filter the data streams.
  - - (item): boolean
    - Parameters
      item: IObjectStoreBucket
      Returns boolean
Returns IObjectStoreBucket[]

getPubSubTopics

getPubSubTopics(strategy?): IPubSubTopic<unknown>[]
Get an array of opened pub/sub topics.
Parameters
- Optionalstrategy: ((item: IPubSubTopic<unknown>) => boolean)
  The strategy to use to filter the topics.
  - - (item): boolean
    - Parameters
      item: IPubSubTopic<unknown>
      Returns boolean
Returns IPubSubTopic<unknown>[]

getRemoteMediaStreams

getRemoteMediaStreams(strategy?): IRemoteMediaStream[]
Get an array of published remote media streams.
Parameters
- Optionalstrategy: ((item: IRemoteMediaStream) => boolean)
  The strategy to use to filter the media streams.
  - - (item): boolean
    - Parameters
      item: IRemoteMediaStream
      Returns boolean
Returns IRemoteMediaStream[]

getRemoteNodes

getRemoteNodes(strategy?): Node[]
Get an array of all connected remote nodes.
Parameters
- Optionalstrategy: ((item: Node) => boolean)
  The strategy to use to filter the nodes.
  - - (item): boolean
    - Parameters
      item: Node
      Returns boolean
Returns Node[]

getVectorDatabases

getVectorDatabases(strategy?): IVectorDatabase[]
Get an array of opened vector databases.
Parameters
- Optionalstrategy: ((item: IVectorDatabase) => boolean)
  The strategy to use to filter the vector databases.
  - - (item): boolean
    - Parameters
      item: IVectorDatabase
      Returns boolean
Returns IVectorDatabase[]

leave

leave(options?): void
Leave the cluster.
Parameters
- Optionaloptions: ISDKCloseOptions
  The options to close the SDK with.
Returns void

off

off(): void
Unsubscribe from all events on the cluster

Returns void
Inherited from IClusterEventEmitter.off
off(event): void
Unsubscribe to an event.
Parameters
- event: string
  The event to unsubscribe from.
Returns void
Inherited from IClusterEventEmitter.off
off(events): void
Unsubscribe from all events, or a specific list of events.
Parameters
- events: string[]
  The list of events to unsubscribe from.
Returns void
Inherited from IClusterEventEmitter.off

openExternalStorageConnection

openExternalStorageConnection(name, type): Promise<IExternalStorageConnection>
Open an external storage connection.
Parameters
- name: string
  The name of the external storage connection.
- type: SharePoint
  The type of the external storage connection.
Returns Promise<IExternalStorageConnection>
The external storage connection.

Throws
SDKClientErrorCodes.ExternalStorageConnectionAlreadyExists if the external storage connection is already open.

Throws
SDKClientErrorCodes.ExternalStorageNameNotString if the name is not a string.

openGenerativeAIContext

openGenerativeAIContext(label): Promise<IGenerativeAIContext>
Open a generative AI context.
Parameters
- label: string
  The label of the generative AI context.
Returns Promise<IGenerativeAIContext>

openGenerativeAIWorker

openGenerativeAIWorker(label): Promise<IGenerativeAIWorker>
Open a generative AI worker.
Parameters
- label: string
  The label of the generative AI Worker.
Returns Promise<IGenerativeAIWorker>

openGraphDatabase

openGraphDatabase(label): IGraphDatabase
Open a graph database.
Parameters
- label: string
  The label of the graph database.
Returns IGraphDatabase

openKeyValueDatabase

openKeyValueDatabase(name, layout): Promise<IKeyValueDatabase>
Open a key-value database.
Parameters
- name: string
  The name of the key-value database.
- layout: IDatabaseLayout | ILayoutBuilder
  The layout of the key-value database.
Returns Promise<IKeyValueDatabase>
A promise that resolves with the key-value database.

Throws
SDKClientErrorCodes.KeyValueDatabaseAlreadyExists if the key-value database is already open.

Throws
SDKClientErrorCodes.KeyValueDatabaseInvalidLayout if the layout is invalid.

Throws
SDKClientErrorCodes.KeyValueDatabaseNameNotString if the name is not a string.

openObjectStoreBucket

openObjectStoreBucket(name, options?): Promise<IObjectStoreBucket>
Open a object store bucket.
Parameters
- name: string
  The name of the Object Store bucket.
- Optionaloptions: IObjectStoreBucketOptions
  The options of the Object Store bucket.
Returns Promise<IObjectStoreBucket>
A promise that resolves with the data stream.

Throws
SDKClientErrorCodes.ObjectStoreAlreadyExists if the data stream is already open.

Throws
SDKClientErrorCodes.ObjectStoreNameNotString if the name is not a string.

openPubSubTopic

openPubSubTopic<T>(name): IPubSubTopic<T>
Open a pub/sub topic.
Type Parameters
- T
Parameters
- name: string
  The name of the PubSub Topic.
Returns IPubSubTopic<T>
The pub/sub topic.

Throws
SDKClientErrorCodes.PubSubTopicAlreadyExists if the topic already exists

Throws
SDKClientErrorCodes.PubSubTopicNameNotString if the name is not a string.

openVectorDatabase

openVectorDatabase(label): IVectorDatabase
Open a vector database.
Parameters
- label: string
  The label of the vector database.
Returns IVectorDatabase

publishLocalDynamicMediaStream

publishLocalDynamicMediaStream(label, mediaSource): ILocalDynamicMediaStream
Publish a local dynamic media stream. Like a local media stream but can be modified after creation.
Parameters
- label: string
  The label of the media stream.
- mediaSource: MediaStreamSource
  The media source to publish.
Returns ILocalDynamicMediaStream
The local dynamic media stream.

Throws
SDKClientErrorCodes.LocalMediaStreamAlreadyExists if the media stream is already published.

publishLocalMediaStream

publishLocalMediaStream(label, mediaSource): ILocalMediaStream
Publish a local media stream.
Parameters
- label: string
  The label of the media stream.
- mediaSource: MediaStreamSource
  The media source to publish.
Returns ILocalMediaStream
The local media stream.

Throws
SDKClientErrorCodes.LocalMediaStreamAlreadyExists if the media stream is already published.

Interface ICluster

Hierarchy (view full)

Index

Properties

Methods

Properties

on

Type Param: U

Param: event

Param: listener

Methods

getExternalStorageConnections

Parameters

Parameters

Returns boolean

Returns IExternalStorageConnection[]

getGenerativeAIContexts

Parameters

Parameters

Returns boolean

Returns IGenerativeAIContext[]

getGenerativeAIWorkers

Parameters

Parameters

Returns boolean

Returns IGenerativeAIWorker[]

getGraphDatabases

Parameters

Parameters

Returns boolean

Returns IGraphDatabase[]

getKeyValueDatabases

Parameters

Parameters

Returns boolean

Returns IKeyValueDatabase[]

getLocalMediaStreams

Parameters

Parameters

Returns boolean

Returns ILocalMediaStream[]

getLocalNode

Returns LocalNode

getObjectStoreBuckets

Parameters

Parameters

Returns boolean

Returns IObjectStoreBucket[]

getPubSubTopics

Parameters

Parameters

Returns boolean

Returns IPubSubTopic<unknown>[]

getRemoteMediaStreams

Parameters

Parameters

Returns boolean

Returns IRemoteMediaStream[]

getRemoteNodes

Parameters

Parameters

Returns boolean

Returns Node[]

getVectorDatabases

Parameters

Parameters

Returns boolean

Returns IVectorDatabase[]

leave

Parameters

Returns void

off

Returns void

Parameters

Returns void

Parameters

Returns void

openExternalStorageConnection

Parameters

Returns Promise<IExternalStorageConnection>