Module io.axoniq.connector.axonserver

Package io.axoniq.axonserver.grpc.admin

Class EventProcessorAdminServiceGrpc.EventProcessorAdminServiceStub

java.lang.Object

io.grpc.stub.AbstractStub<S>

io.grpc.stub.AbstractAsyncStub<EventProcessorAdminServiceGrpc.EventProcessorAdminServiceStub>

io.axoniq.axonserver.grpc.admin.EventProcessorAdminServiceGrpc.EventProcessorAdminServiceStub

Enclosing class:

EventProcessorAdminServiceGrpc

public static final class EventProcessorAdminServiceGrpc.EventProcessorAdminServiceStub
extends io.grpc.stub.AbstractAsyncStub<EventProcessorAdminServiceGrpc.EventProcessorAdminServiceStub>

A stub to allow clients to do asynchronous rpc calls to service EventProcessorAdminService.

 Event Processor Admin Service ***************************
 

Nested Class Summary

Nested classes/interfaces inherited from class io.grpc.stub.AbstractStub

io.grpc.stub.AbstractStub.StubFactory<T extends io.grpc.stub.AbstractStub<T>>

Method Summary

Modifier and Type	Method	Description
protected EventProcessorAdminServiceGrpc.EventProcessorAdminServiceStub	build(io.grpc.Channel channel, io.grpc.CallOptions callOptions)
void	getAllEventProcessors(com.google.protobuf.Empty request, io.grpc.stub.StreamObserver<EventProcessor> responseObserver)	Retrieves all event processors registered in an Axon Server cluster
void	getBalancingStrategies(com.google.protobuf.Empty request, io.grpc.stub.StreamObserver<LoadBalancingStrategy> responseObserver)
void	getEventProcessorsByComponent(Component request, io.grpc.stub.StreamObserver<EventProcessor> responseObserver)	Retrieves all event processors registered in an Axon Server cluster for the specified component
void	loadBalanceProcessor(LoadBalanceRequest request, io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver)
void	mergeEventProcessor(EventProcessorIdentifier request, io.grpc.stub.StreamObserver<AdminActionResult> responseObserver)	Request to merge the smallest two segments of a streaming event processor
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
void	pauseEventProcessor(EventProcessorIdentifier request, io.grpc.stub.StreamObserver<AdminActionResult> responseObserver)	Request to pause an event processor
void	setAutoLoadBalanceStrategy(LoadBalanceRequest request, io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver)
void	splitEventProcessor(EventProcessorIdentifier request, io.grpc.stub.StreamObserver<AdminActionResult> responseObserver)	Request to split the largest segment of a streaming event processor
void	startEventProcessor(EventProcessorIdentifier request, io.grpc.stub.StreamObserver<AdminActionResult> responseObserver)	Request to start an event processor

Methods inherited from class io.grpc.stub.AbstractAsyncStub

newStub, newStub

Methods inherited from class io.grpc.stub.AbstractStub

getCallOptions, getChannel, withCallCredentials, withChannel, withCompression, withDeadline, withDeadlineAfter, withDeadlineAfter, withExecutor, withInterceptors, withMaxInboundMessageSize, withMaxOutboundMessageSize, withOnReadyThreshold, withOption, withWaitForReady

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Detail

build

protected EventProcessorAdminServiceGrpc.EventProcessorAdminServiceStub build(io.grpc.Channel channel,
                                                                              io.grpc.CallOptions callOptions)

Specified by:

build in class io.grpc.stub.AbstractStub<EventProcessorAdminServiceGrpc.EventProcessorAdminServiceStub>

pauseEventProcessor

public void pauseEventProcessor(EventProcessorIdentifier request,
                                io.grpc.stub.StreamObserver<AdminActionResult> responseObserver)

 Request to pause an event processor 
 

startEventProcessor

public void startEventProcessor(EventProcessorIdentifier request,
                                io.grpc.stub.StreamObserver<AdminActionResult> responseObserver)

 Request to start an event processor 
 

splitEventProcessor

public void splitEventProcessor(EventProcessorIdentifier request,
                                io.grpc.stub.StreamObserver<AdminActionResult> responseObserver)

 Request to split the largest segment of a streaming event processor 
 

mergeEventProcessor

public void mergeEventProcessor(EventProcessorIdentifier request,
                                io.grpc.stub.StreamObserver<AdminActionResult> responseObserver)

 Request to merge the smallest two segments of a streaming event processor 
 

moveEventProcessorSegment

public 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

public void getAllEventProcessors(com.google.protobuf.Empty request,
                                  io.grpc.stub.StreamObserver<EventProcessor> responseObserver)

 Retrieves all event processors registered in an Axon Server cluster 
 

getEventProcessorsByComponent

public 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

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

setAutoLoadBalanceStrategy

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

getBalancingStrategies

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