1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
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
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
|
require "flipper/adapters/http"
require "flipper/adapters/memory"
require "flipper/adapters/sync"
module Flipper
module Cloud
class Configuration
# The default url should be the one, the only, the website.
DEFAULT_URL = "https://www.flippercloud.io/adapter".freeze
# Public: The token corresponding to an environment on flippercloud.io.
attr_accessor :token
# Public: The url for http adapter (default: Flipper::Cloud::DEFAULT_URL).
# Really should only be customized for development work. Feel free
# to forget you ever saw this.
attr_reader :url
# Public: net/http read timeout for all http requests (default: 5).
attr_accessor :read_timeout
# Public: net/http open timeout for all http requests (default: 5).
attr_accessor :open_timeout
# Public: net/http write timeout for all http requests (default: 5).
attr_accessor :write_timeout
# Public: IO stream to send debug output too. Off by default.
#
# # for example, this would send all http request information to STDOUT
# configuration = Flipper::Cloud::Configuration.new
# configuration.debug_output = STDOUT
attr_accessor :debug_output
# Public: Instrumenter to use for the Flipper instance returned by
# Flipper::Cloud.new (default: Flipper::Instrumenters::Noop).
#
# # for example, to use active support notifications you could do:
# configuration = Flipper::Cloud::Configuration.new
# configuration.instrumenter = ActiveSupport::Notifications
attr_accessor :instrumenter
# Public: Local adapter that all reads should go to in order to ensure
# latency is low and resiliency is high. This adapter is automatically
# kept in sync with cloud.
#
# # for example, to use active record you could do:
# configuration = Flipper::Cloud::Configuration.new
# configuration.local_adapter = Flipper::Adapters::ActiveRecord.new
attr_accessor :local_adapter
# Public: The Integer or Float number of seconds between attempts to bring
# the local in sync with cloud (default: 10).
attr_accessor :sync_interval
def initialize(options = {})
@token = options.fetch(:token)
@instrumenter = options.fetch(:instrumenter, Instrumenters::Noop)
@read_timeout = options.fetch(:read_timeout, 5)
@open_timeout = options.fetch(:open_timeout, 5)
@write_timeout = options.fetch(:write_timeout, 5)
@sync_interval = options.fetch(:sync_interval, 10)
@local_adapter = options.fetch(:local_adapter) { Adapters::Memory.new }
@debug_output = options[:debug_output]
@adapter_block = ->(adapter) { adapter }
self.url = options.fetch(:url, DEFAULT_URL)
end
# Public: Read or customize the http adapter. Calling without a block will
# perform a read. Calling with a block yields the cloud adapter
# for customization.
#
# # for example, to instrument the http calls, you can wrap the http
# # adapter with the intsrumented adapter
# configuration = Flipper::Cloud::Configuration.new
# configuration.adapter do |adapter|
# Flipper::Adapters::Instrumented.new(adapter)
# end
#
def adapter(&block)
if block_given?
@adapter_block = block
else
@adapter_block.call sync_adapter
end
end
# Public: Set url for the http adapter.
attr_writer :url
private
def sync_adapter
sync_options = {
instrumenter: instrumenter,
interval: sync_interval,
}
Flipper::Adapters::Sync.new(local_adapter, http_adapter, sync_options)
end
def http_adapter
http_options = {
url: @url,
read_timeout: @read_timeout,
open_timeout: @open_timeout,
debug_output: @debug_output,
headers: {
"Feature-Flipper-Token" => @token,
},
}
Flipper::Adapters::Http.new(http_options)
end
end
end
end
|
