Skip to content

Commit e885516

Browse files
committed
Make sure mandatory is present
1 parent 8c5bdc2 commit e885516

File tree

1 file changed

+4
-4
lines changed

1 file changed

+4
-4
lines changed

lib/replicated_rate_limiter.ex

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -122,8 +122,8 @@ defmodule ReplicatedRateLimiter do
122122
end
123123

124124
def allow?(config, bucket, capacity, refill, cost) do
125-
ets_table = Keyword.get(config, :ets_table)
126-
crdt_name = Keyword.get(config, :crdt_name)
125+
ets_table = Keyword.fetch!(config, :ets_table)
126+
crdt_name = Keyword.fetch!(config, :crdt_name)
127127

128128
now = System.system_time(:second)
129129

@@ -183,8 +183,8 @@ defmodule ReplicatedRateLimiter do
183183
def apply_diffs(config, diffs) when is_list(diffs) do
184184
Logger.debug("Applying diffs: #{inspect(diffs)}")
185185

186-
ets_table = Keyword.get(config, :ets_table)
187-
crdt_name = Keyword.get(config, :crdt_name)
186+
ets_table = Keyword.fetch!(config, :ets_table)
187+
crdt_name = Keyword.fetch!(config, :crdt_name)
188188

189189
Task.start(fn ->
190190
changed_buckets =

0 commit comments

Comments
 (0)