Skip to content

Commit 851522c

Browse files
authored
Merge pull request #3 from nsweeting/kv-2.0
Update to KeywordValidator 2.0
2 parents de1a33a + 959ff3d commit 851522c

4 files changed

Lines changed: 14 additions & 16 deletions

File tree

lib/data_buffer/partition.ex

Lines changed: 10 additions & 10 deletions
Original file line numberDiff line numberDiff line change
@@ -34,16 +34,16 @@ defmodule DataBuffer.Partition do
3434
@type partition :: atom()
3535
@type table :: :ets.tid()
3636

37-
@opts_schema %{
38-
name: [type: :atom, required: true],
39-
buffer: [type: :module, required: true],
40-
max_size: [type: :integer, default: 5_000, required: true],
41-
max_size_jitter: [type: :integer, default: 0, required: true],
42-
flush_interval: [type: :integer, default: 10_000, required: true],
43-
flush_jitter: [type: :integer, default: 2_000, required: true],
44-
flush_meta: [type: :any, required: false],
45-
flush_timeout: [type: :integer, default: 60_000, required: true]
46-
}
37+
@opts_schema KeywordValidator.schema!(
38+
name: [is: :atom, required: true],
39+
buffer: [is: :mod, required: true],
40+
max_size: [is: :integer, default: 5_000, required: true],
41+
max_size_jitter: [is: :integer, default: 0, required: true],
42+
flush_interval: [is: :integer, default: 10_000, required: true],
43+
flush_jitter: [is: :integer, default: 2_000, required: true],
44+
flush_meta: [is: :any, required: false],
45+
flush_timeout: [is: :timeout, default: 60_000, required: true]
46+
)
4747

4848
################################
4949
# Public API

lib/data_buffer/partition_pool.ex

Lines changed: 1 addition & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -5,9 +5,7 @@ defmodule DataBuffer.PartitionPool do
55

66
@atomics_ix 1
77
@counter_max 2_000_000_000
8-
@opts_schema %{
9-
partitions: [type: :integer, default: 1, required: true]
10-
}
8+
@opts_schema KeywordValidator.schema!(partitions: [is: :integer, default: 1, required: true])
119

1210
################################
1311
# Public API

mix.exs

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1,7 +1,7 @@
11
defmodule DataBuffer.MixProject do
22
use Mix.Project
33

4-
@version "0.5.1"
4+
@version "0.6.0"
55

66
def project do
77
[
@@ -54,7 +54,7 @@ defmodule DataBuffer.MixProject do
5454
# Run "mix help deps" to learn about dependencies.
5555
defp deps do
5656
[
57-
{:keyword_validator, "~> 1.0"},
57+
{:keyword_validator, "~> 2.0"},
5858
{:telemetry, "~> 0.4"},
5959
{:benchee, "~> 1.0", only: :dev},
6060
{:ex_doc, "~> 0.22", only: :dev, runtime: false}

mix.lock

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -3,7 +3,7 @@
33
"deep_merge": {:hex, :deep_merge, "1.0.0", "b4aa1a0d1acac393bdf38b2291af38cb1d4a52806cf7a4906f718e1feb5ee961", [:mix], [], "hexpm", "ce708e5f094b9cd4e8f2be4f00d2f4250c4095be93f8cd6d018c753894885430"},
44
"earmark_parser": {:hex, :earmark_parser, "1.4.10", "6603d7a603b9c18d3d20db69921527f82ef09990885ed7525003c7fe7dc86c56", [:mix], [], "hexpm", "8e2d5370b732385db2c9b22215c3f59c84ac7dda7ed7e544d7c459496ae519c0"},
55
"ex_doc": {:hex, :ex_doc, "0.22.2", "03a2a58bdd2ba0d83d004507c4ee113b9c521956938298eba16e55cc4aba4a6c", [:mix], [{:earmark_parser, "~> 1.4.0", [hex: :earmark_parser, repo: "hexpm", optional: false]}, {:makeup_elixir, "~> 0.14", [hex: :makeup_elixir, repo: "hexpm", optional: false]}], "hexpm", "cf60e1b3e2efe317095b6bb79651f83a2c1b3edcb4d319c421d7fcda8b3aff26"},
6-
"keyword_validator": {:hex, :keyword_validator, "1.0.1", "1aef6705d306677d59c59fff9c3b7e1f70b161900af400a7b784cdfc042c0cb3", [:mix], [], "hexpm", "22e729ef861eb157f9a661d918abc2eee164dd7903110d9128948be59e33a40e"},
6+
"keyword_validator": {:hex, :keyword_validator, "2.0.1", "92ab90dc93ea9e049530eb0a79c8f074833942dfb93d25e6a946b71b70086b49", [:mix], [], "hexpm", "09715a32d458c6318d39c0a484e958ce20fff64d646188b5801c334179be9fc2"},
77
"makeup": {:hex, :makeup, "1.0.3", "e339e2f766d12e7260e6672dd4047405963c5ec99661abdc432e6ec67d29ef95", [:mix], [{:nimble_parsec, "~> 0.5", [hex: :nimble_parsec, repo: "hexpm", optional: false]}], "hexpm", "2e9b4996d11832947731f7608fed7ad2f9443011b3b479ae288011265cdd3dad"},
88
"makeup_elixir": {:hex, :makeup_elixir, "0.14.1", "4f0e96847c63c17841d42c08107405a005a2680eb9c7ccadfd757bd31dabccfb", [:mix], [{:makeup, "~> 1.0", [hex: :makeup, repo: "hexpm", optional: false]}], "hexpm", "f2438b1a80eaec9ede832b5c41cd4f373b38fd7aa33e3b22d9db79e640cbde11"},
99
"nimble_parsec": {:hex, :nimble_parsec, "0.6.0", "32111b3bf39137144abd7ba1cce0914533b2d16ef35e8abc5ec8be6122944263", [:mix], [], "hexpm", "27eac315a94909d4dc68bc07a4a83e06c8379237c5ea528a9acff4ca1c873c52"},

0 commit comments

Comments
 (0)