Skip to content

Commit 99ad827

Browse files
sleipnirsleipnir
authored
Merge pull request #415 from eigr/feat/add-monitor-app
feat: added clustering for spawn monitor
2 parents 62dfa6f + e596f80 commit 99ad827

Some content is hidden

Large Commits have some content hidden by default. Use the searchbox below for content that may be hidden.

62 files changed

+1359
-332
lines changed

‎Makefile

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -170,7 +170,7 @@ test-sdk:
170170
elixir --name [email protected] -S mix test
171171

172172
test-operator:
173-
cd spawn_operator/spawn_operator && MIX_ENV=test mix deps.get && MIX_ENV=test PROXY_DATABASE_TYPE=mysql PROXY_CLUSTER_STRATEGY=gossip PROXY_HTTP_PORT=9005 SPAWN_STATESTORE_KEY=3Jnb0hZiHIzHTOih7t2cTEPEpY98Tu1wvQkPfq/XwqE= elixir --name [email protected] -S mix test
173+
cd spawn_operator/spawn_operator && MIX_ENV=test mix deps.get && MIX_ENV=test PROXY_DATABASE_TYPE=mariadb PROXY_CLUSTER_STRATEGY=gossip PROXY_HTTP_PORT=9005 SPAWN_STATESTORE_KEY=3Jnb0hZiHIzHTOih7t2cTEPEpY98Tu1wvQkPfq/XwqE= elixir --name [email protected] -S mix test
174174

175175
test-proxy:
176176
cd spawn_proxy/proxy && MIX_ENV=test mix deps.get && MIX_ENV=test SPAWN_PROXY_LOGGER_LEVEL=debug PROXY_DATABASE_TYPE=mariadb PROXY_DATABASE_PORT=3307 PROXY_CLUSTER_STRATEGY=gossip PROXY_HTTP_PORT=9005 SPAWN_STATESTORE_KEY=3Jnb0hZiHIzHTOih7t2cTEPEpY98Tu1wvQkPfq/XwqE= elixir --name [email protected] -S mix test
@@ -227,7 +227,7 @@ integration.yaml: ## Create a k3d cluster
227227
test.integration: integration.yaml
228228

229229
test.integration: ## Run integration tests using k3d `make cluster`
230-
cd spawn_operator/spawn_operator && PROXY_CLUSTER_STRATEGY=gossip PROXY_DATABASE_TYPE=mysql PROXY_DATABASE_POOL_SIZE=10 SPAWN_STATESTORE_KEY=3Jnb0hZiHIzHTOih7t2cTEPEpY98Tu1wvQkPfq/XwqE= TEST_KUBECONFIG=${K3D_KUBECONFIG_PATH} mix test --only integration
230+
cd spawn_operator/spawn_operator && PROXY_CLUSTER_STRATEGY=gossip PROXY_DATABASE_TYPE=mariadb PROXY_DATABASE_POOL_SIZE=10 SPAWN_STATESTORE_KEY=3Jnb0hZiHIzHTOih7t2cTEPEpY98Tu1wvQkPfq/XwqE= TEST_KUBECONFIG=${K3D_KUBECONFIG_PATH} mix test --only integration
231231

232232
run-benchmark:
233233
cd spawn_sdk/spawn_sdk_example && \
@@ -427,7 +427,7 @@ run-activator-sqs-local:
427427

428428
run-proxy-image:
429429
docker run --rm --name=spawn-proxy \
430-
-e PROXY_DATABASE_TYPE=mysql \
430+
-e PROXY_DATABASE_TYPE=mariadb \
431431
-e SPAWN_STATESTORE_KEY=3Jnb0hZiHIzHTOih7t2cTEPEpY98Tu1wvQkPfq/XwqE= \
432432
--net=host ${proxy-image}
433433

‎lib/_generated/io/cloudevents/v1/spec.pb.ex

Lines changed: 5 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -1,6 +1,6 @@
11
defmodule Io.Cloudevents.V1.CloudEvent.AttributesEntry do
22
@moduledoc false
3-
use Protobuf, map: true, syntax: :proto3, protoc_gen_elixir_version: "0.13.0"
3+
use Protobuf, map: true, protoc_gen_elixir_version: "0.14.0", syntax: :proto3
44

55
def descriptor do
66
# credo:disable-for-next-line
@@ -46,6 +46,7 @@ defmodule Io.Cloudevents.V1.CloudEvent.AttributesEntry do
4646
deprecated: false,
4747
map_entry: true,
4848
deprecated_legacy_json_field_conflicts: nil,
49+
features: nil,
4950
uninterpreted_option: [],
5051
__pb_extensions__: %{},
5152
__unknown_fields__: []
@@ -63,7 +64,7 @@ end
6364

6465
defmodule Io.Cloudevents.V1.CloudEvent.CloudEventAttributeValue do
6566
@moduledoc false
66-
use Protobuf, syntax: :proto3, protoc_gen_elixir_version: "0.13.0"
67+
use Protobuf, protoc_gen_elixir_version: "0.14.0", syntax: :proto3
6768

6869
def descriptor do
6970
# credo:disable-for-next-line
@@ -196,7 +197,7 @@ end
196197

197198
defmodule Io.Cloudevents.V1.CloudEvent do
198199
@moduledoc false
199-
use Protobuf, syntax: :proto3, protoc_gen_elixir_version: "0.13.0"
200+
use Protobuf, protoc_gen_elixir_version: "0.14.0", syntax: :proto3
200201

201202
def descriptor do
202203
# credo:disable-for-next-line
@@ -359,6 +360,7 @@ defmodule Io.Cloudevents.V1.CloudEvent do
359360
deprecated: false,
360361
map_entry: true,
361362
deprecated_legacy_json_field_conflicts: nil,
363+
features: nil,
362364
uninterpreted_option: [],
363365
__pb_extensions__: %{},
364366
__unknown_fields__: []

‎lib/_generated/spawn/actors/actor.pb.ex

Lines changed: 26 additions & 20 deletions
Original file line numberDiff line numberDiff line change
@@ -1,6 +1,6 @@
11
defmodule Spawn.Actors.Kind do
22
@moduledoc false
3-
use Protobuf, enum: true, syntax: :proto3, protoc_gen_elixir_version: "0.13.0"
3+
use Protobuf, enum: true, protoc_gen_elixir_version: "0.14.0", syntax: :proto3
44

55
def descriptor do
66
# credo:disable-for-next-line
@@ -68,7 +68,7 @@ end
6868

6969
defmodule Spawn.Actors.Registry.ActorsEntry do
7070
@moduledoc false
71-
use Protobuf, map: true, syntax: :proto3, protoc_gen_elixir_version: "0.13.0"
71+
use Protobuf, map: true, protoc_gen_elixir_version: "0.14.0", syntax: :proto3
7272

7373
def descriptor do
7474
# credo:disable-for-next-line
@@ -114,6 +114,7 @@ defmodule Spawn.Actors.Registry.ActorsEntry do
114114
deprecated: false,
115115
map_entry: true,
116116
deprecated_legacy_json_field_conflicts: nil,
117+
features: nil,
117118
uninterpreted_option: [],
118119
__pb_extensions__: %{},
119120
__unknown_fields__: []
@@ -131,7 +132,7 @@ end
131132

132133
defmodule Spawn.Actors.Registry do
133134
@moduledoc false
134-
use Protobuf, syntax: :proto3, protoc_gen_elixir_version: "0.13.0"
135+
use Protobuf, protoc_gen_elixir_version: "0.14.0", syntax: :proto3
135136

136137
def descriptor do
137138
# credo:disable-for-next-line
@@ -196,6 +197,7 @@ defmodule Spawn.Actors.Registry do
196197
deprecated: false,
197198
map_entry: true,
198199
deprecated_legacy_json_field_conflicts: nil,
200+
features: nil,
199201
uninterpreted_option: [],
200202
__pb_extensions__: %{},
201203
__unknown_fields__: []
@@ -222,7 +224,7 @@ end
222224

223225
defmodule Spawn.Actors.ActorSystem do
224226
@moduledoc false
225-
use Protobuf, syntax: :proto3, protoc_gen_elixir_version: "0.13.0"
227+
use Protobuf, protoc_gen_elixir_version: "0.14.0", syntax: :proto3
226228

227229
def descriptor do
228230
# credo:disable-for-next-line
@@ -276,7 +278,7 @@ end
276278

277279
defmodule Spawn.Actors.ActorSnapshotStrategy do
278280
@moduledoc false
279-
use Protobuf, syntax: :proto3, protoc_gen_elixir_version: "0.13.0"
281+
use Protobuf, protoc_gen_elixir_version: "0.14.0", syntax: :proto3
280282

281283
def descriptor do
282284
# credo:disable-for-next-line
@@ -323,7 +325,7 @@ end
323325

324326
defmodule Spawn.Actors.ActorDeactivationStrategy do
325327
@moduledoc false
326-
use Protobuf, syntax: :proto3, protoc_gen_elixir_version: "0.13.0"
328+
use Protobuf, protoc_gen_elixir_version: "0.14.0", syntax: :proto3
327329

328330
def descriptor do
329331
# credo:disable-for-next-line
@@ -370,7 +372,7 @@ end
370372

371373
defmodule Spawn.Actors.TimeoutStrategy do
372374
@moduledoc false
373-
use Protobuf, syntax: :proto3, protoc_gen_elixir_version: "0.13.0"
375+
use Protobuf, protoc_gen_elixir_version: "0.14.0", syntax: :proto3
374376

375377
def descriptor do
376378
# credo:disable-for-next-line
@@ -409,7 +411,7 @@ end
409411

410412
defmodule Spawn.Actors.Action do
411413
@moduledoc false
412-
use Protobuf, syntax: :proto3, protoc_gen_elixir_version: "0.13.0"
414+
use Protobuf, protoc_gen_elixir_version: "0.14.0", syntax: :proto3
413415

414416
def descriptor do
415417
# credo:disable-for-next-line
@@ -448,7 +450,7 @@ end
448450

449451
defmodule Spawn.Actors.FixedTimerAction do
450452
@moduledoc false
451-
use Protobuf, syntax: :proto3, protoc_gen_elixir_version: "0.13.0"
453+
use Protobuf, protoc_gen_elixir_version: "0.14.0", syntax: :proto3
452454

453455
def descriptor do
454456
# credo:disable-for-next-line
@@ -502,7 +504,7 @@ end
502504

503505
defmodule Spawn.Actors.ActorState.TagsEntry do
504506
@moduledoc false
505-
use Protobuf, map: true, syntax: :proto3, protoc_gen_elixir_version: "0.13.0"
507+
use Protobuf, map: true, protoc_gen_elixir_version: "0.14.0", syntax: :proto3
506508

507509
def descriptor do
508510
# credo:disable-for-next-line
@@ -548,6 +550,7 @@ defmodule Spawn.Actors.ActorState.TagsEntry do
548550
deprecated: false,
549551
map_entry: true,
550552
deprecated_legacy_json_field_conflicts: nil,
553+
features: nil,
551554
uninterpreted_option: [],
552555
__pb_extensions__: %{},
553556
__unknown_fields__: []
@@ -565,7 +568,7 @@ end
565568

566569
defmodule Spawn.Actors.ActorState do
567570
@moduledoc false
568-
use Protobuf, syntax: :proto3, protoc_gen_elixir_version: "0.13.0"
571+
use Protobuf, protoc_gen_elixir_version: "0.14.0", syntax: :proto3
569572

570573
def descriptor do
571574
# credo:disable-for-next-line
@@ -644,6 +647,7 @@ defmodule Spawn.Actors.ActorState do
644647
deprecated: false,
645648
map_entry: true,
646649
deprecated_legacy_json_field_conflicts: nil,
650+
features: nil,
647651
uninterpreted_option: [],
648652
__pb_extensions__: %{},
649653
__unknown_fields__: []
@@ -671,7 +675,7 @@ end
671675

672676
defmodule Spawn.Actors.Metadata.TagsEntry do
673677
@moduledoc false
674-
use Protobuf, map: true, syntax: :proto3, protoc_gen_elixir_version: "0.13.0"
678+
use Protobuf, map: true, protoc_gen_elixir_version: "0.14.0", syntax: :proto3
675679

676680
def descriptor do
677681
# credo:disable-for-next-line
@@ -717,6 +721,7 @@ defmodule Spawn.Actors.Metadata.TagsEntry do
717721
deprecated: false,
718722
map_entry: true,
719723
deprecated_legacy_json_field_conflicts: nil,
724+
features: nil,
720725
uninterpreted_option: [],
721726
__pb_extensions__: %{},
722727
__unknown_fields__: []
@@ -734,7 +739,7 @@ end
734739

735740
defmodule Spawn.Actors.Metadata do
736741
@moduledoc false
737-
use Protobuf, syntax: :proto3, protoc_gen_elixir_version: "0.13.0"
742+
use Protobuf, protoc_gen_elixir_version: "0.14.0", syntax: :proto3
738743

739744
def descriptor do
740745
# credo:disable-for-next-line
@@ -813,6 +818,7 @@ defmodule Spawn.Actors.Metadata do
813818
deprecated: false,
814819
map_entry: true,
815820
deprecated_legacy_json_field_conflicts: nil,
821+
features: nil,
816822
uninterpreted_option: [],
817823
__pb_extensions__: %{},
818824
__unknown_fields__: []
@@ -840,7 +846,7 @@ end
840846

841847
defmodule Spawn.Actors.Channel do
842848
@moduledoc false
843-
use Protobuf, syntax: :proto3, protoc_gen_elixir_version: "0.13.0"
849+
use Protobuf, protoc_gen_elixir_version: "0.14.0", syntax: :proto3
844850

845851
def descriptor do
846852
# credo:disable-for-next-line
@@ -894,7 +900,7 @@ end
894900

895901
defmodule Spawn.Actors.ProjectionSubject do
896902
@moduledoc false
897-
use Protobuf, syntax: :proto3, protoc_gen_elixir_version: "0.13.0"
903+
use Protobuf, protoc_gen_elixir_version: "0.14.0", syntax: :proto3
898904

899905
def descriptor do
900906
# credo:disable-for-next-line
@@ -978,7 +984,7 @@ end
978984

979985
defmodule Spawn.Actors.EventsRetentionStrategy do
980986
@moduledoc false
981-
use Protobuf, syntax: :proto3, protoc_gen_elixir_version: "0.13.0"
987+
use Protobuf, protoc_gen_elixir_version: "0.14.0", syntax: :proto3
982988

983989
def descriptor do
984990
# credo:disable-for-next-line
@@ -1040,7 +1046,7 @@ end
10401046

10411047
defmodule Spawn.Actors.ProjectionSettings do
10421048
@moduledoc false
1043-
use Protobuf, syntax: :proto3, protoc_gen_elixir_version: "0.13.0"
1049+
use Protobuf, protoc_gen_elixir_version: "0.14.0", syntax: :proto3
10441050

10451051
def descriptor do
10461052
# credo:disable-for-next-line
@@ -1129,7 +1135,7 @@ end
11291135

11301136
defmodule Spawn.Actors.ActorSettings do
11311137
@moduledoc false
1132-
use Protobuf, syntax: :proto3, protoc_gen_elixir_version: "0.13.0"
1138+
use Protobuf, protoc_gen_elixir_version: "0.14.0", syntax: :proto3
11331139

11341140
def descriptor do
11351141
# credo:disable-for-next-line
@@ -1287,7 +1293,7 @@ end
12871293

12881294
defmodule Spawn.Actors.ActorId do
12891295
@moduledoc false
1290-
use Protobuf, syntax: :proto3, protoc_gen_elixir_version: "0.13.0"
1296+
use Protobuf, protoc_gen_elixir_version: "0.14.0", syntax: :proto3
12911297

12921298
def descriptor do
12931299
# credo:disable-for-next-line
@@ -1356,7 +1362,7 @@ end
13561362

13571363
defmodule Spawn.Actors.Actor do
13581364
@moduledoc false
1359-
use Protobuf, syntax: :proto3, protoc_gen_elixir_version: "0.13.0"
1365+
use Protobuf, protoc_gen_elixir_version: "0.14.0", syntax: :proto3
13601366

13611367
def descriptor do
13621368
# credo:disable-for-next-line

‎lib/_generated/spawn/actors/extensions.pb.ex

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -1,6 +1,6 @@
11
defmodule Spawn.Actors.PbExtension do
22
@moduledoc false
3-
use Protobuf, syntax: :proto3, protoc_gen_elixir_version: "0.13.0"
3+
use Protobuf, protoc_gen_elixir_version: "0.14.0", syntax: :proto3
44

55
extend(Google.Protobuf.FieldOptions, :actor_id, 9999,
66
optional: true,
@@ -23,7 +23,7 @@ end
2323

2424
defmodule Spawn.Actors.ActorOpts do
2525
@moduledoc false
26-
use Protobuf, syntax: :proto3, protoc_gen_elixir_version: "0.13.0"
26+
use Protobuf, protoc_gen_elixir_version: "0.14.0", syntax: :proto3
2727

2828
def descriptor do
2929
# credo:disable-for-next-line
@@ -187,7 +187,7 @@ end
187187

188188
defmodule Spawn.Actors.ActorViewOption do
189189
@moduledoc false
190-
use Protobuf, syntax: :proto3, protoc_gen_elixir_version: "0.13.0"
190+
use Protobuf, protoc_gen_elixir_version: "0.14.0", syntax: :proto3
191191

192192
def descriptor do
193193
# credo:disable-for-next-line

‎lib/_generated/spawn/actors/healthcheck.pb.ex

Lines changed: 8 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -1,6 +1,6 @@
11
defmodule Spawn.Actors.Healthcheck.Status do
22
@moduledoc false
3-
use Protobuf, syntax: :proto3, protoc_gen_elixir_version: "0.13.0"
3+
use Protobuf, protoc_gen_elixir_version: "0.14.0", syntax: :proto3
44

55
def descriptor do
66
# credo:disable-for-next-line
@@ -69,7 +69,7 @@ end
6969

7070
defmodule Spawn.Actors.Healthcheck.HealthCheckReply do
7171
@moduledoc false
72-
use Protobuf, syntax: :proto3, protoc_gen_elixir_version: "0.13.0"
72+
use Protobuf, protoc_gen_elixir_version: "0.14.0", syntax: :proto3
7373

7474
def descriptor do
7575
# credo:disable-for-next-line
@@ -109,7 +109,7 @@ end
109109
defmodule Spawn.Actors.Healthcheck.HealthCheckActor.Service do
110110
use GRPC.Service,
111111
name: "spawn.actors.healthcheck.HealthCheckActor",
112-
protoc_gen_elixir_version: "0.13.0"
112+
protoc_gen_elixir_version: "0.14.0"
113113

114114
def descriptor do
115115
# credo:disable-for-next-line
@@ -220,6 +220,7 @@ defmodule Spawn.Actors.Healthcheck.HealthCheckActor.Service do
220220
options: %Google.Protobuf.MethodOptions{
221221
deprecated: false,
222222
idempotency_level: :IDEMPOTENCY_UNKNOWN,
223+
features: nil,
223224
uninterpreted_option: [],
224225
__pb_extensions__: %{
225226
{Google.Api.PbExtension, :http} => %Google.Api.HttpRule{
@@ -244,6 +245,7 @@ defmodule Spawn.Actors.Healthcheck.HealthCheckActor.Service do
244245
options: %Google.Protobuf.MethodOptions{
245246
deprecated: false,
246247
idempotency_level: :IDEMPOTENCY_UNKNOWN,
248+
features: nil,
247249
uninterpreted_option: [],
248250
__pb_extensions__: %{
249251
{Google.Api.PbExtension, :http} => %Google.Api.HttpRule{
@@ -264,6 +266,7 @@ defmodule Spawn.Actors.Healthcheck.HealthCheckActor.Service do
264266
],
265267
options: %Google.Protobuf.ServiceOptions{
266268
deprecated: false,
269+
features: nil,
267270
uninterpreted_option: [],
268271
__pb_extensions__: %{
269272
{Spawn.Actors.PbExtension, :actor} => %Spawn.Actors.ActorOpts{
@@ -303,9 +306,9 @@ defmodule Spawn.Actors.Healthcheck.HealthCheckActor.Service do
303306
swift_prefix: nil,
304307
php_class_prefix: nil,
305308
php_namespace: nil,
306-
php_generic_services: false,
307309
php_metadata_namespace: nil,
308310
ruby_package: nil,
311+
features: nil,
309312
uninterpreted_option: [],
310313
__pb_extensions__: %{},
311314
__unknown_fields__: []
@@ -673,6 +676,7 @@ defmodule Spawn.Actors.Healthcheck.HealthCheckActor.Service do
673676
__unknown_fields__: []
674677
}
675678
],
679+
__pb_extensions__: %{},
676680
__unknown_fields__: []
677681
},
678682
public_dependency: [],

0 commit comments

Comments
 (0)