Interface EventStreamRpc
- All Known Implementing Classes:
GatewayEventStreamRpc
public interface EventStreamRpc
-
Field Summary
Fields -
Method Summary
Modifier and TypeMethodDescriptiongetDiagnostics
(String projectName, String path) Returns the current diagnostics for the given Event Stream.Returns a list of all available Event Stream encoders.List of all available Event Stream Handler descriptors.List of all available Event Stream Source descriptors.Returns the current state of the Event Stream.listEventStreams
(String project) Returns a list of all Event Streams in the given project.runEventStream
(String projectName, String path, EventStreamConfig config, EventStreamRunConfig runConfig) Starts the Event Stream with the given configuration.
-
Field Details
-
SERIALIZER
-
-
Method Details
-
getSourceDescriptors
List<SourceDescriptor> getSourceDescriptors()List of all available Event Stream Source descriptors. -
getHandlerDescriptors
List<HandlerDescriptor> getHandlerDescriptors()List of all available Event Stream Handler descriptors. -
getEventStreamEncoders
List<EventStreamEncoder.Descriptor> getEventStreamEncoders()Returns a list of all available Event Stream encoders.- Returns:
- List of Event Stream encoder descriptors
-
listEventStreams
Returns a list of all Event Streams in the given project.- Parameters:
project
- Project name- Returns:
- List of Event Stream descriptions
-
getDiagnostics
Returns the current diagnostics for the given Event Stream.- Parameters:
projectName
- Project namepath
- Path to Event Stream- Returns:
- Current diagnostics for the Event Stream
-
runEventStream
EventStreamDiagnostics runEventStream(String projectName, String path, EventStreamConfig config, EventStreamRunConfig runConfig) Starts the Event Stream with the given configuration. Stops immediately after the first event.- Parameters:
projectName
- Project namepath
- Path to Event Streamconfig
- Configuration for the Event StreamrunConfig
- Run configuration for the Event Stream- Returns:
- Current diagnostics for the Event Stream
-
getState
Returns the current state of the Event Stream.- Parameters:
project
- Project namepath
- Path to Event Stream- Returns:
- Current state of the Event Stream
-