A convenience API for managing and accessing an individual stream.
Assigns the stream to a storage node.
a resolved promise if (1) stream was assigned to storage node and (2) the storage node acknowledged the
timeout, otherwise rejects. Notice that is possible for this promise to reject but for the
storage node assignment to go through eventually.
control how long to wait for storage node to pick up on assignment
Deletes the stream.
Stream instance should not be used afterwards.
Attempts to detect and update the config metadata of the stream by performing a resend.
Only works on stored streams.
be mindful that in the case of there being zero messages stored, the returned promise will resolve even though fields were not updated
Returns the metadata of the stream.
Returns the partitions of the stream.
Updates the metadata of the stream by merging with the existing metadata.
Generated using TypeDoc