PravegaStreamManager is a wrapper around the StreamManager Java API.
Basically it's allow to create, drop, seal, truncate, etc. streams.
Attributes
- Companion
- trait
- Graph
-
- Supertypes
-
class Objecttrait Matchableclass Any
- Self type
-
PravegaStreamManager.type
Members list
Value members
Concrete methods
Create a scope with the given name.
Create a scope with the given name.
Returns true if the scope was created, false if it already exists.
Attributes
Create a stream with the given name and config.
Create a stream with the given name and config.
Returns true if the stream was created, false if it already exists.
Attributes
Drop a scope with the given name.
Drop a scope with the given name.
Returns true if the scope was dropped, false if it does not exist.
Attributes
Drop a stream with the given name.
Drop a stream with the given name.
Returns true if the stream is deleted.
Attributes
List all the scopes in the Pravega cluster.
List all the scopes in the Pravega cluster.
Attributes
List all the streams in the Pravega cluster given scope.
List all the streams in the Pravega cluster given scope.
Attributes
ZLayer to provide a PravegaStreamManager from a environment with a ClientConfig.
ZLayer to provide a PravegaStreamManager from a environment with a ClientConfig.
Attributes
ZLayer to provide a PravegaStreamManager from a ClientConfig.
ZLayer to provide a PravegaStreamManager from a ClientConfig.
Attributes
Seal a stream with the given name.
Seal a stream with the given name.
Returns true if the stream is sealed.
Attributes
Truncate a stream with the given name.
Truncate a stream with the given name.
Returns true if the stream is truncated.