Class 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.

    • Constructor Detail

      • RedisDataSource

        public RedisDataSource​(Object delegate)
    • Method Detail

      • 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 Single<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 Single<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 Single<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 Single<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