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
-