Class RedisDataSource

java.lang.Object
io.vertx.mutiny.servicediscovery.types.RedisDataSource
All Implemented Interfaces:
MutinyDelegate

public class RedisDataSource extends Object implements MutinyDelegate
Service type for Redis data source.

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

  • Field Details

  • Constructor Details

    • RedisDataSource

      public RedisDataSource(io.vertx.servicediscovery.types.RedisDataSource delegate)
    • RedisDataSource

      public RedisDataSource(Object delegate)
  • Method Details

    • getDelegate

      public io.vertx.servicediscovery.types.RedisDataSource getDelegate()
      Specified by:
      getDelegate in interface MutinyDelegate
      Returns:
      the delegate used by this Mutiny object of generated type
    • 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
    • createRecord

      public static io.vertx.servicediscovery.Record createRecord(String name, io.vertx.core.json.JsonObject location, io.vertx.core.json.JsonObject metadata)
      Parameters:
      name - the service name
      location - the location of the service (e.g. url, port...)
      metadata - additional metadata
      Returns:
      the created record
    • getRedisClient

      @CheckReturnValue public static io.smallrye.mutiny.Uni<Redis> getRedisClient(ServiceDiscovery discovery, io.vertx.core.json.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.

      Unlike the bare Vert.x variant, this method returns a Uni. Don't forget to subscribe on it to trigger the operation.

      Parameters:
      discovery - The service discovery instance
      filter - The filter, optional
      Returns:
      the uni firing the result of the operation when completed, or a failure if the operation failed.
    • getRedisClientAndAwait

      public static Redis getRedisClientAndAwait(ServiceDiscovery discovery, io.vertx.core.json.JsonObject filter)
      Blocking variant of getRedisClient(io.vertx.mutiny.servicediscovery.ServiceDiscovery,JsonObject).

      This method waits for the completion of the underlying asynchronous operation. If the operation completes successfully, the result is returned, otherwise the failure is thrown (potentially wrapped in a RuntimeException).

      Parameters:
      discovery - The service discovery instance
      filter - The filter, optional
      Returns:
      the Redis instance produced by the operation.
    • getRedisClientAndForget

      public static void getRedisClientAndForget(ServiceDiscovery discovery, io.vertx.core.json.JsonObject filter)
      Variant of getRedisClient(io.vertx.mutiny.servicediscovery.ServiceDiscovery,JsonObject) that ignores the result of the operation.

      This method subscribes on the result of getRedisClient(io.vertx.mutiny.servicediscovery.ServiceDiscovery,JsonObject), but discards the outcome (item or failure). This method is useful to trigger the asynchronous operation from getRedisClient(io.vertx.mutiny.servicediscovery.ServiceDiscovery,JsonObject) but you don't need to compose it with other operations.

      Parameters:
      discovery - The service discovery instance
      filter - The filter, optional
    • getRedisClient

      @CheckReturnValue public static io.smallrye.mutiny.Uni<Redis> getRedisClient(ServiceDiscovery discovery, Function<io.vertx.servicediscovery.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.

      Unlike the bare Vert.x variant, this method returns a Uni. Don't forget to subscribe on it to trigger the operation.

      Parameters:
      discovery - The service discovery instance
      filter - The filter, cannot be null
      Returns:
      the uni firing the result of the operation when completed, or a failure if the operation failed.
    • getRedisClientAndAwait

      public static Redis getRedisClientAndAwait(ServiceDiscovery discovery, Function<io.vertx.servicediscovery.Record,Boolean> filter)
      Blocking variant of getRedisClient(io.vertx.mutiny.servicediscovery.ServiceDiscovery,Function).

      This method waits for the completion of the underlying asynchronous operation. If the operation completes successfully, the result is returned, otherwise the failure is thrown (potentially wrapped in a RuntimeException).

      Parameters:
      discovery - The service discovery instance
      filter - The filter, cannot be null
      Returns:
      the Redis instance produced by the operation.
    • getRedisClientAndForget

      public static void getRedisClientAndForget(ServiceDiscovery discovery, Function<io.vertx.servicediscovery.Record,Boolean> filter)
      Variant of getRedisClient(io.vertx.mutiny.servicediscovery.ServiceDiscovery,Function) that ignores the result of the operation.

      This method subscribes on the result of getRedisClient(io.vertx.mutiny.servicediscovery.ServiceDiscovery,Function), but discards the outcome (item or failure). This method is useful to trigger the asynchronous operation from getRedisClient(io.vertx.mutiny.servicediscovery.ServiceDiscovery,Function) but you don't need to compose it with other operations.

      Parameters:
      discovery - The service discovery instance
      filter - The filter, cannot be null
    • getRedisClient

      @CheckReturnValue public static io.smallrye.mutiny.Uni<Redis> getRedisClient(ServiceDiscovery discovery, io.vertx.core.json.JsonObject filter, io.vertx.core.json.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.

      Unlike the bare Vert.x variant, this method returns a Uni. Don't forget to subscribe on it to trigger the operation.

      Parameters:
      discovery - The service discovery instance
      filter - The filter, optional
      consumerConfiguration - The additional consumer configuration
      Returns:
      the uni firing the result of the operation when completed, or a failure if the operation failed.
    • getRedisClientAndAwait

      public static Redis getRedisClientAndAwait(ServiceDiscovery discovery, io.vertx.core.json.JsonObject filter, io.vertx.core.json.JsonObject consumerConfiguration)
      Blocking variant of getRedisClient(io.vertx.mutiny.servicediscovery.ServiceDiscovery,JsonObject,JsonObject).

      This method waits for the completion of the underlying asynchronous operation. If the operation completes successfully, the result is returned, otherwise the failure is thrown (potentially wrapped in a RuntimeException).

      Parameters:
      discovery - The service discovery instance
      filter - The filter, optional
      consumerConfiguration - The additional consumer configuration
      Returns:
      the Redis instance produced by the operation.
    • getRedisClientAndForget

      public static void getRedisClientAndForget(ServiceDiscovery discovery, io.vertx.core.json.JsonObject filter, io.vertx.core.json.JsonObject consumerConfiguration)
      Variant of getRedisClient(io.vertx.mutiny.servicediscovery.ServiceDiscovery,JsonObject,JsonObject) that ignores the result of the operation.

      This method subscribes on the result of getRedisClient(io.vertx.mutiny.servicediscovery.ServiceDiscovery,JsonObject,JsonObject), but discards the outcome (item or failure). This method is useful to trigger the asynchronous operation from getRedisClient(io.vertx.mutiny.servicediscovery.ServiceDiscovery,JsonObject,JsonObject) but you don't need to compose it with other operations.

      Parameters:
      discovery - The service discovery instance
      filter - The filter, optional
      consumerConfiguration - The additional consumer configuration
    • getRedisClient

      @CheckReturnValue public static io.smallrye.mutiny.Uni<Redis> getRedisClient(ServiceDiscovery discovery, Function<io.vertx.servicediscovery.Record,Boolean> filter, io.vertx.core.json.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.

      Unlike the bare Vert.x variant, this method returns a Uni. Don't forget to subscribe on it to trigger the operation.

      Parameters:
      discovery - The service discovery instance
      filter - The filter, cannot be null
      consumerConfiguration - The additional consumer configuration
      Returns:
      the uni firing the result of the operation when completed, or a failure if the operation failed.
    • getRedisClientAndAwait

      public static Redis getRedisClientAndAwait(ServiceDiscovery discovery, Function<io.vertx.servicediscovery.Record,Boolean> filter, io.vertx.core.json.JsonObject consumerConfiguration)
      Blocking variant of getRedisClient(io.vertx.mutiny.servicediscovery.ServiceDiscovery,Function,JsonObject).

      This method waits for the completion of the underlying asynchronous operation. If the operation completes successfully, the result is returned, otherwise the failure is thrown (potentially wrapped in a RuntimeException).

      Parameters:
      discovery - The service discovery instance
      filter - The filter, cannot be null
      consumerConfiguration - The additional consumer configuration
      Returns:
      the Redis instance produced by the operation.
    • getRedisClientAndForget

      public static void getRedisClientAndForget(ServiceDiscovery discovery, Function<io.vertx.servicediscovery.Record,Boolean> filter, io.vertx.core.json.JsonObject consumerConfiguration)
      Variant of getRedisClient(io.vertx.mutiny.servicediscovery.ServiceDiscovery,Function,JsonObject) that ignores the result of the operation.

      This method subscribes on the result of getRedisClient(io.vertx.mutiny.servicediscovery.ServiceDiscovery,Function,JsonObject), but discards the outcome (item or failure). This method is useful to trigger the asynchronous operation from getRedisClient(io.vertx.mutiny.servicediscovery.ServiceDiscovery,Function,JsonObject) but you don't need to compose it with other operations.

      Parameters:
      discovery - The service discovery instance
      filter - The filter, cannot be null
      consumerConfiguration - The additional consumer configuration
    • newInstance

      public static RedisDataSource newInstance(io.vertx.servicediscovery.types.RedisDataSource arg)