Class: VertxServiceDiscovery::RedisDataSource

Inherits:
Object
  • Object
show all
Defined in:
/Users/julien/java/vertx-aggregator/modules/vertx-lang-ruby/vertx-lang-ruby/target/classes/vertx-service-discovery/redis_data_source.rb

Overview

Service type for Redis data source.

Constant Summary

@@j_api_type =
Object.new

Class Method Summary (collapse)

Class Method Details

+ (Boolean) accept?(obj)

Returns:

  • (Boolean)


20
21
22
# File '/Users/julien/java/vertx-aggregator/modules/vertx-lang-ruby/vertx-lang-ruby/target/classes/vertx-service-discovery/redis_data_source.rb', line 20

def @@j_api_type.accept?(obj)
  obj.class == RedisDataSource
end

+ (Hash{String => Object}) createRecord(name, location, metadata)

Convenient method to create a record for a Redis data source.

Parameters:

  • name (String)
    the service name
  • location (Hash{String => Object})
    the location of the service (e.g. url, port...)
  • metadata (Hash{String => Object})
    additional metadata

Returns:

  • (Hash{String => Object})
    the created record


102
103
104
105
106
107
108
109
110
111
# File '/Users/julien/java/vertx-aggregator/modules/vertx-lang-ruby/vertx-lang-ruby/target/classes/vertx-service-discovery/redis_data_source.rb', line 102

def self.create_record(*args)
  if args[0].class == String && args[1].class == Hash && args[2].class == Hash && !block_given?
    return Java::IoVertxServicediscoveryTypes::RedisDataSource.java_method(:createRecord, [Java::java.lang.String.java_class,Java::IoVertxCoreJson::JsonObject.java_class,Java::IoVertxCoreJson::JsonObject.java_class]).call(args[0],::Vertx::Util::Utils.to_json_object(args[1]),::Vertx::Util::Utils.to_json_object(args[2])) != nil ? JSON.parse(Java::IoVertxServicediscoveryTypes::RedisDataSource.java_method(:createRecord, [Java::java.lang.String.java_class,Java::IoVertxCoreJson::JsonObject.java_class,Java::IoVertxCoreJson::JsonObject.java_class]).call(args[0],::Vertx::Util::Utils.to_json_object(args[1]),::Vertx::Util::Utils.to_json_object(args[2])).toJson.encode) : nil
  end
  if defined?(super)
    super
  else
    raise ArgumentError, "Invalid arguments when calling create_record(#{args[0]},#{args[1]},#{args[2]})"
  end
end

+ (void) getRedisClient(discovery, filter, resultHandler) { ... } + (void) getRedisClient(discovery, filter, resultHandler) { ... } + (void) getRedisClient(discovery, filter, consumerConfiguration, resultHandler) { ... } + (void) getRedisClient(discovery, filter, consumerConfiguration, resultHandler) { ... }

This method returns an undefined value.

Convenient method that looks for a Redis data source and provides the configured VertxRedis::Redis. The async result is marked as failed is there are no matching services, or if the lookup fails.

Overloads:

  • + (void) getRedisClient(discovery, filter, resultHandler) { ... }

    Parameters:

    Yields:

    • The result handler
  • + (void) getRedisClient(discovery, filter, resultHandler) { ... }

    Parameters:

    Yields:

    • The result handler
  • + (void) getRedisClient(discovery, filter, consumerConfiguration, resultHandler) { ... }

    Parameters:

    • discovery (::VertxServiceDiscovery::ServiceDiscovery)
      The service discovery instance
    • filter (Hash{String => Object})
      The filter, optional
    • consumerConfiguration (Hash{String => Object})
      The additional consumer configuration

    Yields:

    • The result handler
  • + (void) getRedisClient(discovery, filter, consumerConfiguration, resultHandler) { ... }

    Parameters:

    • discovery (::VertxServiceDiscovery::ServiceDiscovery)
      The service discovery instance
    • filter (Proc)
      The filter, cannot be null
    • consumerConfiguration (Hash{String => Object})
      The additional consumer configuration

    Yields:

    • The result handler


56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
# File '/Users/julien/java/vertx-aggregator/modules/vertx-lang-ruby/vertx-lang-ruby/target/classes/vertx-service-discovery/redis_data_source.rb', line 56

def self.get_redis_client(*args)
  if args[0].class.method_defined?(:j_del) && args[1].class == Hash && true && args[2] == nil
    if (block_given?)
      return Java::IoVertxServicediscoveryTypes::RedisDataSource.java_method(:getRedisClient, [Java::IoVertxServicediscovery::ServiceDiscovery.java_class,Java::IoVertxCoreJson::JsonObject.java_class,Java::IoVertxCore::Handler.java_class]).call(args[0].j_del,::Vertx::Util::Utils.to_json_object(args[1]),block_given? ? Proc.new { |ar| yield(ar.failed ? ar.cause : nil, ar.succeeded ? ::Vertx::Util::Utils.safe_create(ar.result,::VertxRedis::Redis) : nil) } : promise)
    else
      promise = ::Vertx::Util::Utils.promise
      Java::IoVertxServicediscoveryTypes::RedisDataSource.java_method(:getRedisClient, [Java::IoVertxServicediscovery::ServiceDiscovery.java_class,Java::IoVertxCoreJson::JsonObject.java_class,Java::IoVertxCore::Handler.java_class]).call(args[0].j_del,::Vertx::Util::Utils.to_json_object(args[1]),block_given? ? Proc.new { |ar| yield(ar.failed ? ar.cause : nil, ar.succeeded ? ::Vertx::Util::Utils.safe_create(ar.result,::VertxRedis::Redis) : nil) } : promise)
      return ::Vertx::Util::Utils.safe_create(promise.future(),::Vertx::Future,::VertxRedis::Redis.j_api_type)
    end
  elsif args[0].class.method_defined?(:j_del) && args[1].class == Proc && true && args[2] == nil
    if (block_given?)
      return Java::IoVertxServicediscoveryTypes::RedisDataSource.java_method(:getRedisClient, [Java::IoVertxServicediscovery::ServiceDiscovery.java_class,Java::JavaUtilFunction::Function.java_class,Java::IoVertxCore::Handler.java_class]).call(args[0].j_del,(Proc.new { |event| args[1].call(event != nil ? JSON.parse(event.toJson.encode) : nil) unless args[1] == nil }),block_given? ? Proc.new { |ar| yield(ar.failed ? ar.cause : nil, ar.succeeded ? ::Vertx::Util::Utils.safe_create(ar.result,::VertxRedis::Redis) : nil) } : promise)
    else
      promise = ::Vertx::Util::Utils.promise
      Java::IoVertxServicediscoveryTypes::RedisDataSource.java_method(:getRedisClient, [Java::IoVertxServicediscovery::ServiceDiscovery.java_class,Java::JavaUtilFunction::Function.java_class,Java::IoVertxCore::Handler.java_class]).call(args[0].j_del,(Proc.new { |event| args[1].call(event != nil ? JSON.parse(event.toJson.encode) : nil) unless args[1] == nil }),block_given? ? Proc.new { |ar| yield(ar.failed ? ar.cause : nil, ar.succeeded ? ::Vertx::Util::Utils.safe_create(ar.result,::VertxRedis::Redis) : nil) } : promise)
      return ::Vertx::Util::Utils.safe_create(promise.future(),::Vertx::Future,::VertxRedis::Redis.j_api_type)
    end
  elsif args[0].class.method_defined?(:j_del) && args[1].class == Hash && args[2].class == Hash && true
    if (block_given?)
      return Java::IoVertxServicediscoveryTypes::RedisDataSource.java_method(:getRedisClient, [Java::IoVertxServicediscovery::ServiceDiscovery.java_class,Java::IoVertxCoreJson::JsonObject.java_class,Java::IoVertxCoreJson::JsonObject.java_class,Java::IoVertxCore::Handler.java_class]).call(args[0].j_del,::Vertx::Util::Utils.to_json_object(args[1]),::Vertx::Util::Utils.to_json_object(args[2]),block_given? ? Proc.new { |ar| yield(ar.failed ? ar.cause : nil, ar.succeeded ? ::Vertx::Util::Utils.safe_create(ar.result,::VertxRedis::Redis) : nil) } : promise)
    else
      promise = ::Vertx::Util::Utils.promise
      Java::IoVertxServicediscoveryTypes::RedisDataSource.java_method(:getRedisClient, [Java::IoVertxServicediscovery::ServiceDiscovery.java_class,Java::IoVertxCoreJson::JsonObject.java_class,Java::IoVertxCoreJson::JsonObject.java_class,Java::IoVertxCore::Handler.java_class]).call(args[0].j_del,::Vertx::Util::Utils.to_json_object(args[1]),::Vertx::Util::Utils.to_json_object(args[2]),block_given? ? Proc.new { |ar| yield(ar.failed ? ar.cause : nil, ar.succeeded ? ::Vertx::Util::Utils.safe_create(ar.result,::VertxRedis::Redis) : nil) } : promise)
      return ::Vertx::Util::Utils.safe_create(promise.future(),::Vertx::Future,::VertxRedis::Redis.j_api_type)
    end
  elsif args[0].class.method_defined?(:j_del) && args[1].class == Proc && args[2].class == Hash && true
    if (block_given?)
      return Java::IoVertxServicediscoveryTypes::RedisDataSource.java_method(:getRedisClient, [Java::IoVertxServicediscovery::ServiceDiscovery.java_class,Java::JavaUtilFunction::Function.java_class,Java::IoVertxCoreJson::JsonObject.java_class,Java::IoVertxCore::Handler.java_class]).call(args[0].j_del,(Proc.new { |event| args[1].call(event != nil ? JSON.parse(event.toJson.encode) : nil) unless args[1] == nil }),::Vertx::Util::Utils.to_json_object(args[2]),block_given? ? Proc.new { |ar| yield(ar.failed ? ar.cause : nil, ar.succeeded ? ::Vertx::Util::Utils.safe_create(ar.result,::VertxRedis::Redis) : nil) } : promise)
    else
      promise = ::Vertx::Util::Utils.promise
      Java::IoVertxServicediscoveryTypes::RedisDataSource.java_method(:getRedisClient, [Java::IoVertxServicediscovery::ServiceDiscovery.java_class,Java::JavaUtilFunction::Function.java_class,Java::IoVertxCoreJson::JsonObject.java_class,Java::IoVertxCore::Handler.java_class]).call(args[0].j_del,(Proc.new { |event| args[1].call(event != nil ? JSON.parse(event.toJson.encode) : nil) unless args[1] == nil }),::Vertx::Util::Utils.to_json_object(args[2]),block_given? ? Proc.new { |ar| yield(ar.failed ? ar.cause : nil, ar.succeeded ? ::Vertx::Util::Utils.safe_create(ar.result,::VertxRedis::Redis) : nil) } : promise)
      return ::Vertx::Util::Utils.safe_create(promise.future(),::Vertx::Future,::VertxRedis::Redis.j_api_type)
    end
  end
  if defined?(super)
    super
  else
    raise ArgumentError, "Invalid arguments when calling get_redis_client(#{args[0]},#{args[1]},#{args[2]})"
  end
end

+ (Object) j_api_type



29
30
31
# File '/Users/julien/java/vertx-aggregator/modules/vertx-lang-ruby/vertx-lang-ruby/target/classes/vertx-service-discovery/redis_data_source.rb', line 29

def self.j_api_type
  @@j_api_type
end

+ (Object) j_class



32
33
34
# File '/Users/julien/java/vertx-aggregator/modules/vertx-lang-ruby/vertx-lang-ruby/target/classes/vertx-service-discovery/redis_data_source.rb', line 32

def self.j_class
  Java::IoVertxServicediscoveryTypes::RedisDataSource.java_class
end

+ (Object) TYPE



116
117
118
# File '/Users/julien/java/vertx-aggregator/modules/vertx-lang-ruby/vertx-lang-ruby/target/classes/vertx-service-discovery/redis_data_source.rb', line 116

def self.TYPE
  Java::IoVertxServicediscoveryTypes::RedisDataSource.TYPE
end

+ (Object) UNKNOWN

Unknown type.


113
114
115
# File '/Users/julien/java/vertx-aggregator/modules/vertx-lang-ruby/vertx-lang-ruby/target/classes/vertx-service-discovery/redis_data_source.rb', line 113

def self.UNKNOWN
  Java::IoVertxServicediscoveryTypes::RedisDataSource.UNKNOWN
end

+ (Object) unwrap(obj)



26
27
28
# File '/Users/julien/java/vertx-aggregator/modules/vertx-lang-ruby/vertx-lang-ruby/target/classes/vertx-service-discovery/redis_data_source.rb', line 26

def @@j_api_type.unwrap(obj)
  obj.j_del
end

+ (Object) wrap(obj)



23
24
25
# File '/Users/julien/java/vertx-aggregator/modules/vertx-lang-ruby/vertx-lang-ruby/target/classes/vertx-service-discovery/redis_data_source.rb', line 23

def @@j_api_type.wrap(obj)
  RedisDataSource.new(obj)
end