Class RedisDataSource

java.lang.Object
io.vertx.reactivex.servicediscovery.types.RedisDataSource
All Implemented Interfaces:
io.vertx.lang.rx.RxDelegate
public class RedisDataSource extends Object implements io.vertx.lang.rx.RxDelegate
Service type for Redis data source.

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

  • Field Details

  • Constructor Details

    • RedisDataSource

      public RedisDataSource(RedisDataSource delegate)

    • RedisDataSource

      public RedisDataSource(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 RedisDataSource getDelegate()
      Specified by:
      getDelegate in interface io.vertx.lang.rx.RxDelegate

    • createRecord

      public static Record createRecord(String name, JsonObject location, JsonObject metadata)
      Convenient method to create a record for a Redis data source.
      Parameters:
      name - the service name
      location - the location of the service (e.g. url, port...)
      metadata - additional metadata
      Returns:
      the created record

    • getRedisClient

      public static Future<Redis> getRedisClient(ServiceDiscovery discovery, JsonObject filter)
      Convenient method that looks for a Redis data source and provides the configured Redis. 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

    • rxGetRedisClient

      public static Single<Redis> rxGetRedisClient(ServiceDiscovery discovery, JsonObject filter)
      Convenient method that looks for a Redis data source and provides the configured Redis. 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

    • getRedisClient

      public static Future<Redis> getRedisClient(ServiceDiscovery discovery, Function<Record,Boolean> filter)
      Convenient method that looks for a Redis data source and provides the configured Redis. 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, cannot be null
      Returns:
      a future notified with the client

    • rxGetRedisClient

      public static Single<Redis> rxGetRedisClient(ServiceDiscovery discovery, Function<Record,Boolean> filter)
      Convenient method that looks for a Redis data source and provides the configured Redis. 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, cannot be null
      Returns:
      a future notified with the client

    • getRedisClient

      public static Future<Redis> getRedisClient(ServiceDiscovery discovery, JsonObject filter, JsonObject consumerConfiguration)
      Convenient method that looks for a Redis data source and provides the configured Redis. 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
      consumerConfiguration - The additional consumer configuration
      Returns:
      a future notified with the client

    • rxGetRedisClient

      public static Single<Redis> rxGetRedisClient(ServiceDiscovery discovery, JsonObject filter, JsonObject consumerConfiguration)
      Convenient method that looks for a Redis data source and provides the configured Redis. 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
      consumerConfiguration - The additional consumer configuration
      Returns:
      a future notified with the client

    • getRedisClient

      public static Future<Redis> getRedisClient(ServiceDiscovery discovery, Function<Record,Boolean> filter, JsonObject consumerConfiguration)
      Convenient method that looks for a Redis data source and provides the configured Redis. 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, cannot be null
      consumerConfiguration - The additional consumer configuration
      Returns:
      a future notified with the client

    • rxGetRedisClient

      public static Single<Redis> rxGetRedisClient(ServiceDiscovery discovery, Function<Record,Boolean> filter, JsonObject consumerConfiguration)
      Convenient method that looks for a Redis data source and provides the configured Redis. 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, cannot be null
      consumerConfiguration - The additional consumer configuration
      Returns:
      a future notified with the client

    • newInstance

      public static RedisDataSource newInstance(RedisDataSource arg)