Module io.axoniq.connector.axonserver
Package io.axoniq.axonserver.grpc.admin

Interface EventProcessorAdminServiceGrpc.AsyncService

    • Method Detail

      • splitEventProcessor

        default void splitEventProcessor​(EventProcessorIdentifier request,
                                 io.grpc.stub.StreamObserver<AdminActionResult> responseObserver)
         Request to split the largest segment of a streaming event processor

      • mergeEventProcessor

        default void mergeEventProcessor​(EventProcessorIdentifier request,
                                 io.grpc.stub.StreamObserver<AdminActionResult> responseObserver)
         Request to merge the smallest two segments of a streaming event processor

      • moveEventProcessorSegment

        default void moveEventProcessorSegment​(MoveSegment request,
                                       io.grpc.stub.StreamObserver<AdminActionResult> responseObserver)
         Request to move the specified segment of a streaming event processor to the desired destination

      • getAllEventProcessors

        default void getAllEventProcessors​(com.google.protobuf.Empty request,
                                   io.grpc.stub.StreamObserver<EventProcessor> responseObserver)
         Retrieves all event processors registered in an Axon Server cluster

      • getEventProcessorsByComponent

        default void getEventProcessorsByComponent​(Component request,
                                           io.grpc.stub.StreamObserver<EventProcessor> responseObserver)
         Retrieves all event processors registered in an Axon Server cluster for the specified component

      • loadBalanceProcessor

        default void loadBalanceProcessor​(LoadBalanceRequest request,
                                  io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver)

      • setAutoLoadBalanceStrategy

        default void setAutoLoadBalanceStrategy​(LoadBalanceRequest request,
                                        io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver)

      • getBalancingStrategies

        default void getBalancingStrategies​(com.google.protobuf.Empty request,
                                    io.grpc.stub.StreamObserver<LoadBalancingStrategy> responseObserver)