Module io.axoniq.connector.axonserver

Package io.axoniq.axonserver.grpc.admin

Class ReplicationGroupAdminServiceGrpc.ReplicationGroupAdminServiceStub

java.lang.Object

io.grpc.stub.AbstractStub<S>

io.grpc.stub.AbstractAsyncStub<ReplicationGroupAdminServiceGrpc.ReplicationGroupAdminServiceStub>

io.axoniq.axonserver.grpc.admin.ReplicationGroupAdminServiceGrpc.ReplicationGroupAdminServiceStub

Enclosing class:

ReplicationGroupAdminServiceGrpc

public static final class ReplicationGroupAdminServiceGrpc.ReplicationGroupAdminServiceStub
extends io.grpc.stub.AbstractAsyncStub<ReplicationGroupAdminServiceGrpc.ReplicationGroupAdminServiceStub>

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

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
void	addNodeToReplicationGroup(JoinReplicationGroup request, io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver)
protected ReplicationGroupAdminServiceGrpc.ReplicationGroupAdminServiceStub	build(io.grpc.Channel channel, io.grpc.CallOptions callOptions)
void	createReplicationGroup(CreateReplicationGroupRequest request, io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver)
void	deleteReplicationGroup(DeleteReplicationGroupRequest request, io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver)
void	getNodes(com.google.protobuf.Empty request, io.grpc.stub.StreamObserver<NodeOverview> responseObserver)
void	getReplicationGroup(GetReplicationGroupRequest request, io.grpc.stub.StreamObserver<ReplicationGroupOverview> responseObserver)
void	getReplicationGroups(com.google.protobuf.Empty request, io.grpc.stub.StreamObserver<ReplicationGroupOverview> responseObserver)
void	removeNodeFromReplicationGroup(LeaveReplicationGroup request, io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver)

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

Specified by:

build in class io.grpc.stub.AbstractStub<ReplicationGroupAdminServiceGrpc.ReplicationGroupAdminServiceStub>

getNodes

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

createReplicationGroup

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

getReplicationGroups

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

getReplicationGroup

public void getReplicationGroup(GetReplicationGroupRequest request,
                                io.grpc.stub.StreamObserver<ReplicationGroupOverview> responseObserver)

deleteReplicationGroup

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

addNodeToReplicationGroup

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

removeNodeFromReplicationGroup

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