default void |
EventProcessorAdminServiceGrpc.AsyncService.mergeEventProcessor(EventProcessorIdentifier request,
io.grpc.stub.StreamObserver<AdminActionResult> responseObserver) |
Request to merge the smallest two segments of a streaming event processor
|
AdminActionResult |
EventProcessorAdminServiceGrpc.EventProcessorAdminServiceBlockingStub.mergeEventProcessor(EventProcessorIdentifier request) |
Request to merge the smallest two segments of a streaming event processor
|
AdminActionResult |
EventProcessorAdminServiceGrpc.EventProcessorAdminServiceBlockingV2Stub.mergeEventProcessor(EventProcessorIdentifier request) |
Request to merge the smallest two segments of a streaming event processor
|
com.google.common.util.concurrent.ListenableFuture<AdminActionResult> |
EventProcessorAdminServiceGrpc.EventProcessorAdminServiceFutureStub.mergeEventProcessor(EventProcessorIdentifier request) |
Request to merge the smallest two segments of a streaming event processor
|
void |
EventProcessorAdminServiceGrpc.EventProcessorAdminServiceStub.mergeEventProcessor(EventProcessorIdentifier request,
io.grpc.stub.StreamObserver<AdminActionResult> responseObserver) |
Request to merge the smallest two segments of a streaming event processor
|
MoveSegment.Builder |
MoveSegment.Builder.mergeEventProcessor(EventProcessorIdentifier value) |
the identifier of the event processor
|
EventProcessorIdentifier.Builder |
EventProcessorIdentifier.Builder.mergeFrom(EventProcessorIdentifier other) |
|
EventProcessor.Builder |
EventProcessor.Builder.mergeIdentifier(EventProcessorIdentifier value) |
the identifier of the event processor
|
LoadBalanceRequest.Builder |
LoadBalanceRequest.Builder.mergeProcessor(EventProcessorIdentifier value) |
.io.axoniq.axonserver.grpc.admin.EventProcessorIdentifier processor = 1;
|
static EventProcessorIdentifier.Builder |
EventProcessorIdentifier.newBuilder(EventProcessorIdentifier prototype) |
|
default void |
EventProcessorAdminServiceGrpc.AsyncService.pauseEventProcessor(EventProcessorIdentifier request,
io.grpc.stub.StreamObserver<AdminActionResult> responseObserver) |
Request to pause an event processor
|
AdminActionResult |
EventProcessorAdminServiceGrpc.EventProcessorAdminServiceBlockingStub.pauseEventProcessor(EventProcessorIdentifier request) |
Request to pause an event processor
|
AdminActionResult |
EventProcessorAdminServiceGrpc.EventProcessorAdminServiceBlockingV2Stub.pauseEventProcessor(EventProcessorIdentifier request) |
Request to pause an event processor
|
com.google.common.util.concurrent.ListenableFuture<AdminActionResult> |
EventProcessorAdminServiceGrpc.EventProcessorAdminServiceFutureStub.pauseEventProcessor(EventProcessorIdentifier request) |
Request to pause an event processor
|
void |
EventProcessorAdminServiceGrpc.EventProcessorAdminServiceStub.pauseEventProcessor(EventProcessorIdentifier request,
io.grpc.stub.StreamObserver<AdminActionResult> responseObserver) |
Request to pause an event processor
|
MoveSegment.Builder |
MoveSegment.Builder.setEventProcessor(EventProcessorIdentifier value) |
the identifier of the event processor
|
EventProcessor.Builder |
EventProcessor.Builder.setIdentifier(EventProcessorIdentifier value) |
the identifier of the event processor
|
LoadBalanceRequest.Builder |
LoadBalanceRequest.Builder.setProcessor(EventProcessorIdentifier value) |
.io.axoniq.axonserver.grpc.admin.EventProcessorIdentifier processor = 1;
|
default void |
EventProcessorAdminServiceGrpc.AsyncService.splitEventProcessor(EventProcessorIdentifier request,
io.grpc.stub.StreamObserver<AdminActionResult> responseObserver) |
Request to split the largest segment of a streaming event processor
|
AdminActionResult |
EventProcessorAdminServiceGrpc.EventProcessorAdminServiceBlockingStub.splitEventProcessor(EventProcessorIdentifier request) |
Request to split the largest segment of a streaming event processor
|
AdminActionResult |
EventProcessorAdminServiceGrpc.EventProcessorAdminServiceBlockingV2Stub.splitEventProcessor(EventProcessorIdentifier request) |
Request to split the largest segment of a streaming event processor
|
com.google.common.util.concurrent.ListenableFuture<AdminActionResult> |
EventProcessorAdminServiceGrpc.EventProcessorAdminServiceFutureStub.splitEventProcessor(EventProcessorIdentifier request) |
Request to split the largest segment of a streaming event processor
|
void |
EventProcessorAdminServiceGrpc.EventProcessorAdminServiceStub.splitEventProcessor(EventProcessorIdentifier request,
io.grpc.stub.StreamObserver<AdminActionResult> responseObserver) |
Request to split the largest segment of a streaming event processor
|
default void |
EventProcessorAdminServiceGrpc.AsyncService.startEventProcessor(EventProcessorIdentifier request,
io.grpc.stub.StreamObserver<AdminActionResult> responseObserver) |
Request to start an event processor
|
AdminActionResult |
EventProcessorAdminServiceGrpc.EventProcessorAdminServiceBlockingStub.startEventProcessor(EventProcessorIdentifier request) |
Request to start an event processor
|
AdminActionResult |
EventProcessorAdminServiceGrpc.EventProcessorAdminServiceBlockingV2Stub.startEventProcessor(EventProcessorIdentifier request) |
Request to start an event processor
|
com.google.common.util.concurrent.ListenableFuture<AdminActionResult> |
EventProcessorAdminServiceGrpc.EventProcessorAdminServiceFutureStub.startEventProcessor(EventProcessorIdentifier request) |
Request to start an event processor
|
void |
EventProcessorAdminServiceGrpc.EventProcessorAdminServiceStub.startEventProcessor(EventProcessorIdentifier request,
io.grpc.stub.StreamObserver<AdminActionResult> responseObserver) |
Request to start an event processor
|