Class: SplitIoClient::SplitClient
- Inherits:
-
Object
- Object
- SplitIoClient::SplitClient
- Defined in:
- lib/splitclient-rb/clients/split_client.rb
Instance Method Summary collapse
- #block_until_ready(time = nil) ⇒ Object
- #destroy ⇒ Object
- #get_treatment(key, split_name, attributes = {}, split_data = nil, store_impressions = true, multiple = false, evaluator = nil) ⇒ Object
- #get_treatment_with_config(key, split_name, attributes = {}, split_data = nil, store_impressions = true, multiple = false, evaluator = nil) ⇒ Object
- #get_treatments(key, split_names, attributes = {}) ⇒ Object
- #get_treatments_by_flag_set(key, flag_set, attributes = {}) ⇒ Object
- #get_treatments_by_flag_sets(key, flag_sets, attributes = {}) ⇒ Object
- #get_treatments_with_config(key, split_names, attributes = {}) ⇒ Object
- #get_treatments_with_config_by_flag_set(key, flag_set, attributes = {}) ⇒ Object
- #get_treatments_with_config_by_flag_sets(key, flag_sets, attributes = {}) ⇒ Object
-
#initialize(sdk_key, repositories, status_manager, config, impressions_manager, telemetry_evaluation_producer, evaluator, split_validator) ⇒ SplitIoClient
constructor
Creates a new split client instance that connects to split.io API.
- #track(key, traffic_type_name, event_type, value = nil, properties = nil) ⇒ Object
Constructor Details
#initialize(sdk_key, repositories, status_manager, config, impressions_manager, telemetry_evaluation_producer, evaluator, split_validator) ⇒ SplitIoClient
Creates a new split client instance that connects to split.io API.
21 22 23 24 25 26 27 28 29 30 31 32 33 34 |
# File 'lib/splitclient-rb/clients/split_client.rb', line 21 def initialize(sdk_key, repositories, status_manager, config, impressions_manager, telemetry_evaluation_producer, evaluator, split_validator) @api_key = sdk_key @splits_repository = repositories[:splits] @segments_repository = repositories[:segments] @impressions_repository = repositories[:impressions] @events_repository = repositories[:events] @status_manager = status_manager @destroyed = false @config = config @impressions_manager = impressions_manager @telemetry_evaluation_producer = telemetry_evaluation_producer @split_validator = split_validator @evaluator = evaluator end |
Instance Method Details
#block_until_ready(time = nil) ⇒ Object
149 150 151 |
# File 'lib/splitclient-rb/clients/split_client.rb', line 149 def block_until_ready(time = nil) @status_manager.wait_until_ready(time) if @status_manager end |
#destroy ⇒ Object
97 98 99 100 101 102 103 104 105 106 107 108 109 110 111 112 113 114 115 116 |
# File 'lib/splitclient-rb/clients/split_client.rb', line 97 def destroy @config.logger.info('Split client shutdown started...') if @config.debug_enabled @config.threads.select { |name, thread| name.to_s.end_with? 'sender' }.values.each do |thread| thread.raise(SplitIoClient::SDKShutdownException) thread.join end @config.threads.values.each { |thread| Thread.kill(thread) } @splits_repository.clear @segments_repository.clear SplitIoClient.load_factory_registry SplitIoClient.split_factory_registry.remove(@api_key) @config.logger.info('Split client shutdown complete') if @config.debug_enabled @config.valid_mode = false @destroyed = true end |
#get_treatment(key, split_name, attributes = {}, split_data = nil, store_impressions = true, multiple = false, evaluator = nil) ⇒ Object
36 37 38 39 40 41 42 43 |
# File 'lib/splitclient-rb/clients/split_client.rb', line 36 def get_treatment( key, split_name, attributes = {}, split_data = nil, store_impressions = true, multiple = false, evaluator = nil ) result = treatment(key, split_name, attributes, split_data, store_impressions, GET_TREATMENT, multiple) return result.tap { |t| t.delete(:config) } if multiple result[:treatment] end |
#get_treatment_with_config(key, split_name, attributes = {}, split_data = nil, store_impressions = true, multiple = false, evaluator = nil) ⇒ Object
45 46 47 48 49 50 |
# File 'lib/splitclient-rb/clients/split_client.rb', line 45 def get_treatment_with_config( key, split_name, attributes = {}, split_data = nil, store_impressions = true, multiple = false, evaluator = nil ) treatment(key, split_name, attributes, split_data, store_impressions, GET_TREATMENT_WITH_CONFIG, multiple) end |
#get_treatments(key, split_names, attributes = {}) ⇒ Object
52 53 54 55 56 57 58 59 |
# File 'lib/splitclient-rb/clients/split_client.rb', line 52 def get_treatments(key, split_names, attributes = {}) treatments = treatments(key, split_names, attributes) return treatments if treatments.nil? keys = treatments.keys treats = treatments.map { |_,t| t[:treatment] } Hash[keys.zip(treats)] end |
#get_treatments_by_flag_set(key, flag_set, attributes = {}) ⇒ Object
65 66 67 68 69 70 71 72 73 |
# File 'lib/splitclient-rb/clients/split_client.rb', line 65 def get_treatments_by_flag_set(key, flag_set, attributes = {}) valid_flag_set = @split_validator.valid_flag_sets(GET_TREATMENTS_BY_FLAG_SET, [flag_set]) split_names = @splits_repository.get_feature_flags_by_sets(valid_flag_set) treatments = treatments(key, split_names, attributes, GET_TREATMENTS_BY_FLAG_SET) return treatments if treatments.nil? keys = treatments.keys treats = treatments.map { |_,t| t[:treatment] } Hash[keys.zip(treats)] end |
#get_treatments_by_flag_sets(key, flag_sets, attributes = {}) ⇒ Object
75 76 77 78 79 80 81 82 83 |
# File 'lib/splitclient-rb/clients/split_client.rb', line 75 def get_treatments_by_flag_sets(key, flag_sets, attributes = {}) valid_flag_set = @split_validator.valid_flag_sets(GET_TREATMENTS_BY_FLAG_SETS, flag_sets) split_names = @splits_repository.get_feature_flags_by_sets(valid_flag_set) treatments = treatments(key, split_names, attributes, GET_TREATMENTS_BY_FLAG_SETS) return treatments if treatments.nil? keys = treatments.keys treats = treatments.map { |_,t| t[:treatment] } Hash[keys.zip(treats)] end |
#get_treatments_with_config(key, split_names, attributes = {}) ⇒ Object
61 62 63 |
# File 'lib/splitclient-rb/clients/split_client.rb', line 61 def get_treatments_with_config(key, split_names, attributes = {}) treatments(key, split_names, attributes, GET_TREATMENTS_WITH_CONFIG) end |
#get_treatments_with_config_by_flag_set(key, flag_set, attributes = {}) ⇒ Object
85 86 87 88 89 |
# File 'lib/splitclient-rb/clients/split_client.rb', line 85 def get_treatments_with_config_by_flag_set(key, flag_set, attributes = {}) valid_flag_set = @split_validator.valid_flag_sets(GET_TREATMENTS_WITH_CONFIG_BY_FLAG_SET, [flag_set]) split_names = @splits_repository.get_feature_flags_by_sets(valid_flag_set) treatments(key, split_names, attributes, GET_TREATMENTS_WITH_CONFIG_BY_FLAG_SET) end |
#get_treatments_with_config_by_flag_sets(key, flag_sets, attributes = {}) ⇒ Object
91 92 93 94 95 |
# File 'lib/splitclient-rb/clients/split_client.rb', line 91 def get_treatments_with_config_by_flag_sets(key, flag_sets, attributes = {}) valid_flag_set = @split_validator.valid_flag_sets(GET_TREATMENTS_WITH_CONFIG_BY_FLAG_SETS, flag_sets) split_names = @splits_repository.get_feature_flags_by_sets(valid_flag_set) treatments(key, split_names, attributes, GET_TREATMENTS_WITH_CONFIG_BY_FLAG_SETS) end |
#track(key, traffic_type_name, event_type, value = nil, properties = nil) ⇒ Object
118 119 120 121 122 123 124 125 126 127 128 129 130 131 132 133 134 135 136 137 138 139 140 141 142 143 144 145 146 147 |
# File 'lib/splitclient-rb/clients/split_client.rb', line 118 def track(key, traffic_type_name, event_type, value = nil, properties = nil) return false unless valid_client && @config.split_validator.valid_track_parameters(key, traffic_type_name, event_type, value, properties) start = Time.now properties_size = EVENT_AVERAGE_SIZE if !properties.nil? properties, size = validate_properties(properties) properties_size += size if (properties_size > EVENTS_SIZE_THRESHOLD) @config.logger.error("The maximum size allowed for the properties is #{EVENTS_SIZE_THRESHOLD}. Current is #{properties_size}. Event not queued") return false end end if ready? && !@config.localhost_mode && !@splits_repository.traffic_type_exists(traffic_type_name) @config.logger.warn("track: Traffic Type #{traffic_type_name} " \ "does not have any corresponding feature flags in this environment, make sure you're tracking " \ 'your events to a valid traffic type defined in the Split user interface') end @events_repository.add(key.to_s, traffic_type_name.downcase, event_type.to_s, (Time.now.to_f * 1000).to_i, value, properties, properties_size) record_latency(TRACK, start) true rescue StandardError => e @config.log_found_exception(__method__.to_s, e) record_exception(TRACK) false end |