Class: Prefab::Client
- Inherits:
-
Object
- Object
- Prefab::Client
- Defined in:
- lib/prefab/client.rb
Constant Summary collapse
- MAX_SLEEP_SEC =
10
- BASE_SLEEP_SEC =
0.5
- NO_DEFAULT_PROVIDED =
:no_default_provided
Instance Attribute Summary collapse
-
#api_key ⇒ Object
readonly
Returns the value of attribute api_key.
-
#interceptor ⇒ Object
readonly
Returns the value of attribute interceptor.
-
#namespace ⇒ Object
readonly
Returns the value of attribute namespace.
-
#options ⇒ Object
readonly
Returns the value of attribute options.
-
#prefab_api_url ⇒ Object
readonly
Returns the value of attribute prefab_api_url.
-
#shared_cache ⇒ Object
readonly
Returns the value of attribute shared_cache.
-
#stats ⇒ Object
readonly
Returns the value of attribute stats.
Instance Method Summary collapse
- #channel ⇒ Object
- #config_client(timeout: 5.0) ⇒ Object
- #enabled?(feature_name, lookup_key = nil, attributes = {}) ⇒ Boolean
- #feature_flag_client ⇒ Object
- #get(key, default_or_lookup_key = NO_DEFAULT_PROVIDED, attributes = {}, ff_default = NO_DEFAULT_PROVIDED) ⇒ Object
-
#initialize(options = Prefab::Options.new) ⇒ Client
constructor
A new instance of Client.
- #log ⇒ Object
- #log_internal(level, msg, path = "prefab") ⇒ Object
- #ratelimit_client(timeout: 5.0) ⇒ Object
- #request(service, method, req_options: {}, params: {}) ⇒ Object
- #reset! ⇒ Object
Constructor Details
#initialize(options = Prefab::Options.new) ⇒ Client
Returns a new instance of Client.
10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 |
# File 'lib/prefab/client.rb', line 10 def initialize( = Prefab::Options.new) @options = @shared_cache = @options.shared_cache @stats = @options.stats @namespace = @options.namespace @stubs = {} if @options.local_only? log_internal Logger::INFO, "Prefab Running in Local Mode" else @api_key = @options.api_key raise Prefab::Errors::InvalidApiKeyError.new(@api_key) if @api_key.nil? || @api_key.empty? || api_key.count("-") < 1 @interceptor = Prefab::AuthInterceptor.new(@api_key) @prefab_api_url = @options.prefab_api_url @prefab_grpc_url = @options.prefab_grpc_url log_internal Logger::INFO, "Prefab Connecting to: #{@prefab_api_url} and #{@prefab_grpc_url} Secure: #{http_secure?}" at_exit do channel.destroy end end end |
Instance Attribute Details
#api_key ⇒ Object (readonly)
Returns the value of attribute api_key.
8 9 10 |
# File 'lib/prefab/client.rb', line 8 def api_key @api_key end |
#interceptor ⇒ Object (readonly)
Returns the value of attribute interceptor.
8 9 10 |
# File 'lib/prefab/client.rb', line 8 def interceptor @interceptor end |
#namespace ⇒ Object (readonly)
Returns the value of attribute namespace.
8 9 10 |
# File 'lib/prefab/client.rb', line 8 def namespace @namespace end |
#options ⇒ Object (readonly)
Returns the value of attribute options.
8 9 10 |
# File 'lib/prefab/client.rb', line 8 def @options end |
#prefab_api_url ⇒ Object (readonly)
Returns the value of attribute prefab_api_url.
8 9 10 |
# File 'lib/prefab/client.rb', line 8 def prefab_api_url @prefab_api_url end |
#shared_cache ⇒ Object (readonly)
Returns the value of attribute shared_cache.
8 9 10 |
# File 'lib/prefab/client.rb', line 8 def shared_cache @shared_cache end |
#stats ⇒ Object (readonly)
Returns the value of attribute stats.
8 9 10 |
# File 'lib/prefab/client.rb', line 8 def stats @stats end |
Instance Method Details
#channel ⇒ Object
32 33 34 35 |
# File 'lib/prefab/client.rb', line 32 def channel credentials = http_secure? ? creds : :this_channel_is_insecure @_channel ||= GRPC::Core::Channel.new(@prefab_grpc_url, nil, credentials) end |
#config_client(timeout: 5.0) ⇒ Object
37 38 39 |
# File 'lib/prefab/client.rb', line 37 def config_client(timeout: 5.0) @config_client ||= Prefab::ConfigClient.new(self, timeout) end |
#enabled?(feature_name, lookup_key = nil, attributes = {}) ⇒ Boolean
88 89 90 |
# File 'lib/prefab/client.rb', line 88 def enabled?(feature_name, lookup_key=nil, attributes={}) feature_flag_client.feature_is_on_for?(feature_name, lookup_key, attributes: attributes) end |
#feature_flag_client ⇒ Object
45 46 47 |
# File 'lib/prefab/client.rb', line 45 def feature_flag_client @feature_flag_client ||= Prefab::FeatureFlagClient.new(self) end |
#get(key, default_or_lookup_key = NO_DEFAULT_PROVIDED, attributes = {}, ff_default = NO_DEFAULT_PROVIDED) ⇒ Object
92 93 94 95 96 97 98 99 100 |
# File 'lib/prefab/client.rb', line 92 def get(key, default_or_lookup_key=NO_DEFAULT_PROVIDED, attributes={}, ff_default=NO_DEFAULT_PROVIDED) result = config_client.get(key, default_or_lookup_key) if result.is_a?(Prefab::FeatureFlag) feature_flag_client.get(key, default_or_lookup_key, attributes, default: ff_default) else result end end |
#log ⇒ Object
49 50 51 |
# File 'lib/prefab/client.rb', line 49 def log @logger_client ||= Prefab::LoggerClient.new(@options.logdev, formatter: @options.log_formatter) end |
#log_internal(level, msg, path = "prefab") ⇒ Object
53 54 55 |
# File 'lib/prefab/client.rb', line 53 def log_internal(level, msg, path = "prefab") log.log_internal msg, path, nil, level end |
#ratelimit_client(timeout: 5.0) ⇒ Object
41 42 43 |
# File 'lib/prefab/client.rb', line 41 def ratelimit_client(timeout: 5.0) @ratelimit_client ||= Prefab::RateLimitClient.new(self, timeout) end |
#request(service, method, req_options: {}, params: {}) ⇒ Object
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 |
# File 'lib/prefab/client.rb', line 57 def request(service, method, req_options: {}, params: {}) opts = { timeout: 10 }.merge() attempts = 0 start_time = Time.now begin attempts += 1 return stub_for(service, opts[:timeout]).send(method, *params) rescue => exception log_internal Logger::WARN, exception if Time.now - start_time > opts[:timeout] raise exception end sleep_seconds = [BASE_SLEEP_SEC * (2 ** (attempts - 1)), MAX_SLEEP_SEC].min sleep_seconds = sleep_seconds * (0.5 * (1 + rand())) sleep_seconds = [BASE_SLEEP_SEC, sleep_seconds].max log_internal Logger::INFO, "Sleep #{sleep_seconds} and Reset #{service} #{method}" sleep sleep_seconds reset! retry end end |
#reset! ⇒ Object
83 84 85 86 |
# File 'lib/prefab/client.rb', line 83 def reset! @stubs.clear @_channel = nil end |