Hierarchy For Package io.axoniq.axonserver.connector.impl

Package Hierarchies:

• All Packages

Class Hierarchy

• java.lang.Object
  • io.axoniq.axonserver.connector.impl.AbstractAxonServerChannel<OUT>
    • io.axoniq.axonserver.connector.impl.ControlChannelImpl (implements io.axoniq.axonserver.connector.control.ControlChannel)
  • io.axoniq.axonserver.connector.impl.AssertUtils
  • io.axoniq.axonserver.connector.impl.AsyncRegistration (implements io.axoniq.axonserver.connector.Registration)
  • io.axoniq.axonserver.connector.impl.AxonConnectorThreadFactory (implements java.util.concurrent.ThreadFactory)
  • io.axoniq.axonserver.connector.impl.BufferingReplyChannel<T> (implements io.axoniq.axonserver.connector.ReplyChannel<T>)
  • io.grpc.stub.CallStreamObserver<V> (implements io.grpc.stub.StreamObserver<V>)
    • io.grpc.stub.ClientCallStreamObserver<ReqT>
      • io.axoniq.axonserver.connector.impl.SynchronizedRequestStream<T>
  • io.grpc.Channel
    • io.grpc.ManagedChannel
      • io.axoniq.axonserver.connector.impl.AxonServerManagedChannel
  • io.axoniq.axonserver.connector.impl.CloseAwareReplyChannel<T> (implements io.axoniq.axonserver.connector.ReplyChannel<T>)
  • java.util.concurrent.CompletableFuture<T> (implements java.util.concurrent.CompletionStage<T>, java.util.concurrent.Future<V>)
    • io.axoniq.axonserver.connector.impl.FutureListStreamObserver<T> (implements io.grpc.stub.StreamObserver<V>)
    • io.axoniq.axonserver.connector.impl.FutureStreamObserver<T> (implements io.grpc.stub.StreamObserver<V>)
  • io.axoniq.axonserver.connector.impl.ContextConnection (implements io.axoniq.axonserver.connector.AxonServerConnection)
  • io.axoniq.axonserver.connector.impl.FlowControlledReplyChannelWriter<T> (implements io.axoniq.axonserver.connector.FlowControl)
  • io.axoniq.axonserver.connector.impl.FlowControlledStream<IN,OUT> (implements io.grpc.stub.ClientResponseObserver<ReqT,RespT>)
    • io.axoniq.axonserver.connector.impl.AbstractIncomingInstructionStream<IN,OUT>
    • io.axoniq.axonserver.connector.impl.FlowControlledBuffer<T,R>
      • io.axoniq.axonserver.connector.impl.AbstractBufferedStream<T,R> (implements io.axoniq.axonserver.connector.ResultStream<T>)
  • io.axoniq.axonserver.connector.impl.ForwardingReplyChannel<T> (implements io.axoniq.axonserver.connector.ReplyChannel<T>)
  • io.axoniq.axonserver.connector.impl.GrpcBufferingInterceptor (implements io.grpc.ClientInterceptor)
  • io.axoniq.axonserver.connector.impl.HeaderAttachingInterceptor<T> (implements io.grpc.ClientInterceptor)
  • io.axoniq.axonserver.connector.impl.Headers
  • io.axoniq.axonserver.connector.impl.HeartbeatMonitor
  • io.axoniq.axonserver.connector.impl.MessageFactory
  • io.axoniq.axonserver.connector.impl.ObjectUtils
  • io.axoniq.axonserver.connector.impl.ObjectUtils.OrElse
  • io.axoniq.axonserver.connector.impl.ProcessorInstructions
  • io.axoniq.axonserver.connector.impl.ReconnectConfiguration
  • io.axoniq.axonserver.connector.impl.ServerAddress
  • io.axoniq.axonserver.connector.impl.SyncRegistration (implements io.axoniq.axonserver.connector.Registration)
  • java.lang.Throwable (implements java.io.Serializable)
    • java.lang.Exception
      • java.lang.RuntimeException
        • io.axoniq.axonserver.connector.impl.StreamClosedException
        • io.axoniq.axonserver.connector.impl.StreamTimeoutException
        • io.axoniq.axonserver.connector.impl.StreamUnexpectedlyCompletedException

Interface Hierarchy

• io.axoniq.axonserver.connector.impl.CloseableReadonlyBuffer<T>
  • io.axoniq.axonserver.connector.impl.CloseableBuffer<T>
  • io.axoniq.axonserver.connector.impl.DisposableReadonlyBuffer<T>
• io.axoniq.axonserver.connector.impl.HeartbeatSender

Enum Hierarchy

• java.lang.Object
  • java.lang.Enum<E> (implements java.lang.Comparable<T>, java.io.Serializable)
    • io.axoniq.axonserver.connector.impl.NoopFlowControl (implements io.axoniq.axonserver.connector.FlowControl)