Module io.axoniq.connector.axonserver

Package io.axoniq.axonserver.grpc.admin

Class EventProcessorAdminServiceGrpc.EventProcessorAdminServiceBlockingV2Stub

java.lang.Object

io.grpc.stub.AbstractStub<S>

io.grpc.stub.AbstractBlockingStub<EventProcessorAdminServiceGrpc.EventProcessorAdminServiceBlockingV2Stub>

io.axoniq.axonserver.grpc.admin.EventProcessorAdminServiceGrpc.EventProcessorAdminServiceBlockingV2Stub

Enclosing class:

EventProcessorAdminServiceGrpc

public static final class EventProcessorAdminServiceGrpc.EventProcessorAdminServiceBlockingV2Stub
extends io.grpc.stub.AbstractBlockingStub<EventProcessorAdminServiceGrpc.EventProcessorAdminServiceBlockingV2Stub>

A stub to allow clients to do synchronous 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.EventProcessorAdminServiceBlockingV2Stub	build(io.grpc.Channel channel, io.grpc.CallOptions callOptions)
io.grpc.stub.BlockingClientCall<?,EventProcessor>	getAllEventProcessors(com.google.protobuf.Empty request)	Retrieves all event processors registered in an Axon Server cluster
io.grpc.stub.BlockingClientCall<?,LoadBalancingStrategy>	getBalancingStrategies(com.google.protobuf.Empty request)
io.grpc.stub.BlockingClientCall<?,EventProcessor>	getEventProcessorsByComponent(Component request)	Retrieves all event processors registered in an Axon Server cluster for the specified component
io.grpc.stub.BlockingClientCall<?,com.google.protobuf.Empty>	loadBalanceProcessor(LoadBalanceRequest request)
AdminActionResult	mergeEventProcessor(EventProcessorIdentifier request)	Request to merge the smallest two segments of a streaming event processor
AdminActionResult	moveEventProcessorSegment(MoveSegment request)	Request to move the specified segment of a streaming event processor to the desired destination
AdminActionResult	pauseEventProcessor(EventProcessorIdentifier request)	Request to pause an event processor
io.grpc.stub.BlockingClientCall<?,com.google.protobuf.Empty>	setAutoLoadBalanceStrategy(LoadBalanceRequest request)
AdminActionResult	splitEventProcessor(EventProcessorIdentifier request)	Request to split the largest segment of a streaming event processor
AdminActionResult	startEventProcessor(EventProcessorIdentifier request)	Request to start an event processor

Methods inherited from class io.grpc.stub.AbstractBlockingStub

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.EventProcessorAdminServiceBlockingV2Stub build(io.grpc.Channel channel,
                                                                                        io.grpc.CallOptions callOptions)

Specified by:

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

pauseEventProcessor

public AdminActionResult pauseEventProcessor(EventProcessorIdentifier request)
                                      throws io.grpc.StatusException

 Request to pause an event processor 
 

Throws:

io.grpc.StatusException

startEventProcessor

public AdminActionResult startEventProcessor(EventProcessorIdentifier request)
                                      throws io.grpc.StatusException

 Request to start an event processor 
 

Throws:

io.grpc.StatusException

splitEventProcessor

public AdminActionResult splitEventProcessor(EventProcessorIdentifier request)
                                      throws io.grpc.StatusException

 Request to split the largest segment of a streaming event processor 
 

Throws:

io.grpc.StatusException

mergeEventProcessor

public AdminActionResult mergeEventProcessor(EventProcessorIdentifier request)
                                      throws io.grpc.StatusException

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

Throws:

io.grpc.StatusException

moveEventProcessorSegment

public AdminActionResult moveEventProcessorSegment(MoveSegment request)
                                            throws io.grpc.StatusException

 Request to move the specified segment of a streaming event processor to the desired destination 
 

Throws:

io.grpc.StatusException

getAllEventProcessors

@ExperimentalApi("https://github.com/grpc/grpc-java/issues/10918")
public io.grpc.stub.BlockingClientCall<?,EventProcessor> getAllEventProcessors(com.google.protobuf.Empty request)

 Retrieves all event processors registered in an Axon Server cluster 
 

getEventProcessorsByComponent

@ExperimentalApi("https://github.com/grpc/grpc-java/issues/10918")
public io.grpc.stub.BlockingClientCall<?,EventProcessor> getEventProcessorsByComponent(Component request)

 Retrieves all event processors registered in an Axon Server cluster for the specified component
 

loadBalanceProcessor

@ExperimentalApi("https://github.com/grpc/grpc-java/issues/10918")
public io.grpc.stub.BlockingClientCall<?,com.google.protobuf.Empty> loadBalanceProcessor(LoadBalanceRequest request)

setAutoLoadBalanceStrategy

@ExperimentalApi("https://github.com/grpc/grpc-java/issues/10918")
public io.grpc.stub.BlockingClientCall<?,com.google.protobuf.Empty> setAutoLoadBalanceStrategy(LoadBalanceRequest request)

getBalancingStrategies

@ExperimentalApi("https://github.com/grpc/grpc-java/issues/10918")
public io.grpc.stub.BlockingClientCall<?,LoadBalancingStrategy> getBalancingStrategies(com.google.protobuf.Empty request)