Skip to content

Instantly share code, notes, and snippets.

@marcellanz

marcellanz/gist:fa8eee2c2a07332d45b00b6a2d72b559 Secret

Created June 22, 2021 20:41
Show Gist options
  • Save marcellanz/fa8eee2c2a07332d45b00b6a2d72b559 to your computer and use it in GitHub Desktop.
Save marcellanz/fa8eee2c2a07332d45b00b6a2d72b559 to your computer and use it in GitHub Desktop.
Download ZIP
massa_discovery.log
Raw
gistfile1.txt
lanzm@defiant massa_proxy % iex --name massa-001@127.0.0.1 -S mix
Erlang/OTP 24 [erts-12.0.2] [source] [64-bit] [smp:16:16] [ds:16:16:10] [async-threads:1] [jit] [dtrace]
2021-06-22 22:19:09.120 [massa-001@127.0.0.1]:[pid=<0.407.0> ]:[info]: Available BEAM Schedulers: 16. Online BEAM Schedulers: 16
2021-06-22 22:19:09.123 [massa-001@127.0.0.1]:[pid=<0.407.0> ]:[info]: HTTP Server started on port 9001
2021-06-22 22:19:09.124 [massa-001@127.0.0.1]:[pid=<0.407.0> ]:[info]: Cluster Strategy gossip
2021-06-22 22:19:09.124 [massa-001@127.0.0.1]:[pid=<0.407.0> ]:[debug]:Cluster topology [proxy: [strategy: Cluster.Strategy.Gossip]]
2021-06-22 22:19:09.134 [massa-001@127.0.0.1]:[pid=<0.518.0> ]:[debug]:Registry Node :"massa-001@127.0.0.1" joining with Node :"massa-001@127.0.0.1"
2021-06-22 22:19:09.135 [massa-001@127.0.0.1]:[pid=<0.521.0> ]:[info]: Starting Horde.RegistryImpl with name MassaProxy.GlobalRegistry
2021-06-22 22:19:09.136 [massa-001@127.0.0.1]:[pid=<0.522.0> ]:[debug]:Supervisor Node :"massa-001@127.0.0.1" joining with Node :"massa-001@127.0.0.1"
2021-06-22 22:19:09.137 [massa-001@127.0.0.1]:[pid=<0.525.0> ]:[info]: Starting Horde.DynamicSupervisorImpl with name MassaProxy.GlobalSupervisor
2021-06-22 22:19:09.140 [massa-001@127.0.0.1]:[pid=<0.538.0> ]:[debug]:Initializing Entity Registry with state []
2021-06-22 22:19:09.141 [massa-001@127.0.0.1]:[pid=<0.539.0> ]:[debug]:Cache State: [cache_name: :cached_servers]
2021-06-22 22:19:09.141 [massa-001@127.0.0.1]:[pid=<0.540.0> ]:[debug]:Cache State: [cache_name: :reflection_cache]
2021-06-22 22:19:09.141 [massa-001@127.0.0.1]:[pid=<0.408.0> ]:[info]: Starting Elixir.MassaProxy.Protocol.Discovery.Worker on target function address tcp://0.0.0.0:8080
Interactive Elixir (1.12.1) - press Ctrl+C to exit (type h() ENTER for help)
iex(massa-001@127.0.0.1)1> 2021-06-22 22:19:09.264 [massa-001@127.0.0.1]:[pid=<0.541.0> ]:[info]: Call discover of cloudstate.EntityDiscovery
2021-06-22 22:19:09.273 [massa-001@127.0.0.1]:[pid=<0.541.0> ]:[info]: Got :ok in 8ms
2021-06-22 22:19:09.274 [massa-001@127.0.0.1]:[pid=<0.541.0> ]:[info]: Received EntitySpec from user function with info: %Cloudstate.EntitySpec{entities: [%Cloudstate.Entity{entity_type: "cloudstate.action.ActionProtocol", passivation_strategy: nil, persistence_id: "", service_name: "cloudstate.tck.model.action.ActionTwo"}, %Cloudstate.Entity{entity_type: "cloudstate.action.ActionProtocol", passivation_strategy: nil, persistence_id: "", service_name: "cloudstate.tck.model.eventlogeventing.EventLogSubscriberModel"}], proto: <<10, 228, 10, 10, 16, 116, 99, 107, 95, 97, 99, 116, 105, 111, 110, 46, 112, 114, 111, 116, 111, 18, 27, 99, 108, 111, 117, 100, 115, 116, 97, 116, 101, 46, 116, 99, 107, 46, 109, 111, 100, 101, 108, 46, 97, 99, 116, 105, ...>>, service_info: %Cloudstate.ServiceInfo{protocol_major_version: 0, protocol_minor_version: 2, service_name: "cloudstate.tck.model.EventSourcedTckModel", service_runtime: "go1.16.4 darwin/amd64", service_version: "0.2.0", support_library_name: "cloudstate-go-support", support_library_version: "0.2.0"}}
2021-06-22 22:19:09.429 [massa-001@127.0.0.1]:[pid=<0.1115.0> ]:[debug]:FieldOptions: %Google.Protobuf.FieldDescriptorProto{default_value: nil, extendee: nil, json_name: "javaGenerateEqualsAndHash", label: :LABEL_OPTIONAL, name: "java_generate_equals_and_hash", number: 20, oneof_index: nil, options: %Google.Protobuf.FieldOptions{__pb_extensions__: %{}, ctype: :STRING, deprecated: true, jstype: :JS_NORMAL, lazy: false, packed: nil, uninterpreted_option: [], weak: false}, type: :TYPE_BOOL, type_name: nil}
2021-06-22 22:19:09.429 [massa-001@127.0.0.1]:[pid=<0.1115.0> ]:[debug]:Entity key extension: nil
2021-06-22 22:19:09.429 [massa-001@127.0.0.1]:[pid=<0.1115.0> ]:[debug]:Has key?: nil
2021-06-22 22:19:09.483 [massa-001@127.0.0.1]:[pid=<0.1355.0> ]:[debug]:FieldOptions: %Google.Protobuf.FieldDescriptorProto{default_value: nil, extendee: nil, json_name: "id", label: :LABEL_OPTIONAL, name: "id", number: 1, oneof_index: nil, options: %Google.Protobuf.FieldOptions{__pb_extensions__: %{}, ctype: :STRING, deprecated: false, jstype: :JS_NORMAL, lazy: false, packed: nil, uninterpreted_option: [], weak: false}, type: :TYPE_STRING, type_name: nil}
2021-06-22 22:19:09.483 [massa-001@127.0.0.1]:[pid=<0.1355.0> ]:[debug]:Entity key extension: nil
2021-06-22 22:19:09.483 [massa-001@127.0.0.1]:[pid=<0.1355.0> ]:[debug]:Has key?: nil
2021-06-22 22:19:09.497 [massa-001@127.0.0.1]:[pid=<0.1415.0> ]:[debug]:FieldOptions: %Google.Protobuf.FieldDescriptorProto{default_value: nil, extendee: nil, json_name: "id", label: :LABEL_OPTIONAL, name: "id", number: 1, oneof_index: nil, options: %Google.Protobuf.FieldOptions{__pb_extensions__: %{}, ctype: :STRING, deprecated: false, jstype: :JS_NORMAL, lazy: false, packed: nil, uninterpreted_option: [], weak: false}, type: :TYPE_STRING, type_name: nil}
2021-06-22 22:19:09.497 [massa-001@127.0.0.1]:[pid=<0.1415.0> ]:[debug]:Entity key extension: nil
2021-06-22 22:19:09.497 [massa-001@127.0.0.1]:[pid=<0.1415.0> ]:[debug]:Has key?: nil
2021-06-22 22:19:09.576 [massa-001@127.0.0.1]:[pid=<0.1756.0> ]:[debug]:MehodOptions HTTP Rules: %Google.Protobuf.MethodDescriptorProto{client_streaming: false, input_type: ".cloudstate.tck.model.action.Request", name: "ProcessUnary", options: %Google.Protobuf.MethodOptions{__pb_extensions__: %{{Google.Api.PbExtension, :http} => %Google.Api.HttpRule{additional_bindings: [], body: "*", pattern: {:post, "/tck/model/action/unary"}, response_body: "", selector: ""}}, deprecated: false, idempotency_level: :IDEMPOTENCY_UNKNOWN, uninterpreted_option: []}, output_type: ".cloudstate.tck.model.action.Response", server_streaming: false}
2021-06-22 22:19:09.576 [massa-001@127.0.0.1]:[pid=<0.1756.0> ]:[debug]:MehodOptions: %Google.Api.HttpRule{additional_bindings: [], body: "*", pattern: {:post, "/tck/model/action/unary"}, response_body: "", selector: ""}
2021-06-22 22:19:09.577 [massa-001@127.0.0.1]:[pid=<0.1756.0> ]:[debug]:MehodOptions Eventing Rules: %Google.Protobuf.MethodDescriptorProto{client_streaming: false, input_type: ".cloudstate.tck.model.action.Request", name: "ProcessUnary", options: %Google.Protobuf.MethodOptions{__pb_extensions__: %{{Google.Api.PbExtension, :http} => %Google.Api.HttpRule{additional_bindings: [], body: "*", pattern: {:post, "/tck/model/action/unary"}, response_body: "", selector: ""}}, deprecated: false, idempotency_level: :IDEMPOTENCY_UNKNOWN, uninterpreted_option: []}, output_type: ".cloudstate.tck.model.action.Response", server_streaming: false}
2021-06-22 22:19:09.577 [massa-001@127.0.0.1]:[pid=<0.1756.0> ]:[debug]:Eventing extension: nil
2021-06-22 22:19:09.577 [massa-001@127.0.0.1]:[pid=<0.1756.0> ]:[debug]:MehodOptions: nil
2021-06-22 22:19:09.577 [massa-001@127.0.0.1]:[pid=<0.1756.0> ]:[debug]:Service mapped %{input_type: ".cloudstate.tck.model.action.Request", name: "ProcessUnary", options: [%{data: %Google.Api.HttpRule{additional_bindings: [], body: "*", pattern: {:post, "/tck/model/action/unary"}, response_body: "", selector: ""}, type: "http"}, %{data: nil, type: "eventing"}], output_type: ".cloudstate.tck.model.action.Response", stream_in: false, stream_out: false, streamed: false, unary: true}
2021-06-22 22:19:09.577 [massa-001@127.0.0.1]:[pid=<0.1756.0> ]:[debug]:Service mapped %{input_type: ".cloudstate.tck.model.action.Request", name: "ProcessStreamedIn", options: [nil, nil], output_type: ".cloudstate.tck.model.action.Response", stream_in: true, stream_out: false, streamed: false, unary: false}
2021-06-22 22:19:09.578 [massa-001@127.0.0.1]:[pid=<0.1756.0> ]:[debug]:Service mapped %{input_type: ".cloudstate.tck.model.action.Request", name: "ProcessStreamedOut", options: [nil, nil], output_type: ".cloudstate.tck.model.action.Response", stream_in: false, stream_out: true, streamed: false, unary: false}
2021-06-22 22:19:09.578 [massa-001@127.0.0.1]:[pid=<0.1756.0> ]:[debug]:Service mapped %{input_type: ".cloudstate.tck.model.action.Request", name: "ProcessStreamed", options: [nil, nil], output_type: ".cloudstate.tck.model.action.Response", stream_in: true, stream_out: true, streamed: true, unary: false}
2021-06-22 22:19:09.582 [massa-001@127.0.0.1]:[pid=<0.1776.0> ]:[debug]:Service mapped %{input_type: ".cloudstate.tck.model.action.OtherRequest", name: "Call", options: [nil, nil], output_type: ".cloudstate.tck.model.action.Response", stream_in: false, stream_out: false, streamed: false, unary: true}
2021-06-22 22:19:09.604 [massa-001@127.0.0.1]:[pid=<0.1876.0> ]:[debug]:MehodOptions HTTP Rules: %Google.Protobuf.MethodDescriptorProto{client_streaming: false, input_type: ".cloudstate.tck.model.eventlogeventing.EventOne", name: "ProcessEventOne", options: %Google.Protobuf.MethodOptions{__pb_extensions__: %{{Cloudstate.PbExtension, :eventing} => %Cloudstate.Eventing{in: %Cloudstate.EventSource{consumer_group: "", source: {:event_log, "eventlogeventing-one"}}, out: nil}}, deprecated: false, idempotency_level: :IDEMPOTENCY_UNKNOWN, uninterpreted_option: []}, output_type: ".cloudstate.tck.model.eventlogeventing.Response", server_streaming: false}
2021-06-22 22:19:09.604 [massa-001@127.0.0.1]:[pid=<0.1876.0> ]:[debug]:MehodOptions: nil
2021-06-22 22:19:09.604 [massa-001@127.0.0.1]:[pid=<0.1876.0> ]:[debug]:MehodOptions Eventing Rules: %Google.Protobuf.MethodDescriptorProto{client_streaming: false, input_type: ".cloudstate.tck.model.eventlogeventing.EventOne", name: "ProcessEventOne", options: %Google.Protobuf.MethodOptions{__pb_extensions__: %{{Cloudstate.PbExtension, :eventing} => %Cloudstate.Eventing{in: %Cloudstate.EventSource{consumer_group: "", source: {:event_log, "eventlogeventing-one"}}, out: nil}}, deprecated: false, idempotency_level: :IDEMPOTENCY_UNKNOWN, uninterpreted_option: []}, output_type: ".cloudstate.tck.model.eventlogeventing.Response", server_streaming: false}
2021-06-22 22:19:09.604 [massa-001@127.0.0.1]:[pid=<0.1876.0> ]:[debug]:Eventing extension: %Cloudstate.Eventing{in: %Cloudstate.EventSource{consumer_group: "", source: {:event_log, "eventlogeventing-one"}}, out: nil}
2021-06-22 22:19:09.604 [massa-001@127.0.0.1]:[pid=<0.1876.0> ]:[debug]:MehodOptions: %Cloudstate.Eventing{in: %Cloudstate.EventSource{consumer_group: "", source: {:event_log, "eventlogeventing-one"}}, out: nil}
2021-06-22 22:19:09.605 [massa-001@127.0.0.1]:[pid=<0.1876.0> ]:[debug]:Service mapped %{input_type: ".cloudstate.tck.model.eventlogeventing.EventOne", name: "ProcessEventOne", options: [%{data: nil, type: "http"}, %{data: %Cloudstate.Eventing{in: %Cloudstate.EventSource{consumer_group: "", source: {:event_log, "eventlogeventing-one"}}, out: nil}, type: "eventing"}], output_type: ".cloudstate.tck.model.eventlogeventing.Response", stream_in: false, stream_out: false, streamed: false, unary: true}
2021-06-22 22:19:09.605 [massa-001@127.0.0.1]:[pid=<0.1876.0> ]:[debug]:MehodOptions HTTP Rules: %Google.Protobuf.MethodDescriptorProto{client_streaming: false, input_type: ".cloudstate.tck.model.eventlogeventing.EventTwo", name: "ProcessEventTwo", options: %Google.Protobuf.MethodOptions{__pb_extensions__: %{{Cloudstate.PbExtension, :eventing} => %Cloudstate.Eventing{in: %Cloudstate.EventSource{consumer_group: "", source: {:event_log, "eventlogeventing-one"}}, out: nil}}, deprecated: false, idempotency_level: :IDEMPOTENCY_UNKNOWN, uninterpreted_option: []}, output_type: ".cloudstate.tck.model.eventlogeventing.Response", server_streaming: true}
2021-06-22 22:19:09.605 [massa-001@127.0.0.1]:[pid=<0.1876.0> ]:[debug]:MehodOptions: nil
2021-06-22 22:19:09.606 [massa-001@127.0.0.1]:[pid=<0.1876.0> ]:[debug]:MehodOptions Eventing Rules: %Google.Protobuf.MethodDescriptorProto{client_streaming: false, input_type: ".cloudstate.tck.model.eventlogeventing.EventTwo", name: "ProcessEventTwo", options: %Google.Protobuf.MethodOptions{__pb_extensions__: %{{Cloudstate.PbExtension, :eventing} => %Cloudstate.Eventing{in: %Cloudstate.EventSource{consumer_group: "", source: {:event_log, "eventlogeventing-one"}}, out: nil}}, deprecated: false, idempotency_level: :IDEMPOTENCY_UNKNOWN, uninterpreted_option: []}, output_type: ".cloudstate.tck.model.eventlogeventing.Response", server_streaming: true}
2021-06-22 22:19:09.606 [massa-001@127.0.0.1]:[pid=<0.1876.0> ]:[debug]:Eventing extension: %Cloudstate.Eventing{in: %Cloudstate.EventSource{consumer_group: "", source: {:event_log, "eventlogeventing-one"}}, out: nil}
2021-06-22 22:19:09.606 [massa-001@127.0.0.1]:[pid=<0.1876.0> ]:[debug]:MehodOptions: %Cloudstate.Eventing{in: %Cloudstate.EventSource{consumer_group: "", source: {:event_log, "eventlogeventing-one"}}, out: nil}
2021-06-22 22:19:09.606 [massa-001@127.0.0.1]:[pid=<0.1876.0> ]:[debug]:Service mapped %{input_type: ".cloudstate.tck.model.eventlogeventing.EventTwo", name: "ProcessEventTwo", options: [%{data: nil, type: "http"}, %{data: %Cloudstate.Eventing{in: %Cloudstate.EventSource{consumer_group: "", source: {:event_log, "eventlogeventing-one"}}, out: nil}, type: "eventing"}], output_type: ".cloudstate.tck.model.eventlogeventing.Response", stream_in: false, stream_out: true, streamed: false, unary: false}
2021-06-22 22:19:09.606 [massa-001@127.0.0.1]:[pid=<0.1876.0> ]:[debug]:Service mapped %{input_type: ".cloudstate.tck.model.eventlogeventing.EffectRequest", name: "Effect", options: [nil, nil], output_type: ".cloudstate.tck.model.eventlogeventing.Response", stream_in: false, stream_out: false, streamed: false, unary: true}
2021-06-22 22:19:09.607 [massa-001@127.0.0.1]:[pid=<0.1876.0> ]:[debug]:MehodOptions HTTP Rules: %Google.Protobuf.MethodDescriptorProto{client_streaming: false, input_type: ".google.protobuf.Any", name: "ProcessAnyEvent", options: %Google.Protobuf.MethodOptions{__pb_extensions__: %{{Cloudstate.PbExtension, :eventing} => %Cloudstate.Eventing{in: %Cloudstate.EventSource{consumer_group: "", source: {:event_log, "eventlogeventing-two"}}, out: nil}}, deprecated: false, idempotency_level: :IDEMPOTENCY_UNKNOWN, uninterpreted_option: []}, output_type: ".cloudstate.tck.model.eventlogeventing.Response", server_streaming: false}
2021-06-22 22:19:09.607 [massa-001@127.0.0.1]:[pid=<0.1876.0> ]:[debug]:MehodOptions: nil
2021-06-22 22:19:09.608 [massa-001@127.0.0.1]:[pid=<0.1876.0> ]:[debug]:MehodOptions Eventing Rules: %Google.Protobuf.MethodDescriptorProto{client_streaming: false, input_type: ".google.protobuf.Any", name: "ProcessAnyEvent", options: %Google.Protobuf.MethodOptions{__pb_extensions__: %{{Cloudstate.PbExtension, :eventing} => %Cloudstate.Eventing{in: %Cloudstate.EventSource{consumer_group: "", source: {:event_log, "eventlogeventing-two"}}, out: nil}}, deprecated: false, idempotency_level: :IDEMPOTENCY_UNKNOWN, uninterpreted_option: []}, output_type: ".cloudstate.tck.model.eventlogeventing.Response", server_streaming: false}
2021-06-22 22:19:09.608 [massa-001@127.0.0.1]:[pid=<0.1876.0> ]:[debug]:Eventing extension: %Cloudstate.Eventing{in: %Cloudstate.EventSource{consumer_group: "", source: {:event_log, "eventlogeventing-two"}}, out: nil}
2021-06-22 22:19:09.608 [massa-001@127.0.0.1]:[pid=<0.1876.0> ]:[debug]:MehodOptions: %Cloudstate.Eventing{in: %Cloudstate.EventSource{consumer_group: "", source: {:event_log, "eventlogeventing-two"}}, out: nil}
2021-06-22 22:19:09.609 [massa-001@127.0.0.1]:[pid=<0.1876.0> ]:[debug]:Service mapped %{input_type: ".google.protobuf.Any", name: "ProcessAnyEvent", options: [%{data: nil, type: "http"}, %{data: %Cloudstate.Eventing{in: %Cloudstate.EventSource{consumer_group: "", source: {:event_log, "eventlogeventing-two"}}, out: nil}, type: "eventing"}], output_type: ".cloudstate.tck.model.eventlogeventing.Response", stream_in: false, stream_out: false, streamed: false, unary: true}
2021-06-22 22:19:09.614 [massa-001@127.0.0.1]:[pid=<0.1897.0> ]:[debug]:Service mapped %{input_type: ".cloudstate.tck.model.eventlogeventing.EmitEventRequest", name: "EmitEvent", options: [nil, nil], output_type: ".google.protobuf.Empty", stream_in: false, stream_out: false, streamed: false, unary: true}
2021-06-22 22:19:09.619 [massa-001@127.0.0.1]:[pid=<0.1917.0> ]:[debug]:Service mapped %{input_type: ".cloudstate.tck.model.eventlogeventing.JsonEvent", name: "EmitJsonEvent", options: [nil, nil], output_type: ".google.protobuf.Empty", stream_in: false, stream_out: false, streamed: false, unary: true}
2021-06-22 22:19:09.638 [massa-001@127.0.0.1]:[pid=<0.538.0> ]:[debug]:Ignoring Entity join of Node: [:"massa-001@127.0.0.1"]
2021-06-22 22:19:09.763 [massa-001@127.0.0.1]:[pid=<0.2558.0> ]:[debug]:FieldOptions: %Google.Protobuf.FieldDescriptorProto{default_value: nil, extendee: nil, json_name: "javaGenerateEqualsAndHash", label: :LABEL_OPTIONAL, name: "java_generate_equals_and_hash", number: 20, oneof_index: nil, options: %Google.Protobuf.FieldOptions{__pb_extensions__: %{}, ctype: :STRING, deprecated: true, jstype: :JS_NORMAL, lazy: false, packed: nil, uninterpreted_option: [], weak: false}, type: :TYPE_BOOL, type_name: nil}
2021-06-22 22:19:09.763 [massa-001@127.0.0.1]:[pid=<0.2558.0> ]:[debug]:Entity key extension: nil
2021-06-22 22:19:09.763 [massa-001@127.0.0.1]:[pid=<0.2558.0> ]:[debug]:Has key?: nil
2021-06-22 22:19:09.817 [massa-001@127.0.0.1]:[pid=<0.2799.0> ]:[debug]:FieldOptions: %Google.Protobuf.FieldDescriptorProto{default_value: nil, extendee: nil, json_name: "id", label: :LABEL_OPTIONAL, name: "id", number: 1, oneof_index: nil, options: %Google.Protobuf.FieldOptions{__pb_extensions__: %{}, ctype: :STRING, deprecated: false, jstype: :JS_NORMAL, lazy: false, packed: nil, uninterpreted_option: [], weak: false}, type: :TYPE_STRING, type_name: nil}
2021-06-22 22:19:09.817 [massa-001@127.0.0.1]:[pid=<0.2799.0> ]:[debug]:Entity key extension: nil
2021-06-22 22:19:09.817 [massa-001@127.0.0.1]:[pid=<0.2799.0> ]:[debug]:Has key?: nil
2021-06-22 22:19:09.830 [massa-001@127.0.0.1]:[pid=<0.2859.0> ]:[debug]:FieldOptions: %Google.Protobuf.FieldDescriptorProto{default_value: nil, extendee: nil, json_name: "id", label: :LABEL_OPTIONAL, name: "id", number: 1, oneof_index: nil, options: %Google.Protobuf.FieldOptions{__pb_extensions__: %{}, ctype: :STRING, deprecated: false, jstype: :JS_NORMAL, lazy: false, packed: nil, uninterpreted_option: [], weak: false}, type: :TYPE_STRING, type_name: nil}
2021-06-22 22:19:09.830 [massa-001@127.0.0.1]:[pid=<0.2859.0> ]:[debug]:Entity key extension: nil
2021-06-22 22:19:09.830 [massa-001@127.0.0.1]:[pid=<0.2859.0> ]:[debug]:Has key?: nil
2021-06-22 22:19:09.908 [massa-001@127.0.0.1]:[pid=<0.3199.0> ]:[debug]:MehodOptions HTTP Rules: %Google.Protobuf.MethodDescriptorProto{client_streaming: false, input_type: ".cloudstate.tck.model.action.Request", name: "ProcessUnary", options: %Google.Protobuf.MethodOptions{__pb_extensions__: %{{Google.Api.PbExtension, :http} => %Google.Api.HttpRule{additional_bindings: [], body: "*", pattern: {:post, "/tck/model/action/unary"}, response_body: "", selector: ""}}, deprecated: false, idempotency_level: :IDEMPOTENCY_UNKNOWN, uninterpreted_option: []}, output_type: ".cloudstate.tck.model.action.Response", server_streaming: false}
2021-06-22 22:19:09.909 [massa-001@127.0.0.1]:[pid=<0.3199.0> ]:[debug]:MehodOptions: %Google.Api.HttpRule{additional_bindings: [], body: "*", pattern: {:post, "/tck/model/action/unary"}, response_body: "", selector: ""}
2021-06-22 22:19:09.909 [massa-001@127.0.0.1]:[pid=<0.3199.0> ]:[debug]:MehodOptions Eventing Rules: %Google.Protobuf.MethodDescriptorProto{client_streaming: false, input_type: ".cloudstate.tck.model.action.Request", name: "ProcessUnary", options: %Google.Protobuf.MethodOptions{__pb_extensions__: %{{Google.Api.PbExtension, :http} => %Google.Api.HttpRule{additional_bindings: [], body: "*", pattern: {:post, "/tck/model/action/unary"}, response_body: "", selector: ""}}, deprecated: false, idempotency_level: :IDEMPOTENCY_UNKNOWN, uninterpreted_option: []}, output_type: ".cloudstate.tck.model.action.Response", server_streaming: false}
2021-06-22 22:19:09.909 [massa-001@127.0.0.1]:[pid=<0.3199.0> ]:[debug]:Eventing extension: nil
2021-06-22 22:19:09.909 [massa-001@127.0.0.1]:[pid=<0.3199.0> ]:[debug]:MehodOptions: nil
2021-06-22 22:19:09.909 [massa-001@127.0.0.1]:[pid=<0.3199.0> ]:[debug]:Service mapped %{input_type: ".cloudstate.tck.model.action.Request", name: "ProcessUnary", options: [%{data: %Google.Api.HttpRule{additional_bindings: [], body: "*", pattern: {:post, "/tck/model/action/unary"}, response_body: "", selector: ""}, type: "http"}, %{data: nil, type: "eventing"}], output_type: ".cloudstate.tck.model.action.Response", stream_in: false, stream_out: false, streamed: false, unary: true}
2021-06-22 22:19:09.910 [massa-001@127.0.0.1]:[pid=<0.3199.0> ]:[debug]:Service mapped %{input_type: ".cloudstate.tck.model.action.Request", name: "ProcessStreamedIn", options: [nil, nil], output_type: ".cloudstate.tck.model.action.Response", stream_in: true, stream_out: false, streamed: false, unary: false}
2021-06-22 22:19:09.910 [massa-001@127.0.0.1]:[pid=<0.3199.0> ]:[debug]:Service mapped %{input_type: ".cloudstate.tck.model.action.Request", name: "ProcessStreamedOut", options: [nil, nil], output_type: ".cloudstate.tck.model.action.Response", stream_in: false, stream_out: true, streamed: false, unary: false}
2021-06-22 22:19:09.910 [massa-001@127.0.0.1]:[pid=<0.3199.0> ]:[debug]:Service mapped %{input_type: ".cloudstate.tck.model.action.Request", name: "ProcessStreamed", options: [nil, nil], output_type: ".cloudstate.tck.model.action.Response", stream_in: true, stream_out: true, streamed: true, unary: false}
2021-06-22 22:19:09.914 [massa-001@127.0.0.1]:[pid=<0.3220.0> ]:[debug]:Service mapped %{input_type: ".cloudstate.tck.model.action.OtherRequest", name: "Call", options: [nil, nil], output_type: ".cloudstate.tck.model.action.Response", stream_in: false, stream_out: false, streamed: false, unary: true}
2021-06-22 22:19:09.939 [massa-001@127.0.0.1]:[pid=<0.3320.0> ]:[debug]:MehodOptions HTTP Rules: %Google.Protobuf.MethodDescriptorProto{client_streaming: false, input_type: ".cloudstate.tck.model.eventlogeventing.EventOne", name: "ProcessEventOne", options: %Google.Protobuf.MethodOptions{__pb_extensions__: %{{Cloudstate.PbExtension, :eventing} => %Cloudstate.Eventing{in: %Cloudstate.EventSource{consumer_group: "", source: {:event_log, "eventlogeventing-one"}}, out: nil}}, deprecated: false, idempotency_level: :IDEMPOTENCY_UNKNOWN, uninterpreted_option: []}, output_type: ".cloudstate.tck.model.eventlogeventing.Response", server_streaming: false}
2021-06-22 22:19:09.939 [massa-001@127.0.0.1]:[pid=<0.3320.0> ]:[debug]:MehodOptions: nil
2021-06-22 22:19:09.940 [massa-001@127.0.0.1]:[pid=<0.3320.0> ]:[debug]:MehodOptions Eventing Rules: %Google.Protobuf.MethodDescriptorProto{client_streaming: false, input_type: ".cloudstate.tck.model.eventlogeventing.EventOne", name: "ProcessEventOne", options: %Google.Protobuf.MethodOptions{__pb_extensions__: %{{Cloudstate.PbExtension, :eventing} => %Cloudstate.Eventing{in: %Cloudstate.EventSource{consumer_group: "", source: {:event_log, "eventlogeventing-one"}}, out: nil}}, deprecated: false, idempotency_level: :IDEMPOTENCY_UNKNOWN, uninterpreted_option: []}, output_type: ".cloudstate.tck.model.eventlogeventing.Response", server_streaming: false}
2021-06-22 22:19:09.940 [massa-001@127.0.0.1]:[pid=<0.3320.0> ]:[debug]:Eventing extension: %Cloudstate.Eventing{in: %Cloudstate.EventSource{consumer_group: "", source: {:event_log, "eventlogeventing-one"}}, out: nil}
2021-06-22 22:19:09.940 [massa-001@127.0.0.1]:[pid=<0.3320.0> ]:[debug]:MehodOptions: %Cloudstate.Eventing{in: %Cloudstate.EventSource{consumer_group: "", source: {:event_log, "eventlogeventing-one"}}, out: nil}
2021-06-22 22:19:09.940 [massa-001@127.0.0.1]:[pid=<0.3320.0> ]:[debug]:Service mapped %{input_type: ".cloudstate.tck.model.eventlogeventing.EventOne", name: "ProcessEventOne", options: [%{data: nil, type: "http"}, %{data: %Cloudstate.Eventing{in: %Cloudstate.EventSource{consumer_group: "", source: {:event_log, "eventlogeventing-one"}}, out: nil}, type: "eventing"}], output_type: ".cloudstate.tck.model.eventlogeventing.Response", stream_in: false, stream_out: false, streamed: false, unary: true}
2021-06-22 22:19:09.941 [massa-001@127.0.0.1]:[pid=<0.3320.0> ]:[debug]:MehodOptions HTTP Rules: %Google.Protobuf.MethodDescriptorProto{client_streaming: false, input_type: ".cloudstate.tck.model.eventlogeventing.EventTwo", name: "ProcessEventTwo", options: %Google.Protobuf.MethodOptions{__pb_extensions__: %{{Cloudstate.PbExtension, :eventing} => %Cloudstate.Eventing{in: %Cloudstate.EventSource{consumer_group: "", source: {:event_log, "eventlogeventing-one"}}, out: nil}}, deprecated: false, idempotency_level: :IDEMPOTENCY_UNKNOWN, uninterpreted_option: []}, output_type: ".cloudstate.tck.model.eventlogeventing.Response", server_streaming: true}
2021-06-22 22:19:09.941 [massa-001@127.0.0.1]:[pid=<0.3320.0> ]:[debug]:MehodOptions: nil
2021-06-22 22:19:09.941 [massa-001@127.0.0.1]:[pid=<0.3320.0> ]:[debug]:MehodOptions Eventing Rules: %Google.Protobuf.MethodDescriptorProto{client_streaming: false, input_type: ".cloudstate.tck.model.eventlogeventing.EventTwo", name: "ProcessEventTwo", options: %Google.Protobuf.MethodOptions{__pb_extensions__: %{{Cloudstate.PbExtension, :eventing} => %Cloudstate.Eventing{in: %Cloudstate.EventSource{consumer_group: "", source: {:event_log, "eventlogeventing-one"}}, out: nil}}, deprecated: false, idempotency_level: :IDEMPOTENCY_UNKNOWN, uninterpreted_option: []}, output_type: ".cloudstate.tck.model.eventlogeventing.Response", server_streaming: true}
2021-06-22 22:19:09.941 [massa-001@127.0.0.1]:[pid=<0.3320.0> ]:[debug]:Eventing extension: %Cloudstate.Eventing{in: %Cloudstate.EventSource{consumer_group: "", source: {:event_log, "eventlogeventing-one"}}, out: nil}
2021-06-22 22:19:09.942 [massa-001@127.0.0.1]:[pid=<0.3320.0> ]:[debug]:MehodOptions: %Cloudstate.Eventing{in: %Cloudstate.EventSource{consumer_group: "", source: {:event_log, "eventlogeventing-one"}}, out: nil}
2021-06-22 22:19:09.942 [massa-001@127.0.0.1]:[pid=<0.3320.0> ]:[debug]:Service mapped %{input_type: ".cloudstate.tck.model.eventlogeventing.EventTwo", name: "ProcessEventTwo", options: [%{data: nil, type: "http"}, %{data: %Cloudstate.Eventing{in: %Cloudstate.EventSource{consumer_group: "", source: {:event_log, "eventlogeventing-one"}}, out: nil}, type: "eventing"}], output_type: ".cloudstate.tck.model.eventlogeventing.Response", stream_in: false, stream_out: true, streamed: false, unary: false}
2021-06-22 22:19:09.942 [massa-001@127.0.0.1]:[pid=<0.3320.0> ]:[debug]:Service mapped %{input_type: ".cloudstate.tck.model.eventlogeventing.EffectRequest", name: "Effect", options: [nil, nil], output_type: ".cloudstate.tck.model.eventlogeventing.Response", stream_in: false, stream_out: false, streamed: false, unary: true}
2021-06-22 22:19:09.943 [massa-001@127.0.0.1]:[pid=<0.3320.0> ]:[debug]:MehodOptions HTTP Rules: %Google.Protobuf.MethodDescriptorProto{client_streaming: false, input_type: ".google.protobuf.Any", name: "ProcessAnyEvent", options: %Google.Protobuf.MethodOptions{__pb_extensions__: %{{Cloudstate.PbExtension, :eventing} => %Cloudstate.Eventing{in: %Cloudstate.EventSource{consumer_group: "", source: {:event_log, "eventlogeventing-two"}}, out: nil}}, deprecated: false, idempotency_level: :IDEMPOTENCY_UNKNOWN, uninterpreted_option: []}, output_type: ".cloudstate.tck.model.eventlogeventing.Response", server_streaming: false}
2021-06-22 22:19:09.943 [massa-001@127.0.0.1]:[pid=<0.3320.0> ]:[debug]:MehodOptions: nil
2021-06-22 22:19:09.943 [massa-001@127.0.0.1]:[pid=<0.3320.0> ]:[debug]:MehodOptions Eventing Rules: %Google.Protobuf.MethodDescriptorProto{client_streaming: false, input_type: ".google.protobuf.Any", name: "ProcessAnyEvent", options: %Google.Protobuf.MethodOptions{__pb_extensions__: %{{Cloudstate.PbExtension, :eventing} => %Cloudstate.Eventing{in: %Cloudstate.EventSource{consumer_group: "", source: {:event_log, "eventlogeventing-two"}}, out: nil}}, deprecated: false, idempotency_level: :IDEMPOTENCY_UNKNOWN, uninterpreted_option: []}, output_type: ".cloudstate.tck.model.eventlogeventing.Response", server_streaming: false}
2021-06-22 22:19:09.943 [massa-001@127.0.0.1]:[pid=<0.3320.0> ]:[debug]:Eventing extension: %Cloudstate.Eventing{in: %Cloudstate.EventSource{consumer_group: "", source: {:event_log, "eventlogeventing-two"}}, out: nil}
2021-06-22 22:19:09.944 [massa-001@127.0.0.1]:[pid=<0.3320.0> ]:[debug]:MehodOptions: %Cloudstate.Eventing{in: %Cloudstate.EventSource{consumer_group: "", source: {:event_log, "eventlogeventing-two"}}, out: nil}
2021-06-22 22:19:09.944 [massa-001@127.0.0.1]:[pid=<0.3320.0> ]:[debug]:Service mapped %{input_type: ".google.protobuf.Any", name: "ProcessAnyEvent", options: [%{data: nil, type: "http"}, %{data: %Cloudstate.Eventing{in: %Cloudstate.EventSource{consumer_group: "", source: {:event_log, "eventlogeventing-two"}}, out: nil}, type: "eventing"}], output_type: ".cloudstate.tck.model.eventlogeventing.Response", stream_in: false, stream_out: false, streamed: false, unary: true}
2021-06-22 22:19:09.948 [massa-001@127.0.0.1]:[pid=<0.3340.0> ]:[debug]:Service mapped %{input_type: ".cloudstate.tck.model.eventlogeventing.EmitEventRequest", name: "EmitEvent", options: [nil, nil], output_type: ".google.protobuf.Empty", stream_in: false, stream_out: false, streamed: false, unary: true}
2021-06-22 22:19:09.952 [massa-001@127.0.0.1]:[pid=<0.3360.0> ]:[debug]:Service mapped %{input_type: ".cloudstate.tck.model.eventlogeventing.JsonEvent", name: "EmitJsonEvent", options: [nil, nil], output_type: ".google.protobuf.Empty", stream_in: false, stream_out: false, streamed: false, unary: true}
2021-06-22 22:19:09.967 [massa-001@127.0.0.1]:[pid=<0.541.0> ]:[debug]:Found 2 Entities to processing.
2021-06-22 22:19:09.967 [massa-001@127.0.0.1]:[pid=<0.538.0> ]:[debug]:Ignoring Entity join of Node: [:"massa-001@127.0.0.1"]
2021-06-22 22:19:12.095 [massa-001@127.0.0.1]:[pid=<0.541.0> ]:[debug]:Compiled module: {{:module, Cloudstate.Tck.Model.Action.ActionTwo.Stub, <<70, 79, 82, 49, 0, 0, 9, 116, 66, 69, 65, 77, 65, 116, 85, 56, 0, 0, 0, 251, 0, 0, 0, 17, 49, 69, 108, 105, 120, 105, 114, 46, 67, 108, 111, 117, 100, 115, 116, 97, 116, 101, 46, 84, 99, 107, ...>>, :ok}, []}
warning: redefining module Google.Api.PbExtension (current version loaded from _build/dev/lib/cloudstate_protocol/ebin/Elixir.Google.Api.PbExtension.beam)
nofile:1
2021-06-22 22:19:12.165 [massa-001@127.0.0.1]:[pid=<0.541.0> ]:[debug]:Compiled module: {{:module, Google.Api.PbExtension, <<70, 79, 82, 49, 0, 0, 13, 192, 66, 69, 65, 77, 65, 116, 85, 56, 0, 0, 1, 62, 0, 0, 0, 25, 29, 69, 108, 105, 120, 105, 114, 46, 71, 111, 111, 103, 108, 101, 46, 65, 112, 105, 46, 80, 98, 69, ...>>, :ok}, []}
warning: redefining module Google.Api.Http (current version loaded from _build/dev/lib/cloudstate_protocol/ebin/Elixir.Google.Api.Http.beam)
nofile:1
warning: redefining module Google.Api.HttpRule (current version loaded from _build/dev/lib/cloudstate_protocol/ebin/Elixir.Google.Api.HttpRule.beam)
nofile:29
warning: redefining module Google.Api.CustomHttpPattern (current version loaded from _build/dev/lib/cloudstate_protocol/ebin/Elixir.Google.Api.CustomHttpPattern.beam)
nofile:80
2021-06-22 22:19:12.632 [massa-001@127.0.0.1]:[pid=<0.541.0> ]:[debug]:Compiled module: {{:module, Google.Api.CustomHttpPattern, <<70, 79, 82, 49, 0, 0, 18, 36, 66, 69, 65, 77, 65, 116, 85, 56, 0, 0, 1, 165, 0, 0, 0, 32, 35, 69, 108, 105, 120, 105, 114, 46, 71, 111, 111, 103, 108, 101, 46, 65, 112, 105, 46, 67, 117, 115, ...>>, :ok}, []}
warning: redefining module Google.Protobuf.FieldDescriptorProto.Type (current version loaded from _build/dev/lib/protobuf/ebin/Elixir.Google.Protobuf.FieldDescriptorProto.Type.beam)
nofile:1
warning: redefining module Google.Protobuf.FieldDescriptorProto.Label (current version loaded from _build/dev/lib/protobuf/ebin/Elixir.Google.Protobuf.FieldDescriptorProto.Label.beam)
nofile:83
warning: redefining module Google.Protobuf.FileOptions.OptimizeMode (current version loaded from _build/dev/lib/protobuf/ebin/Elixir.Google.Protobuf.FileOptions.OptimizeMode.beam)
nofile:104
warning: redefining module Google.Protobuf.FieldOptions.CType (current version loaded from _build/dev/lib/protobuf/ebin/Elixir.Google.Protobuf.FieldOptions.CType.beam)
nofile:125
warning: redefining module Google.Protobuf.FieldOptions.JSType (current version loaded from _build/dev/lib/protobuf/ebin/Elixir.Google.Protobuf.FieldOptions.JSType.beam)
nofile:146
warning: redefining module Google.Protobuf.MethodOptions.IdempotencyLevel (current version loaded from _build/dev/lib/protobuf/ebin/Elixir.Google.Protobuf.MethodOptions.IdempotencyLevel.beam)
nofile:167
warning: redefining module Google.Protobuf.FileDescriptorSet (current version loaded from _build/dev/lib/protobuf/ebin/Elixir.Google.Protobuf.FileDescriptorSet.beam)
nofile:189
warning: redefining module Google.Protobuf.FileDescriptorProto (current version loaded from _build/dev/lib/protobuf/ebin/Elixir.Google.Protobuf.FileDescriptorProto.beam)
nofile:212
warning: redefining module Google.Protobuf.DescriptorProto.ExtensionRange (current version loaded from _build/dev/lib/protobuf/ebin/Elixir.Google.Protobuf.DescriptorProto.ExtensionRange.beam)
nofile:298
warning: redefining module Google.Protobuf.DescriptorProto.ReservedRange (current version loaded from _build/dev/lib/protobuf/ebin/Elixir.Google.Protobuf.DescriptorProto.ReservedRange.beam)
nofile:328
warning: redefining module Google.Protobuf.DescriptorProto (current version loaded from _build/dev/lib/protobuf/ebin/Elixir.Google.Protobuf.DescriptorProto.beam)
nofile:352
warning: redefining module Google.Protobuf.ExtensionRangeOptions (current version loaded from _build/dev/lib/protobuf/ebin/Elixir.Google.Protobuf.ExtensionRangeOptions.beam)
nofile:442
warning: redefining module Google.Protobuf.FieldDescriptorProto (current version loaded from _build/dev/lib/protobuf/ebin/Elixir.Google.Protobuf.FieldDescriptorProto.beam)
nofile:471
warning: redefining module Google.Protobuf.OneofDescriptorProto (current version loaded from _build/dev/lib/protobuf/ebin/Elixir.Google.Protobuf.OneofDescriptorProto.beam)
nofile:562
warning: redefining module Google.Protobuf.EnumDescriptorProto.EnumReservedRange (current version loaded from _build/dev/lib/protobuf/ebin/Elixir.Google.Protobuf.EnumDescriptorProto.EnumReservedRange.beam)
nofile:588
warning: redefining module Google.Protobuf.EnumDescriptorProto (current version loaded from _build/dev/lib/protobuf/ebin/Elixir.Google.Protobuf.EnumDescriptorProto.beam)
nofile:612
warning: redefining module Google.Protobuf.EnumValueDescriptorProto (current version loaded from _build/dev/lib/protobuf/ebin/Elixir.Google.Protobuf.EnumValueDescriptorProto.beam)
nofile:661
warning: redefining module Google.Protobuf.ServiceDescriptorProto (current version loaded from _build/dev/lib/protobuf/ebin/Elixir.Google.Protobuf.ServiceDescriptorProto.beam)
nofile:691
warning: redefining module Google.Protobuf.MethodDescriptorProto (current version loaded from _build/dev/lib/protobuf/ebin/Elixir.Google.Protobuf.MethodDescriptorProto.beam)
nofile:723
warning: redefining module Google.Protobuf.FileOptions (current version loaded from _build/dev/lib/protobuf/ebin/Elixir.Google.Protobuf.FileOptions.beam)
nofile:766
warning: redefining module Google.Protobuf.MessageOptions (current version loaded from _build/dev/lib/protobuf/ebin/Elixir.Google.Protobuf.MessageOptions.beam)
nofile:916
warning: redefining module Google.Protobuf.FieldOptions (current version loaded from _build/dev/lib/protobuf/ebin/Elixir.Google.Protobuf.FieldOptions.beam)
nofile:971
warning: redefining module Google.Protobuf.OneofOptions (current version loaded from _build/dev/lib/protobuf/ebin/Elixir.Google.Protobuf.OneofOptions.beam)
nofile:1049
warning: redefining module Google.Protobuf.EnumOptions (current version loaded from _build/dev/lib/protobuf/ebin/Elixir.Google.Protobuf.EnumOptions.beam)
nofile:1078
warning: redefining module Google.Protobuf.EnumValueOptions (current version loaded from _build/dev/lib/protobuf/ebin/Elixir.Google.Protobuf.EnumValueOptions.beam)
nofile:1114
warning: redefining module Google.Protobuf.ServiceOptions (current version loaded from _build/dev/lib/protobuf/ebin/Elixir.Google.Protobuf.ServiceOptions.beam)
nofile:1147
warning: redefining module Google.Protobuf.MethodOptions (current version loaded from _build/dev/lib/protobuf/ebin/Elixir.Google.Protobuf.MethodOptions.beam)
nofile:1180
warning: redefining module Google.Protobuf.UninterpretedOption.NamePart (current version loaded from _build/dev/lib/protobuf/ebin/Elixir.Google.Protobuf.UninterpretedOption.NamePart.beam)
nofile:1230
warning: redefining module Google.Protobuf.UninterpretedOption (current version loaded from _build/dev/lib/protobuf/ebin/Elixir.Google.Protobuf.UninterpretedOption.beam)
nofile:1255
warning: redefining module Google.Protobuf.SourceCodeInfo.Location (current version loaded from _build/dev/lib/protobuf/ebin/Elixir.Google.Protobuf.SourceCodeInfo.Location.beam)
nofile:1315
warning: redefining module Google.Protobuf.SourceCodeInfo (current version loaded from _build/dev/lib/protobuf/ebin/Elixir.Google.Protobuf.SourceCodeInfo.beam)
nofile:1353
warning: redefining module Google.Protobuf.GeneratedCodeInfo.Annotation (current version loaded from _build/dev/lib/protobuf/ebin/Elixir.Google.Protobuf.GeneratedCodeInfo.Annotation.beam)
nofile:1388
warning: redefining module Google.Protobuf.GeneratedCodeInfo (current version loaded from _build/dev/lib/protobuf/ebin/Elixir.Google.Protobuf.GeneratedCodeInfo.beam)
nofile:1419
2021-06-22 22:19:17.602 [massa-001@127.0.0.1]:[pid=<0.541.0> ]:[debug]:Compiled module: {{:module, Google.Protobuf.GeneratedCodeInfo, <<70, 79, 82, 49, 0, 0, 19, 152, 66, 69, 65, 77, 65, 116, 85, 56, 0, 0, 1, 170, 0, 0, 0, 32, 40, 69, 108, 105, 120, 105, 114, 46, 71, 111, 111, 103, 108, 101, 46, 80, 114, 111, 116, 111, 98, 117, ...>>, :ok}, []}
2021-06-22 22:19:19.419 [massa-001@127.0.0.1]:[pid=<0.541.0> ]:[debug]:Compiled module: {{:module, Cloudstate.Tck.Model.Eventlogeventing.EventSourcedEntityTwo.Stub, <<70, 79, 82, 49, 0, 0, 10, 28, 66, 69, 65, 77, 65, 116, 85, 56, 0, 0, 1, 55, 0, 0, 0, 18, 71, 69, 108, 105, 120, 105, 114, 46, 67, 108, 111, 117, 100, 115, 116, 97, 116, 101, 46, 84, 99, 107, ...>>, :ok}, []}
warning: redefining module Google.Protobuf.Any (current version loaded from _build/dev/lib/google_protos/ebin/Elixir.Google.Protobuf.Any.beam)
nofile:1
2021-06-22 22:19:19.543 [massa-001@127.0.0.1]:[pid=<0.541.0> ]:[debug]:Compiled module: {{:module, Google.Protobuf.Any, <<70, 79, 82, 49, 0, 0, 17, 248, 66, 69, 65, 77, 65, 116, 85, 56, 0, 0, 1, 156, 0, 0, 0, 32, 26, 69, 108, 105, 120, 105, 114, 46, 71, 111, 111, 103, 108, 101, 46, 80, 114, 111, 116, 111, 98, 117, ...>>, :ok}, []}
warning: redefining module Google.Protobuf.Empty (current version loaded from _build/dev/lib/google_protos/ebin/Elixir.Google.Protobuf.Empty.beam)
nofile:1
2021-06-22 22:19:19.672 [massa-001@127.0.0.1]:[pid=<0.541.0> ]:[debug]:Compiled module: {{:module, Google.Protobuf.Empty, <<70, 79, 82, 49, 0, 0, 15, 180, 66, 69, 65, 77, 65, 116, 85, 56, 0, 0, 1, 158, 0, 0, 0, 32, 28, 69, 108, 105, 120, 105, 114, 46, 71, 111, 111, 103, 108, 101, 46, 80, 114, 111, 116, 111, 98, 117, ...>>, {:descriptor, 0}}, []}
warning: redefining module Cloudstate.Eventing (current version loaded from _build/dev/lib/cloudstate_protocol/ebin/Elixir.Cloudstate.Eventing.beam)
nofile:1
warning: redefining module Cloudstate.EventSource (current version loaded from _build/dev/lib/cloudstate_protocol/ebin/Elixir.Cloudstate.EventSource.beam)
nofile:27
warning: redefining module Cloudstate.EventDestination (current version loaded from _build/dev/lib/cloudstate_protocol/ebin/Elixir.Cloudstate.EventDestination.beam)
nofile:57
warning: redefining module Cloudstate.PbExtension (current version loaded from _build/dev/lib/cloudstate_protocol/ebin/Elixir.Cloudstate.PbExtension.beam)
nofile:81
2021-06-22 22:19:20.127 [massa-001@127.0.0.1]:[pid=<0.541.0> ]:[debug]:Compiled module: {{:module, Cloudstate.PbExtension, <<70, 79, 82, 49, 0, 0, 13, 196, 66, 69, 65, 77, 65, 116, 85, 56, 0, 0, 1, 62, 0, 0, 0, 25, 29, 69, 108, 105, 120, 105, 114, 46, 67, 108, 111, 117, 100, 115, 116, 97, 116, 101, 46, 80, 98, 69, ...>>, :ok}, []}
warning: redefining module Cloudstate.PbExtension (current version defined in memory)
nofile:1
2021-06-22 22:19:20.199 [massa-001@127.0.0.1]:[pid=<0.541.0> ]:[debug]:Compiled module: {{:module, Cloudstate.PbExtension, <<70, 79, 82, 49, 0, 0, 13, 180, 66, 69, 65, 77, 65, 116, 85, 56, 0, 0, 1, 62, 0, 0, 0, 25, 29, 69, 108, 105, 120, 105, 114, 46, 67, 108, 111, 117, 100, 115, 116, 97, 116, 101, 46, 80, 98, 69, ...>>, :ok}, []}
2021-06-22 22:19:20.206 [massa-001@127.0.0.1]:[pid=<0.541.0> ]:[info]: Generating Service Cloudstate.Tck.Model.Action.ActionTwo.Service with Methods: ["process_unary", "process_streamed_in", "process_streamed_out", "process_streamed"]
2021-06-22 22:19:20.215 [massa-001@127.0.0.1]:[pid=<0.541.0> ]:[debug]:Service defined: defmodule Cloudstate.Tck.Model.Action.ActionTwo.Service.ProxyService do
@moduledoc """
This Cloudstate.Tck.Model.Action.ActionTwo.Service.ProxyService module only passes
incoming gRPC requests to the respective Entity handlers.
"""
@moduledoc since: "0.1.0"
use GRPC.Server, service: Cloudstate.Tck.Model.Action.ActionTwo.Service
@spec process_unary(Cloudstate.Tck.Model.Action.Request.t(), GRPC.Server.Stream.t()) :: Cloudstate.Tck.Model.Action.Response.t()
def process_unary(message, stream),
do:
MassaProxy.Server.Dispatcher.dispatch(%{
service_name: "cloudstate.tck.model.action.ActionTwo",
entity_type: "cloudstate.action.ActionProtocol",
persistence_id: "",
original_method: "ProcessUnary",
message: message,
stream: stream,
input_type: Cloudstate.Tck.Model.Action.Request,
output_type: Cloudstate.Tck.Model.Action.Response,
request_type: "unary"
})
@spec process_streamed_in(Cloudstate.Tck.Model.Action.Request.t(), GRPC.Server.Stream.t()) :: Cloudstate.Tck.Model.Action.Response.t()
def process_streamed_in(message, stream),
do:
MassaProxy.Server.Dispatcher.dispatch(%{
service_name: "cloudstate.tck.model.action.ActionTwo",
entity_type: "cloudstate.action.ActionProtocol",
persistence_id: "",
original_method: "ProcessStreamedIn",
message: message,
stream: stream,
input_type: Cloudstate.Tck.Model.Action.Request,
output_type: Cloudstate.Tck.Model.Action.Response,
request_type: "stream_in"
})
@spec process_streamed_out(Cloudstate.Tck.Model.Action.Request.t(), GRPC.Server.Stream.t()) :: Cloudstate.Tck.Model.Action.Response.t()
def process_streamed_out(message, stream),
do:
MassaProxy.Server.Dispatcher.dispatch(%{
service_name: "cloudstate.tck.model.action.ActionTwo",
entity_type: "cloudstate.action.ActionProtocol",
persistence_id: "",
original_method: "ProcessStreamedOut",
message: message,
stream: stream,
input_type: Cloudstate.Tck.Model.Action.Request,
output_type: Cloudstate.Tck.Model.Action.Response,
request_type: "stream_out"
})
@spec process_streamed(Cloudstate.Tck.Model.Action.Request.t(), GRPC.Server.Stream.t()) :: Cloudstate.Tck.Model.Action.Response.t()
def process_streamed(message, stream),
do:
MassaProxy.Server.Dispatcher.dispatch(%{
service_name: "cloudstate.tck.model.action.ActionTwo",
entity_type: "cloudstate.action.ActionProtocol",
persistence_id: "",
original_method: "ProcessStreamed",
message: message,
stream: stream,
input_type: Cloudstate.Tck.Model.Action.Request,
output_type: Cloudstate.Tck.Model.Action.Response,
request_type: "streamed"
})
end
2021-06-22 22:19:20.361 [massa-001@127.0.0.1]:[pid=<0.541.0> ]:[debug]:Service compiled: {{:module, Cloudstate.Tck.Model.Action.ActionTwo.Service.ProxyService, <<70, 79, 82, 49, 0, 0, 16, 72, 66, 69, 65, 77, 65, 116, 85, 56, 0, 0, 2, 138, 0, 0, 0, 42, 65, 69, 108, 105, 120, 105, 114, 46, 67, 108, 111, 117, 100, 115, 116, 97, 116, 101, 46, 84, 99, 107, ...>>, {:process_streamed, 2}}, []}
2021-06-22 22:19:20.366 [massa-001@127.0.0.1]:[pid=<0.541.0> ]:[info]: Generating Service Cloudstate.Tck.Model.Eventlogeventing.EventLogSubscriberModel.Service with Methods: ["process_unary", "process_streamed_in", "process_streamed_out", "process_streamed"]
2021-06-22 22:19:20.374 [massa-001@127.0.0.1]:[pid=<0.541.0> ]:[debug]:Service defined: defmodule Cloudstate.Tck.Model.Eventlogeventing.EventLogSubscriberModel.Service.ProxyService do
@moduledoc """
This Cloudstate.Tck.Model.Eventlogeventing.EventLogSubscriberModel.Service.ProxyService module only passes
incoming gRPC requests to the respective Entity handlers.
"""
@moduledoc since: "0.1.0"
use GRPC.Server, service: Cloudstate.Tck.Model.Eventlogeventing.EventLogSubscriberModel.Service
@spec process_unary(Cloudstate.Tck.Model.Action.Request.t(), GRPC.Server.Stream.t()) :: Cloudstate.Tck.Model.Action.Response.t()
def process_unary(message, stream),
do:
MassaProxy.Server.Dispatcher.dispatch(%{
service_name: "cloudstate.tck.model.eventlogeventing.EventLogSubscriberModel",
entity_type: "cloudstate.action.ActionProtocol",
persistence_id: "",
original_method: "ProcessUnary",
message: message,
stream: stream,
input_type: Cloudstate.Tck.Model.Action.Request,
output_type: Cloudstate.Tck.Model.Action.Response,
request_type: "unary"
})
@spec process_streamed_in(Cloudstate.Tck.Model.Action.Request.t(), GRPC.Server.Stream.t()) :: Cloudstate.Tck.Model.Action.Response.t()
def process_streamed_in(message, stream),
do:
MassaProxy.Server.Dispatcher.dispatch(%{
service_name: "cloudstate.tck.model.eventlogeventing.EventLogSubscriberModel",
entity_type: "cloudstate.action.ActionProtocol",
persistence_id: "",
original_method: "ProcessStreamedIn",
message: message,
stream: stream,
input_type: Cloudstate.Tck.Model.Action.Request,
output_type: Cloudstate.Tck.Model.Action.Response,
request_type: "stream_in"
})
@spec process_streamed_out(Cloudstate.Tck.Model.Action.Request.t(), GRPC.Server.Stream.t()) :: Cloudstate.Tck.Model.Action.Response.t()
def process_streamed_out(message, stream),
do:
MassaProxy.Server.Dispatcher.dispatch(%{
service_name: "cloudstate.tck.model.eventlogeventing.EventLogSubscriberModel",
entity_type: "cloudstate.action.ActionProtocol",
persistence_id: "",
original_method: "ProcessStreamedOut",
message: message,
stream: stream,
input_type: Cloudstate.Tck.Model.Action.Request,
output_type: Cloudstate.Tck.Model.Action.Response,
request_type: "stream_out"
})
@spec process_streamed(Cloudstate.Tck.Model.Action.Request.t(), GRPC.Server.Stream.t()) :: Cloudstate.Tck.Model.Action.Response.t()
def process_streamed(message, stream),
do:
MassaProxy.Server.Dispatcher.dispatch(%{
service_name: "cloudstate.tck.model.eventlogeventing.EventLogSubscriberModel",
entity_type: "cloudstate.action.ActionProtocol",
persistence_id: "",
original_method: "ProcessStreamed",
message: message,
stream: stream,
input_type: Cloudstate.Tck.Model.Action.Request,
output_type: Cloudstate.Tck.Model.Action.Response,
request_type: "streamed"
})
end
2021-06-22 22:19:20.549 [massa-001@127.0.0.1]:[pid=<0.541.0> ]:[debug]:Service compiled: {{:module, Cloudstate.Tck.Model.Eventlogeventing.EventLogSubscriberModel.Service.ProxyService, <<70, 79, 82, 49, 0, 0, 19, 104, 66, 69, 65, 77, 65, 116, 85, 56, 0, 0, 3, 5, 0, 0, 0, 47, 89, 69, 108, 105, 120, 105, 114, 46, 67, 108, 111, 117, 100, 115, 116, 97, 116, 101, 46, 84, 99, 107, ...>>, {:process_streamed, 2}}, []}
2021-06-22 22:19:20.557 [massa-001@127.0.0.1]:[pid=<0.541.0> ]:[debug]:Endpoint defined: defmodule Massa.Server.Grpc.ProxyEndpoint do
@moduledoc false
use GRPC.Endpoint
intercept(GRPC.Logger.Server)
intercept(GRPCPrometheus.ServerInterceptor)
services = [
MassProxy.Reflection.Service,
Cloudstate.Tck.Model.Action.ActionTwo.Service.ProxyService,
Cloudstate.Tck.Model.Eventlogeventing.EventLogSubscriberModel.Service.ProxyService,
]
run(services)
end
2021-06-22 22:19:20.617 [massa-001@127.0.0.1]:[pid=<0.541.0> ]:[debug]:Endpoint compiled: {{:module, Massa.Server.Grpc.ProxyEndpoint, <<70, 79, 82, 49, 0, 0, 6, 216, 66, 69, 65, 77, 65, 116, 85, 56, 0, 0, 0, 207, 0, 0, 0, 17, 38, 69, 108, 105, 120, 105, 114, 46, 77, 97, 115, 115, 97, 46, 83, 101, 114, 118, 101, 114, 46, 71, ...>>, :ok}, []}
2021-06-22 22:19:20.617 [massa-001@127.0.0.1]:[pid=<0.541.0> ]:[info]: Starting gRPC Server...
2021-06-22 22:19:20.619 [massa-001@127.0.0.1]:[pid=<0.3849.0> ]:[info]: Running Massa.Server.Grpc.ProxyEndpoint with Cowboy using http://0.0.0.0:9000
2021-06-22 22:19:20.621 [massa-001@127.0.0.1]:[pid=<0.541.0> ]:[info]: Started gRPC Server in 10.653185ms
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment