Class HttpEndpoint

java.lang.Object
io.vertx.reactivex.servicediscovery.types.HttpEndpoint
All Implemented Interfaces:
io.vertx.lang.rx.RxDelegate
public class HttpEndpoint extends Object implements io.vertx.lang.rx.RxDelegate
for HTTP endpoint (REST api). Consumers receive a HTTP client configured with the host and port of the endpoint.

NOTE: This class has been automatically generated from the original non RX-ified interface using Vert.x codegen.

  • Field Details

  • Constructor Details

    • HttpEndpoint

      public HttpEndpoint(HttpEndpoint delegate)

    • HttpEndpoint

      public HttpEndpoint(Object delegate)

  • Method Details

    • toString

      public String toString()
      Overrides:
      toString in class Object

    • equals

      public boolean equals(Object o)
      Overrides:
      equals in class Object

    • hashCode

      public int hashCode()
      Overrides:
      hashCode in class Object

    • getDelegate

      public HttpEndpoint getDelegate()
      Specified by:
      getDelegate in interface io.vertx.lang.rx.RxDelegate

    • createRecord

      public static Record createRecord(String name, String host, int port, String root, JsonObject metadata)
      Convenient method to create a record for a HTTP endpoint.
      Parameters:
      name - the service name
      host - the host (IP or DNS name), it must be the _public_ IP / name
      port - the port, it must be the _public_ port
      root - the path of the service, "/" if not set
      metadata - additional metadata
      Returns:
      the created record

    • createRecord

      public static Record createRecord(String name, boolean ssl, String host, int port, String root, JsonObject metadata)
      Same as createRecord(String, String, int, String, JsonObject) but let you configure whether or not the service is using https.
      Parameters:
      name - the service name
      ssl - whether or not the service is using HTTPS
      host - the host (IP or DNS name), it must be the _public_ IP / name
      port - the port, it must be the _public_ port
      root - the path of the service, "/" if not set
      metadata - additional metadata
      Returns:
      the created record

    • createRecord

      public static Record createRecord(String name, String host, int port, String root)
      Same as createRecord(String, String, int, String, JsonObject) but without metadata.
      Parameters:
      name - the service name
      host - the host, must be public
      port - the port
      root - the root, if not set "/" is used
      Returns:
      the created record

    • createRecord

      public static Record createRecord(String name, String host)
      Same as createRecord(String, String, int, String, JsonObject) but without metadata, using the port 80 and using "/" as root.
      Parameters:
      name - the name
      host - the host
      Returns:
      the created record

    • getClient

      public static Future<HttpClient> getClient(ServiceDiscovery discovery, JsonObject filter)
      Convenient method that looks for a HTTP endpoint and provides the configured . The async result is marked as failed is there are no matching services, or if the lookup fails.
      Parameters:
      discovery - The service discovery instance
      filter - The filter, optional
      Returns:
      a future notified with the client

    • rxGetClient

      public static Single<HttpClient> rxGetClient(ServiceDiscovery discovery, JsonObject filter)
      Convenient method that looks for a HTTP endpoint and provides the configured . The async result is marked as failed is there are no matching services, or if the lookup fails.
      Parameters:
      discovery - The service discovery instance
      filter - The filter, optional
      Returns:
      a future notified with the client

    • getWebClient

      public static Future<WebClient> getWebClient(ServiceDiscovery discovery, JsonObject filter)
      Convenient method that looks for a HTTP endpoint and provides the configured . The async result is marked as failed is there are no matching services, or if the lookup fails.
      Parameters:
      discovery - The service discovery instance
      filter - The filter, optional
      Returns:
      a future notified with the client

    • rxGetWebClient

      public static Single<WebClient> rxGetWebClient(ServiceDiscovery discovery, JsonObject filter)
      Convenient method that looks for a HTTP endpoint and provides the configured . The async result is marked as failed is there are no matching services, or if the lookup fails.
      Parameters:
      discovery - The service discovery instance
      filter - The filter, optional
      Returns:
      a future notified with the client

    • getClient

      public static Future<HttpClient> getClient(ServiceDiscovery discovery, JsonObject filter, JsonObject conf)
      Convenient method that looks for a HTTP endpoint and provides the configured . The async result is marked as failed is there are no matching services, or if the lookup fails. This method accepts a configuration for the HTTP client
      Parameters:
      discovery - The service discovery instance
      filter - The filter, optional
      conf - the configuration of the client
      Returns:
      a future notified with the client

    • rxGetClient

      public static Single<HttpClient> rxGetClient(ServiceDiscovery discovery, JsonObject filter, JsonObject conf)
      Convenient method that looks for a HTTP endpoint and provides the configured . The async result is marked as failed is there are no matching services, or if the lookup fails. This method accepts a configuration for the HTTP client
      Parameters:
      discovery - The service discovery instance
      filter - The filter, optional
      conf - the configuration of the client
      Returns:
      a future notified with the client

    • getWebClient

      public static Future<WebClient> getWebClient(ServiceDiscovery discovery, JsonObject filter, JsonObject conf)
      Convenient method that looks for a HTTP endpoint and provides the configured . The async result is marked as failed is there are no matching services, or if the lookup fails. This method accepts a configuration for the HTTP client
      Parameters:
      discovery - The service discovery instance
      filter - The filter, optional
      conf - the configuration of the client
      Returns:
      a future notified with the client

    • rxGetWebClient

      public static Single<WebClient> rxGetWebClient(ServiceDiscovery discovery, JsonObject filter, JsonObject conf)
      Convenient method that looks for a HTTP endpoint and provides the configured . The async result is marked as failed is there are no matching services, or if the lookup fails. This method accepts a configuration for the HTTP client
      Parameters:
      discovery - The service discovery instance
      filter - The filter, optional
      conf - the configuration of the client
      Returns:
      a future notified with the client

    • getClient

      public static Future<HttpClient> getClient(ServiceDiscovery discovery, Function<Record,Boolean> filter)
      Convenient method that looks for a HTTP endpoint and provides the configured . The async result is marked as failed is there are no matching services, or if the lookup fails.
      Parameters:
      discovery - The service discovery instance
      filter - The filter
      Returns:
      a future notified with the client

    • rxGetClient

      public static Single<HttpClient> rxGetClient(ServiceDiscovery discovery, Function<Record,Boolean> filter)
      Convenient method that looks for a HTTP endpoint and provides the configured . The async result is marked as failed is there are no matching services, or if the lookup fails.
      Parameters:
      discovery - The service discovery instance
      filter - The filter
      Returns:
      a future notified with the client

    • getWebClient

      public static Future<WebClient> getWebClient(ServiceDiscovery discovery, Function<Record,Boolean> filter)
      Convenient method that looks for a HTTP endpoint and provides the configured . The async result is marked as failed is there are no matching services, or if the lookup fails.
      Parameters:
      discovery - The service discovery instance
      filter - The filter
      Returns:
      a future notified with the client

    • rxGetWebClient

      public static Single<WebClient> rxGetWebClient(ServiceDiscovery discovery, Function<Record,Boolean> filter)
      Convenient method that looks for a HTTP endpoint and provides the configured . The async result is marked as failed is there are no matching services, or if the lookup fails.
      Parameters:
      discovery - The service discovery instance
      filter - The filter
      Returns:
      a future notified with the client

    • getClient

      public static Future<HttpClient> getClient(ServiceDiscovery discovery, Function<Record,Boolean> filter, JsonObject conf)
      Convenient method that looks for a HTTP endpoint and provides the configured . The async result is marked as failed is there are no matching services, or if the lookup fails. This method accepts a configuration for the HTTP client.
      Parameters:
      discovery - The service discovery instance
      filter - The filter
      conf - the configuration of the client
      Returns:
      a future notified with the client

    • rxGetClient

      public static Single<HttpClient> rxGetClient(ServiceDiscovery discovery, Function<Record,Boolean> filter, JsonObject conf)
      Convenient method that looks for a HTTP endpoint and provides the configured . The async result is marked as failed is there are no matching services, or if the lookup fails. This method accepts a configuration for the HTTP client.
      Parameters:
      discovery - The service discovery instance
      filter - The filter
      conf - the configuration of the client
      Returns:
      a future notified with the client

    • getWebClient

      public static Future<WebClient> getWebClient(ServiceDiscovery discovery, Function<Record,Boolean> filter, JsonObject conf)
      Convenient method that looks for a HTTP endpoint and provides the configured . The async result is marked as failed is there are no matching services, or if the lookup fails. This method accepts a configuration for the HTTP client.
      Parameters:
      discovery - The service discovery instance
      filter - The filter
      conf - the configuration of the client
      Returns:
      a future notified with the client

    • rxGetWebClient

      public static Single<WebClient> rxGetWebClient(ServiceDiscovery discovery, Function<Record,Boolean> filter, JsonObject conf)
      Convenient method that looks for a HTTP endpoint and provides the configured . The async result is marked as failed is there are no matching services, or if the lookup fails. This method accepts a configuration for the HTTP client.
      Parameters:
      discovery - The service discovery instance
      filter - The filter
      conf - the configuration of the client
      Returns:
      a future notified with the client

    • newInstance

      public static HttpEndpoint newInstance(HttpEndpoint arg)