Creates the StreamLayerClient instance.
The StreamLayerClientParams instance.
The StreamLayerClient instance.
Fetches partition data using data handle.
The message data of partition metadata.
A signal object that allows you to communicate with a request (such as the fetch request)
and, if required, abort it using the AbortController object.
For more information, see the AbortController documentation.
The data from the requested partition.
Consumes data from a layer. Returns messages from a stream layer. If the data size is less than 1 MB, the data field will be populated. If the data size is greater than 1 MB, a data handle will be returned pointing to the object stored in the Blob store.
The PollRequest instance of the configured request parameters.
A signal object that allows you to communicate with a request (such as the fetch request)
and, if required, abort it using the AbortController object.
For more information, see the AbortController documentation.
Messages [[StreamApi.Messages]] from a stream layer
Method allows to start reading data from a specified offset. The message pointer can be moved to any offset in the layer (topic). Message consumption will start from that offset. Once you seek to an offset, there is no returning to the initial offset, unless the initial offset is saved.
The SeekRequest instance of the configured request parameters.
A signal object that allows you to communicate with a request (such as the fetch request)
and, if required, abort it using the AbortController object.
For more information, see the AbortController documentation.
Response with status 200 if success.
Enables message consumption from a specific stream layer. Use the base path returned from the API Lookup service. For mode = parallel, one unit of parallelism currently equals 1 MBps inbound or 2 MBps outbound, whichever is greater, rounded up to the nearest integer. The number of subscriptions within the same group cannot exceed the parallelism allowed. For more details see Get Data from a Stream Layer
The SubscribeRequest instance of the configured request parameters.
A signal object that allows you to communicate with a request (such as the fetch request)
and, if required, abort it using the AbortController object.
For more information, see the AbortController documentation.
Subscription Id
Method deletes a subscription to a layer. This operation removes the subscription from the service.
The UnsubscribeRequest instance of the configured request parameters.
A signal object that allows you to communicate with a request (such as the fetch request)
and, if required, abort it using the AbortController object.
For more information, see the AbortController documentation.
Generated using TypeDoc
Describes a stream layer.