Class HttpClient5StorageNodeClient

  • All Implemented Interfaces:
    StorageNodeClient,, java.lang.AutoCloseable

    public class HttpClient5StorageNodeClient
    extends java.lang.Object
    implements StorageNodeClient
    • Constructor Detail

      • HttpClient5StorageNodeClient

        public HttpClient5StorageNodeClient​(java.util.Optional<SSLFactory> sslFactory,
                                            VeniceRouterConfig routerConfig)
    • Method Detail

      • close

        public void close()
        Description copied from interface: StorageNodeClient
        Close the client and release all resources held by the client
        Specified by:
        close in interface java.lang.AutoCloseable
        Specified by:
        close in interface
        Specified by:
        close in interface StorageNodeClient
      • query

        public void query​(Instance host,
                          VenicePath path,
                          java.util.function.Consumer<PortableHttpResponse> completedCallBack,
                          java.util.function.Consumer<java.lang.Throwable> failedCallBack,
                          java.util.function.BooleanSupplier cancelledCallBack)
                   throws RouterException
        Description copied from interface: StorageNodeClient
        Send a request to storage node
        Specified by:
        query in interface StorageNodeClient
        host - The target host to which the request will be sent
        path - contains information like URI, request content, HTTP method, etc.
        completedCallBack - Callback function for a complete response
        failedCallBack - if any exception thrown in the channel
        cancelledCallBack - for requests that are cancelled by the channel