Uses of Class
io.axoniq.axonserver.grpc.control.ClientIdentification
-
-
Uses of ClientIdentification in io.axoniq.axonserver.connector.admin.impl
Constructors in io.axoniq.axonserver.connector.admin.impl with parameters of type ClientIdentification Constructor Description AdminChannelImpl(ClientIdentification clientIdentification, ScheduledExecutorService executor, AxonServerManagedChannel channel) -
Uses of ClientIdentification in io.axoniq.axonserver.connector.command.impl
Constructors in io.axoniq.axonserver.connector.command.impl with parameters of type ClientIdentification Constructor Description CommandChannelImpl(ClientIdentification clientIdentification, String context, int permits, int permitsBatch, ScheduledExecutorService executor, AxonServerManagedChannel channel)Constructs aCommandChannelImpl. -
Uses of ClientIdentification in io.axoniq.axonserver.connector.event.impl
Constructors in io.axoniq.axonserver.connector.event.impl with parameters of type ClientIdentification Constructor Description BufferedEventStream(ClientIdentification clientId, long trackingToken, int bufferSize, int refillBatch, boolean forceReadFromLeader)DcbEventChannelImpl(ClientIdentification clientIdentification, ScheduledExecutorService executor, AxonServerManagedChannel axonServerManagedChannel)Instantiate anAbstractAxonServerChannel.EventChannelImpl(ClientIdentification clientIdentification, ScheduledExecutorService executor, AxonServerManagedChannel channel)Constructs aEventChannelImpl.PersistentStreamImpl(ClientIdentification clientId, String streamId, int bufferSize, int refillBatch, PersistentStreamCallbacks callbacks)Constructs aPersistentStreamImpl.SnapshotChannelImpl(ClientIdentification clientIdentification, ScheduledExecutorService executor, AxonServerManagedChannel axonServerManagedChannel)Instantiate anAbstractAxonServerChannel. -
Uses of ClientIdentification in io.axoniq.axonserver.connector.event.transformation.impl
Constructors in io.axoniq.axonserver.connector.event.transformation.impl with parameters of type ClientIdentification Constructor Description EventTransformationChannelImpl(ClientIdentification clientIdentification, ScheduledExecutorService executor, AxonServerManagedChannel axonServerManagedChannel)Constructs an instance based on aGrpcEventTransformationService. -
Uses of ClientIdentification in io.axoniq.axonserver.connector.impl
Constructors in io.axoniq.axonserver.connector.impl with parameters of type ClientIdentification Constructor Description AbstractAxonServerChannel(ClientIdentification clientIdentification, ScheduledExecutorService executor, AxonServerManagedChannel axonServerManagedChannel)Instantiate anAbstractAxonServerChannel.AxonServerManagedChannel(List<ServerAddress> routingServers, ReconnectConfiguration reconnectConfiguration, String context, ClientIdentification clientIdentification, ScheduledExecutorService executor, BiFunction<ServerAddress,String,io.grpc.ManagedChannel> connectionFactory)Constructs aAxonServerManagedChannel.ContextConnection(ClientIdentification clientIdentification, ScheduledExecutorService executorService, AxonServerManagedChannel connection, long processorInfoUpdateFrequency, int commandPermits, int queryPermits, String context, Consumer<ContextConnection> onShutdown)Construct aContextConnectioncarrying context information.ControlChannelImpl(ClientIdentification clientIdentification, String context, ScheduledExecutorService executor, AxonServerManagedChannel channel, long processorInfoUpdateFrequency, Runnable reconnectHandler)Constructs aControlChannelImpl. -
Uses of ClientIdentification in io.axoniq.axonserver.connector.query.impl
Constructors in io.axoniq.axonserver.connector.query.impl with parameters of type ClientIdentification Constructor Description QueryChannelImpl(ClientIdentification clientIdentification, String context, int permits, int permitsBatch, ScheduledExecutorService executor, AxonServerManagedChannel channel)Constructs aQueryChannelImpl. -
Uses of ClientIdentification in io.axoniq.axonserver.grpc.control
Methods in io.axoniq.axonserver.grpc.control that return ClientIdentification Modifier and Type Method Description ClientIdentificationClientIdentification.Builder. build()ClientIdentificationClientIdentification.Builder. buildPartial()static ClientIdentificationClientIdentification. getDefaultInstance()ClientIdentificationClientIdentification.Builder. getDefaultInstanceForType()ClientIdentificationClientIdentification. getDefaultInstanceForType()ClientIdentificationPlatformInboundInstruction.Builder. getRegister()Information about the client being connected.ClientIdentificationPlatformInboundInstruction. getRegister()Information about the client being connected.ClientIdentificationPlatformInboundInstructionOrBuilder. getRegister()Information about the client being connected.static ClientIdentificationClientIdentification. parseDelimitedFrom(InputStream input)static ClientIdentificationClientIdentification. parseDelimitedFrom(InputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry)static ClientIdentificationClientIdentification. parseFrom(byte[] data)static ClientIdentificationClientIdentification. parseFrom(byte[] data, com.google.protobuf.ExtensionRegistryLite extensionRegistry)static ClientIdentificationClientIdentification. parseFrom(com.google.protobuf.ByteString data)static ClientIdentificationClientIdentification. parseFrom(com.google.protobuf.ByteString data, com.google.protobuf.ExtensionRegistryLite extensionRegistry)static ClientIdentificationClientIdentification. parseFrom(com.google.protobuf.CodedInputStream input)static ClientIdentificationClientIdentification. parseFrom(com.google.protobuf.CodedInputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry)static ClientIdentificationClientIdentification. parseFrom(InputStream input)static ClientIdentificationClientIdentification. parseFrom(InputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry)static ClientIdentificationClientIdentification. parseFrom(ByteBuffer data)static ClientIdentificationClientIdentification. parseFrom(ByteBuffer data, com.google.protobuf.ExtensionRegistryLite extensionRegistry)Methods in io.axoniq.axonserver.grpc.control that return types with arguments of type ClientIdentification Modifier and Type Method Description static io.grpc.MethodDescriptor<ClientIdentification,PlatformInfo>PlatformServiceGrpc. getGetPlatformServerMethod()com.google.protobuf.Parser<ClientIdentification>ClientIdentification. getParserForType()static com.google.protobuf.Parser<ClientIdentification>ClientIdentification. parser()Methods in io.axoniq.axonserver.grpc.control with parameters of type ClientIdentification Modifier and Type Method Description default voidPlatformServiceGrpc.AsyncService. getPlatformServer(ClientIdentification request, io.grpc.stub.StreamObserver<PlatformInfo> responseObserver)Obtains connection information for the Server that a Client should use for its connections.PlatformInfoPlatformServiceGrpc.PlatformServiceBlockingStub. getPlatformServer(ClientIdentification request)Obtains connection information for the Server that a Client should use for its connections.PlatformInfoPlatformServiceGrpc.PlatformServiceBlockingV2Stub. getPlatformServer(ClientIdentification request)Obtains connection information for the Server that a Client should use for its connections.com.google.common.util.concurrent.ListenableFuture<PlatformInfo>PlatformServiceGrpc.PlatformServiceFutureStub. getPlatformServer(ClientIdentification request)Obtains connection information for the Server that a Client should use for its connections.voidPlatformServiceGrpc.PlatformServiceStub. getPlatformServer(ClientIdentification request, io.grpc.stub.StreamObserver<PlatformInfo> responseObserver)Obtains connection information for the Server that a Client should use for its connections.ClientIdentification.BuilderClientIdentification.Builder. mergeFrom(ClientIdentification other)PlatformInboundInstruction.BuilderPlatformInboundInstruction.Builder. mergeRegister(ClientIdentification value)Information about the client being connected.static ClientIdentification.BuilderClientIdentification. newBuilder(ClientIdentification prototype)PlatformInboundInstruction.BuilderPlatformInboundInstruction.Builder. setRegister(ClientIdentification value)Information about the client being connected.
-