Module io.axoniq.connector.axonserver

Package io.axoniq.axonserver.grpc.admin

Class EventProcessorAdminServiceGrpc.EventProcessorAdminServiceFutureStub

java.lang.Object

io.grpc.stub.AbstractStub<S>

io.grpc.stub.AbstractFutureStub<EventProcessorAdminServiceGrpc.EventProcessorAdminServiceFutureStub>

io.axoniq.axonserver.grpc.admin.EventProcessorAdminServiceGrpc.EventProcessorAdminServiceFutureStub

Enclosing class:

EventProcessorAdminServiceGrpc

public static final class EventProcessorAdminServiceGrpc.EventProcessorAdminServiceFutureStub
extends io.grpc.stub.AbstractFutureStub<EventProcessorAdminServiceGrpc.EventProcessorAdminServiceFutureStub>

A stub to allow clients to do ListenableFuture-style 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.EventProcessorAdminServiceFutureStub	build(io.grpc.Channel channel, io.grpc.CallOptions callOptions)
com.google.common.util.concurrent.ListenableFuture<AdminActionResult>	mergeEventProcessor(EventProcessorIdentifier request)	Request to merge the smallest two segments of a streaming event processor
com.google.common.util.concurrent.ListenableFuture<AdminActionResult>	moveEventProcessorSegment(MoveSegment request)	Request to move the specified segment of a streaming event processor to the desired destination
com.google.common.util.concurrent.ListenableFuture<AdminActionResult>	pauseEventProcessor(EventProcessorIdentifier request)	Request to pause an event processor
com.google.common.util.concurrent.ListenableFuture<AdminActionResult>	splitEventProcessor(EventProcessorIdentifier request)	Request to split the largest segment of a streaming event processor
com.google.common.util.concurrent.ListenableFuture<AdminActionResult>	startEventProcessor(EventProcessorIdentifier request)	Request to start an event processor

Methods inherited from class io.grpc.stub.AbstractFutureStub

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

Specified by:

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

pauseEventProcessor

public com.google.common.util.concurrent.ListenableFuture<AdminActionResult> pauseEventProcessor(EventProcessorIdentifier request)

 Request to pause an event processor 
 

startEventProcessor

public com.google.common.util.concurrent.ListenableFuture<AdminActionResult> startEventProcessor(EventProcessorIdentifier request)

 Request to start an event processor 
 

splitEventProcessor

public com.google.common.util.concurrent.ListenableFuture<AdminActionResult> splitEventProcessor(EventProcessorIdentifier request)

 Request to split the largest segment of a streaming event processor 
 

mergeEventProcessor

public com.google.common.util.concurrent.ListenableFuture<AdminActionResult> mergeEventProcessor(EventProcessorIdentifier request)

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

moveEventProcessorSegment

public com.google.common.util.concurrent.ListenableFuture<AdminActionResult> moveEventProcessorSegment(MoveSegment request)

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