Module io.axoniq.connector.axonserver

Package io.axoniq.axonserver.grpc.admin

Class EventProcessorAdminServiceGrpc.EventProcessorAdminServiceBlockingStub

java.lang.Object

io.grpc.stub.AbstractStub<S>

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

io.axoniq.axonserver.grpc.admin.EventProcessorAdminServiceGrpc.EventProcessorAdminServiceBlockingStub

Enclosing class:

EventProcessorAdminServiceGrpc

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

A stub to allow clients to do limited 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.EventProcessorAdminServiceBlockingStub	build(io.grpc.Channel channel, io.grpc.CallOptions callOptions)
Iterator<EventProcessor>	getAllEventProcessors(com.google.protobuf.Empty request)	Retrieves all event processors registered in an Axon Server cluster
Iterator<LoadBalancingStrategy>	getBalancingStrategies(com.google.protobuf.Empty request)
Iterator<EventProcessor>	getEventProcessorsByComponent(Component request)	Retrieves all event processors registered in an Axon Server cluster for the specified component
Iterator<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
Iterator<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.EventProcessorAdminServiceBlockingStub build(io.grpc.Channel channel,
                                                                                      io.grpc.CallOptions callOptions)

Specified by:

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

pauseEventProcessor

public AdminActionResult pauseEventProcessor(EventProcessorIdentifier request)

 Request to pause an event processor 
 

startEventProcessor

public AdminActionResult startEventProcessor(EventProcessorIdentifier request)

 Request to start an event processor 
 

splitEventProcessor

public AdminActionResult splitEventProcessor(EventProcessorIdentifier request)

 Request to split the largest segment of a streaming event processor 
 

mergeEventProcessor

public AdminActionResult mergeEventProcessor(EventProcessorIdentifier request)

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

moveEventProcessorSegment

public AdminActionResult moveEventProcessorSegment(MoveSegment request)

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

getAllEventProcessors

public Iterator<EventProcessor> getAllEventProcessors(com.google.protobuf.Empty request)

 Retrieves all event processors registered in an Axon Server cluster 
 

getEventProcessorsByComponent

public Iterator<EventProcessor> getEventProcessorsByComponent(Component request)

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

loadBalanceProcessor

public Iterator<com.google.protobuf.Empty> loadBalanceProcessor(LoadBalanceRequest request)

setAutoLoadBalanceStrategy

public Iterator<com.google.protobuf.Empty> setAutoLoadBalanceStrategy(LoadBalanceRequest request)

getBalancingStrategies

public Iterator<LoadBalancingStrategy> getBalancingStrategies(com.google.protobuf.Empty request)