diff --git a/protobuf/eigr/actor.proto b/protobuf/eigr/actor.proto
index 58b2072..e9c7c69 100644
--- a/protobuf/eigr/actor.proto
+++ b/protobuf/eigr/actor.proto
@@ -25,28 +25,95 @@ message ActorSnapshotStrategy {
 }
 
 // A strategy which a user function's entity is passivated.
-message ActorDeactivateStrategy {
+message ActorDeactivationStrategy {
     oneof strategy {
         // the timeout strategy.
         TimeoutStrategy timeout = 1;
     }
 }
 
-// A strategy based on a timeout.
+// A strategy based on a timeout. 
 message TimeoutStrategy {
     // The timeout in millis
     int64 timeout = 1;
 }
 
+// A command represents an action that the user can perform on an Actor. 
+// Commands in supporting languages are represented by functions or methods.
+// An Actor command has nothing to do with the semantics of Commands in a CQRS/EventSourced system. 
+// It just represents an action that supporting languages can invoke.
+message Command {
+
+    // The name of the function or method in the supporting language that has been registered in Ator.
+    string name = 1;
+}
+
+// A FixedTimerCommand is similar to a regular Command, its main differences are that it is scheduled to run at regular intervals 
+// and only takes the actor's state as an argument.
+// Timer Commands are good for executing loops that manipulate the actor's own state. 
+// In Elixir or other languages in BEAM it would be similar to invoking Process.send_after(self(), atom, msg, timeout)
+message FixedTimerCommand {
+
+    // The time to wait until the command is triggered
+    int32 seconds = 1;
+
+    // See Command description Above
+    Command command = 2;
+}
+
 message ActorState {
     map<string, string> tags = 1;
     google.protobuf.Any state = 2;
 }
 
-message Actor {
-    string name = 1;
+// TODO doc here
+message Metadata {
+    // A channel group represents a way to send commands to various actors 
+    // that belong to a certain semantic group.
+    string channel_group = 1;
+
+    map<string, string> tags = 2;
+}
+
+message ActorSettings {
+
+    // Indicates if actor´s is abstract or non abstract.
+    bool abstract = 1;
+
+    // Indicates whether an actor's state should be persisted in a definitive store.
     bool persistent = 2;
-    ActorState state = 3;
-    ActorSnapshotStrategy snapshot_strategy = 4;
-    ActorDeactivateStrategy deactivate_strategy = 5;
+
+    // Snapshot strategy
+    ActorSnapshotStrategy snapshot_strategy = 3;
+
+    // Deactivate strategy
+    ActorDeactivationStrategy deactivation_strategy = 4;
+}
+
+message ActorId {
+    // The name of a Actor Entity.
+    string name = 1;
+
+    // Name of a ActorSystem
+    string system = 2;
+}
+
+message Actor {
+    // Actor Identification
+    ActorId id = 1;
+
+    // A Actor state.
+    ActorState state = 2;
+
+    // Actor metadata
+    Metadata metadata = 6;
+
+    // Actor settings.
+    ActorSettings settings = 3;
+
+    // The commands registered for an actor
+    repeated Command commands = 4;
+
+    // The registered timer commands for an actor.
+    repeated FixedTimerCommand timer_commands = 5;
 }
\ No newline at end of file
diff --git a/protobuf/eigr/protocol.proto b/protobuf/eigr/protocol.proto
index a19f797..012bc8a 100644
--- a/protobuf/eigr/protocol.proto
+++ b/protobuf/eigr/protocol.proto
@@ -104,6 +104,14 @@ import "google/protobuf/any.proto";
 option java_package = "io.eigr.functions.protocol";
 option go_package = "github.com/eigr/go-support/eigr/protocol;protocol";
 
+message SpawnRequest {
+    eigr.actors.ActorSystem actor_system = 2;
+}
+
+message SpawnResponse {
+    RequestStatus status = 1;
+}
+
 message RegistrationRequest {
 
     ServiceInfo service_info = 1;
@@ -144,7 +152,7 @@ message ProxyInfo {
     int32 protocol_minor_version = 2;
 
     string proxy_name = 3;
-
+    
     string proxy_version = 4;
 }
 
@@ -155,29 +163,91 @@ message RegistrationResponse {
     ProxyInfo proxy_info = 2;
 }
 
-// Context is where current and/or updated state is stored
+// Context is where current and/or updated state is stored 
 // to be transmitted to/from proxy and user function
 //
 // Params:
-//   * state: Actor state passed back and forth between proxy and user function.
+//   * state: Actor state passed back and forth between proxy and user function. 
 message Context {
 
     google.protobuf.Any state = 1;
 }
 
+// When a Host Function is invoked it returns the updated state and return value to the call. 
+// It can also return a number of side effects to other Actors as a result of its computation. 
+// These side effects will be forwarded to the respective Actors asynchronously and should not affect the Host Function's response to its caller.
+// Internally side effects is just a special kind of InvocationRequest.
+// Useful for handle handle `recipient list` and `Composed Message Processor` patterns:
+// https://www.enterpriseintegrationpatterns.com/patterns/messaging/RecipientList.html
+// https://www.enterpriseintegrationpatterns.com/patterns/messaging/DistributionAggregate.html
+message SideEffect {
+    InvocationRequest request = 1;
+}
+
+// Broadcast a message to many Actors
+// Useful for handle `recipient list`, `publish-subscribe channel`, and `scatter-gatther` patterns:
+// https://www.enterpriseintegrationpatterns.com/patterns/messaging/RecipientList.html
+// https://www.enterpriseintegrationpatterns.com/patterns/messaging/PublishSubscribeChannel.html
+// https://www.enterpriseintegrationpatterns.com/patterns/messaging/BroadcastAggregate.html
+message Broadcast {
+    // Channel of target Actors
+    string channel_group = 1;
+
+    // Command. Only Actors that have this command will run successfully
+    string command_name = 2;
+
+    // Payload
+    google.protobuf.Any value = 3;
+}
+
+// Sends the output of a command of an Actor to the input of another command of an Actor
+// Useful for handle `pipes` pattern:
+// https://www.enterpriseintegrationpatterns.com/patterns/messaging/PipesAndFilters.html
+message Pipe {
+  // Target Actor
+  string actor = 1;
+
+  // Command. 
+  string command_name = 2;
+}
+
+// Sends the input of a command of an Actor to the input of another command of an Actor
+// Useful for handle `content-basead router` pattern
+// https://www.enterpriseintegrationpatterns.com/patterns/messaging/ContentBasedRouter.html
+message Forward {
+  // Target Actor
+  string actor = 1;
+
+  // Command. 
+  string command_name = 2;
+}
+
+// Container for archicetural message patterns 
+message Workflow {
+    
+    Broadcast broadcast = 2;
+
+    repeated SideEffect effects = 1;
+
+    oneof routing {
+        Pipe pipe = 3;
+        Forward forward = 4;
+    }
+}
+
 // The user function when it wants to send a message to an Actor uses the InvocationRequest message type.
 //
 // Params:
 //   * system: See ActorStstem message.
 //   * actor: The target Actor, i.e. the one that the user function is calling to perform some computation.
-//   * command_name: The function or method on the target Actor that will receive this request
+//   * command_name: The function or method on the target Actor that will receive this request 
 //     and perform some useful computation with the sent data.
 //   * value: This is the value sent by the user function to be computed by the request's target Actor command.
-//   * async: Indicates whether the command should be processed synchronously, where a response should be sent back to the user function,
+//   * async: Indicates whether the command should be processed synchronously, where a response should be sent back to the user function, 
 //            or whether the command should be processed asynchronously, i.e. no response sent to the caller and no waiting.
 message InvocationRequest {
 
-    eigr.actors.ActorSystem system =1;
+    eigr.actors.ActorSystem system = 1;
 
     eigr.actors.Actor actor = 2;
 
@@ -188,16 +258,16 @@ message InvocationRequest {
     bool async = 5;
 }
 
-// ActorInvocation is a translation message between a local invocation made via InvocationRequest
+// ActorInvocation is a translation message between a local invocation made via InvocationRequest 
 // and the real Actor that intends to respond to this invocation and that can be located anywhere in the cluster.
 //
 // Params:
 //   actor_name: The name of the Actor handling the InvocationRequest request, also called the target Actor.
 //   actor_system: The name of ActorSystem registered in Registration step.
-//   command_name: The function or method on the target Actor that will receive this request
+//   command_name: The function or method on the target Actor that will receive this request 
 //                 and perform some useful computation with the sent data.
-//   current_context: The current Context with current state value of the target Actor.
-//                    That is, the same as found via matching in %Actor{name: target_actor, state: %ActorState{state: value} = actor_state}.
+//   current_context: The current Context with current state value of the target Actor. 
+//                    That is, the same as found via matching in %Actor{name: target_actor, state: %ActorState{state: value} = actor_state}. 
 //                    In this case, the Context type will contain in the value attribute the same `value` as the matching above.
 //   value: The value to be passed to the function or method corresponding to command_name.
 message ActorInvocation {
@@ -219,7 +289,7 @@ message ActorInvocation {
 //   actor_name: The name of the Actor handling the InvocationRequest request, also called the target Actor.
 //   actor_system: The name of ActorSystem registered in Registration step.
 //   updated_context: The Context with updated state value of the target Actor after user function has processed a request.
-//   value: The value that the original request proxy will forward in response to the InvocationRequest type request.
+//   value: The value that the original request proxy will forward in response to the InvocationRequest type request. 
 //          This is the final response from the point of view of the user who invoked the Actor call and its subsequent processing.
 message ActorInvocationResponse {
 
@@ -230,13 +300,15 @@ message ActorInvocationResponse {
     Context updated_context = 3;
 
     google.protobuf.Any value = 4;
+
+    Workflow workflow = 5;
 }
 
 // InvocationResponse is the response that the proxy that received the InvocationRequest request will forward to the request's original user function.
 //
 // Params:
 //   status: Status of request. Could be one of [UNKNOWN, OK, ACTOR_NOT_FOUND, ERROR].
-//   sytem: The original ActorSystem of the InvocationRequest request.
+//   system: The original ActorSystem of the InvocationRequest request.
 //   actor: The target Actor originally sent in the InvocationRequest message.
 //   value: The value resulting from the request processing that the target Actor made.
 //          This value must be passed by the user function to the one who requested the initial request in InvocationRequest.
@@ -267,4 +339,6 @@ message RequestStatus {
     Status status = 1;
 
     string message = 2;
-}
\ No newline at end of file
+}
+
+  
\ No newline at end of file
diff --git a/spawn/controller.py b/spawn/controller.py
index 1725dde..8fe214a 100644
--- a/spawn/controller.py
+++ b/spawn/controller.py
@@ -4,9 +4,14 @@
 """
 from spawn.eigr.actor_pb2 import (
     Actor,
-    ActorDeactivateStrategy,
-    ActorSnapshotStrategy,
+    ActorId,
     ActorState,
+    Metadata,
+    ActorSettings,
+    Command,
+    FixedTimerCommand,
+    ActorSnapshotStrategy,
+    ActorDeactivationStrategy,
     ActorSystem,
     Registry,
     TimeoutStrategy,
@@ -59,18 +64,43 @@ def register(self, actors: List[ActorEntity]):
 
             actor_state = ActorState()
 
-            deactivate_strategy = ActorDeactivateStrategy()
+            deactivate_strategy = ActorDeactivationStrategy()
             deactivate_strategy.timeout.CopyFrom(deactivate_timeout_strategy)
 
             snaphot_strategy = ActorSnapshotStrategy()
             snaphot_strategy.timeout.CopyFrom(snaphot_timeout_strategy)
 
             actor_01 = Actor()
-            actor_01.name = "user_actor_01"
-            actor_01.persistent = True
+
+            actor_id = ActorId()
+            actor_id.name = "user_actor_01"
+            actor_id.system = "spawn-system"
+
+            actor_01.id.CopyFrom(actor_id)
+
             actor_01.state.CopyFrom(actor_state)
-            actor_01.deactivate_strategy.CopyFrom(deactivate_strategy)
-            actor_01.snapshot_strategy.CopyFrom(snaphot_strategy)
+
+            actor_metatdata = Metadata()
+            actor_metatdata.channel_group = "spawn-python"
+            actor_metatdata.tags["actor"] = "user_actor_01"
+
+            actor_01.metadata.CopyFrom(actor_metatdata)
+
+            actor_settings = ActorSettings()
+            actor_settings.abstract = True
+            actor_settings.persistent = True
+            actor_settings.snapshot_strategy.CopyFrom(snaphot_strategy)
+            actor_settings.deactivation_strategy.CopyFrom(deactivate_strategy)
+
+            actor_01.settings.CopyFrom(actor_settings)
+
+            actor_command = actor_01.commands.add()
+            actor_command.name = ""
+
+            actor_fixed_timer_command = actor_01.timer_commands.add()
+
+            actor_fixed_timer_command.seconds = 1
+            actor_fixed_timer_command.command.CopyFrom(actor_command)
 
             registry = Registry()
             registry.actors.get_or_create("user_actor_01").CopyFrom(actor_01)
@@ -110,4 +140,4 @@ def register(self, actors: List[ActorEntity]):
             logging.info("Actors register response %s", resp)
         except Exception as e:
             logging.error("ERROR: %s", e)
-            logging.error("Shit %s", e.__cause__)
\ No newline at end of file
+            logging.error("Shit %s", e.__cause__)
diff --git a/spawn/eigr/actor_pb2.py b/spawn/eigr/actor_pb2.py
index af6ce42..98e02be 100644
--- a/spawn/eigr/actor_pb2.py
+++ b/spawn/eigr/actor_pb2.py
@@ -1,6 +1,6 @@
 # -*- coding: utf-8 -*-
 # Generated by the protocol buffer compiler.  DO NOT EDIT!
-# source: eigr/actor.proto
+# source: protobuf/eigr/actor.proto
 
 from google.protobuf import descriptor as _descriptor
 from google.protobuf import message as _message
@@ -15,12 +15,12 @@
 
 
 DESCRIPTOR = _descriptor.FileDescriptor(
-  name='eigr/actor.proto',
+  name='protobuf/eigr/actor.proto',
   package='eigr.actors',
   syntax='proto3',
   serialized_options=b'\n!io.eigr.functions.protocol.actorsZ-github.com/eigr/go-support/eigr/actors;actors',
   create_key=_descriptor._internal_create_key,
-  serialized_pb=b'\n\x10\x65igr/actor.proto\x12\x0b\x65igr.actors\x1a\x19google/protobuf/any.proto\"\x80\x01\n\x08Registry\x12\x31\n\x06\x61\x63tors\x18\x01 \x03(\x0b\x32!.eigr.actors.Registry.ActorsEntry\x1a\x41\n\x0b\x41\x63torsEntry\x12\x0b\n\x03key\x18\x01 \x01(\t\x12!\n\x05value\x18\x02 \x01(\x0b\x32\x12.eigr.actors.Actor:\x02\x38\x01\"D\n\x0b\x41\x63torSystem\x12\x0c\n\x04name\x18\x01 \x01(\t\x12\'\n\x08registry\x18\x02 \x01(\x0b\x32\x15.eigr.actors.Registry\"T\n\x15\x41\x63torSnapshotStrategy\x12/\n\x07timeout\x18\x01 \x01(\x0b\x32\x1c.eigr.actors.TimeoutStrategyH\x00\x42\n\n\x08strategy\"V\n\x17\x41\x63torDeactivateStrategy\x12/\n\x07timeout\x18\x01 \x01(\x0b\x32\x1c.eigr.actors.TimeoutStrategyH\x00\x42\n\n\x08strategy\"\"\n\x0fTimeoutStrategy\x12\x0f\n\x07timeout\x18\x01 \x01(\x03\"\x8f\x01\n\nActorState\x12/\n\x04tags\x18\x01 \x03(\x0b\x32!.eigr.actors.ActorState.TagsEntry\x12#\n\x05state\x18\x02 \x01(\x0b\x32\x14.google.protobuf.Any\x1a+\n\tTagsEntry\x12\x0b\n\x03key\x18\x01 \x01(\t\x12\r\n\x05value\x18\x02 \x01(\t:\x02\x38\x01\"\xd3\x01\n\x05\x41\x63tor\x12\x0c\n\x04name\x18\x01 \x01(\t\x12\x12\n\npersistent\x18\x02 \x01(\x08\x12&\n\x05state\x18\x03 \x01(\x0b\x32\x17.eigr.actors.ActorState\x12=\n\x11snapshot_strategy\x18\x04 \x01(\x0b\x32\".eigr.actors.ActorSnapshotStrategy\x12\x41\n\x13\x64\x65\x61\x63tivate_strategy\x18\x05 \x01(\x0b\x32$.eigr.actors.ActorDeactivateStrategyBR\n!io.eigr.functions.protocol.actorsZ-github.com/eigr/go-support/eigr/actors;actorsb\x06proto3'
+  serialized_pb=b'\n\x19protobuf/eigr/actor.proto\x12\x0b\x65igr.actors\x1a\x19google/protobuf/any.proto\"\x80\x01\n\x08Registry\x12\x31\n\x06\x61\x63tors\x18\x01 \x03(\x0b\x32!.eigr.actors.Registry.ActorsEntry\x1a\x41\n\x0b\x41\x63torsEntry\x12\x0b\n\x03key\x18\x01 \x01(\t\x12!\n\x05value\x18\x02 \x01(\x0b\x32\x12.eigr.actors.Actor:\x02\x38\x01\"D\n\x0b\x41\x63torSystem\x12\x0c\n\x04name\x18\x01 \x01(\t\x12\'\n\x08registry\x18\x02 \x01(\x0b\x32\x15.eigr.actors.Registry\"T\n\x15\x41\x63torSnapshotStrategy\x12/\n\x07timeout\x18\x01 \x01(\x0b\x32\x1c.eigr.actors.TimeoutStrategyH\x00\x42\n\n\x08strategy\"X\n\x19\x41\x63torDeactivationStrategy\x12/\n\x07timeout\x18\x01 \x01(\x0b\x32\x1c.eigr.actors.TimeoutStrategyH\x00\x42\n\n\x08strategy\"\"\n\x0fTimeoutStrategy\x12\x0f\n\x07timeout\x18\x01 \x01(\x03\"\x17\n\x07\x43ommand\x12\x0c\n\x04name\x18\x01 \x01(\t\"K\n\x11\x46ixedTimerCommand\x12\x0f\n\x07seconds\x18\x01 \x01(\x05\x12%\n\x07\x63ommand\x18\x02 \x01(\x0b\x32\x14.eigr.actors.Command\"\x8f\x01\n\nActorState\x12/\n\x04tags\x18\x01 \x03(\x0b\x32!.eigr.actors.ActorState.TagsEntry\x12#\n\x05state\x18\x02 \x01(\x0b\x32\x14.google.protobuf.Any\x1a+\n\tTagsEntry\x12\x0b\n\x03key\x18\x01 \x01(\t\x12\r\n\x05value\x18\x02 \x01(\t:\x02\x38\x01\"}\n\x08Metadata\x12\x15\n\rchannel_group\x18\x01 \x01(\t\x12-\n\x04tags\x18\x02 \x03(\x0b\x32\x1f.eigr.actors.Metadata.TagsEntry\x1a+\n\tTagsEntry\x12\x0b\n\x03key\x18\x01 \x01(\t\x12\r\n\x05value\x18\x02 \x01(\t:\x02\x38\x01\"\xbb\x01\n\rActorSettings\x12\x10\n\x08\x61\x62stract\x18\x01 \x01(\x08\x12\x12\n\npersistent\x18\x02 \x01(\x08\x12=\n\x11snapshot_strategy\x18\x03 \x01(\x0b\x32\".eigr.actors.ActorSnapshotStrategy\x12\x45\n\x15\x64\x65\x61\x63tivation_strategy\x18\x04 \x01(\x0b\x32&.eigr.actors.ActorDeactivationStrategy\"\'\n\x07\x41\x63torId\x12\x0c\n\x04name\x18\x01 \x01(\t\x12\x0e\n\x06system\x18\x02 \x01(\t\"\x88\x02\n\x05\x41\x63tor\x12 \n\x02id\x18\x01 \x01(\x0b\x32\x14.eigr.actors.ActorId\x12&\n\x05state\x18\x02 \x01(\x0b\x32\x17.eigr.actors.ActorState\x12\'\n\x08metadata\x18\x06 \x01(\x0b\x32\x15.eigr.actors.Metadata\x12,\n\x08settings\x18\x03 \x01(\x0b\x32\x1a.eigr.actors.ActorSettings\x12&\n\x08\x63ommands\x18\x04 \x03(\x0b\x32\x14.eigr.actors.Command\x12\x36\n\x0etimer_commands\x18\x05 \x03(\x0b\x32\x1e.eigr.actors.FixedTimerCommandBR\n!io.eigr.functions.protocol.actorsZ-github.com/eigr/go-support/eigr/actors;actorsb\x06proto3'
   ,
   dependencies=[google_dot_protobuf_dot_any__pb2.DESCRIPTOR,])
 
@@ -61,8 +61,8 @@
   extension_ranges=[],
   oneofs=[
   ],
-  serialized_start=124,
-  serialized_end=189,
+  serialized_start=133,
+  serialized_end=198,
 )
 
 _REGISTRY = _descriptor.Descriptor(
@@ -92,8 +92,8 @@
   extension_ranges=[],
   oneofs=[
   ],
-  serialized_start=61,
-  serialized_end=189,
+  serialized_start=70,
+  serialized_end=198,
 )
 
 
@@ -131,8 +131,8 @@
   extension_ranges=[],
   oneofs=[
   ],
-  serialized_start=191,
-  serialized_end=259,
+  serialized_start=200,
+  serialized_end=268,
 )
 
 
@@ -168,21 +168,21 @@
       create_key=_descriptor._internal_create_key,
     fields=[]),
   ],
-  serialized_start=261,
-  serialized_end=345,
+  serialized_start=270,
+  serialized_end=354,
 )
 
 
-_ACTORDEACTIVATESTRATEGY = _descriptor.Descriptor(
-  name='ActorDeactivateStrategy',
-  full_name='eigr.actors.ActorDeactivateStrategy',
+_ACTORDEACTIVATIONSTRATEGY = _descriptor.Descriptor(
+  name='ActorDeactivationStrategy',
+  full_name='eigr.actors.ActorDeactivationStrategy',
   filename=None,
   file=DESCRIPTOR,
   containing_type=None,
   create_key=_descriptor._internal_create_key,
   fields=[
     _descriptor.FieldDescriptor(
-      name='timeout', full_name='eigr.actors.ActorDeactivateStrategy.timeout', index=0,
+      name='timeout', full_name='eigr.actors.ActorDeactivationStrategy.timeout', index=0,
       number=1, type=11, cpp_type=10, label=1,
       has_default_value=False, default_value=None,
       message_type=None, enum_type=None, containing_type=None,
@@ -200,13 +200,13 @@
   extension_ranges=[],
   oneofs=[
     _descriptor.OneofDescriptor(
-      name='strategy', full_name='eigr.actors.ActorDeactivateStrategy.strategy',
+      name='strategy', full_name='eigr.actors.ActorDeactivationStrategy.strategy',
       index=0, containing_type=None,
       create_key=_descriptor._internal_create_key,
     fields=[]),
   ],
-  serialized_start=347,
-  serialized_end=433,
+  serialized_start=356,
+  serialized_end=444,
 )
 
 
@@ -237,8 +237,79 @@
   extension_ranges=[],
   oneofs=[
   ],
-  serialized_start=435,
-  serialized_end=469,
+  serialized_start=446,
+  serialized_end=480,
+)
+
+
+_COMMAND = _descriptor.Descriptor(
+  name='Command',
+  full_name='eigr.actors.Command',
+  filename=None,
+  file=DESCRIPTOR,
+  containing_type=None,
+  create_key=_descriptor._internal_create_key,
+  fields=[
+    _descriptor.FieldDescriptor(
+      name='name', full_name='eigr.actors.Command.name', index=0,
+      number=1, type=9, cpp_type=9, label=1,
+      has_default_value=False, default_value=b"".decode('utf-8'),
+      message_type=None, enum_type=None, containing_type=None,
+      is_extension=False, extension_scope=None,
+      serialized_options=None, file=DESCRIPTOR,  create_key=_descriptor._internal_create_key),
+  ],
+  extensions=[
+  ],
+  nested_types=[],
+  enum_types=[
+  ],
+  serialized_options=None,
+  is_extendable=False,
+  syntax='proto3',
+  extension_ranges=[],
+  oneofs=[
+  ],
+  serialized_start=482,
+  serialized_end=505,
+)
+
+
+_FIXEDTIMERCOMMAND = _descriptor.Descriptor(
+  name='FixedTimerCommand',
+  full_name='eigr.actors.FixedTimerCommand',
+  filename=None,
+  file=DESCRIPTOR,
+  containing_type=None,
+  create_key=_descriptor._internal_create_key,
+  fields=[
+    _descriptor.FieldDescriptor(
+      name='seconds', full_name='eigr.actors.FixedTimerCommand.seconds', index=0,
+      number=1, type=5, cpp_type=1, label=1,
+      has_default_value=False, default_value=0,
+      message_type=None, enum_type=None, containing_type=None,
+      is_extension=False, extension_scope=None,
+      serialized_options=None, file=DESCRIPTOR,  create_key=_descriptor._internal_create_key),
+    _descriptor.FieldDescriptor(
+      name='command', full_name='eigr.actors.FixedTimerCommand.command', index=1,
+      number=2, type=11, cpp_type=10, label=1,
+      has_default_value=False, default_value=None,
+      message_type=None, enum_type=None, containing_type=None,
+      is_extension=False, extension_scope=None,
+      serialized_options=None, file=DESCRIPTOR,  create_key=_descriptor._internal_create_key),
+  ],
+  extensions=[
+  ],
+  nested_types=[],
+  enum_types=[
+  ],
+  serialized_options=None,
+  is_extendable=False,
+  syntax='proto3',
+  extension_ranges=[],
+  oneofs=[
+  ],
+  serialized_start=507,
+  serialized_end=582,
 )
 
 
@@ -276,8 +347,8 @@
   extension_ranges=[],
   oneofs=[
   ],
-  serialized_start=572,
-  serialized_end=615,
+  serialized_start=685,
+  serialized_end=728,
 )
 
 _ACTORSTATE = _descriptor.Descriptor(
@@ -314,54 +385,230 @@
   extension_ranges=[],
   oneofs=[
   ],
-  serialized_start=472,
-  serialized_end=615,
+  serialized_start=585,
+  serialized_end=728,
 )
 
 
-_ACTOR = _descriptor.Descriptor(
-  name='Actor',
-  full_name='eigr.actors.Actor',
+_METADATA_TAGSENTRY = _descriptor.Descriptor(
+  name='TagsEntry',
+  full_name='eigr.actors.Metadata.TagsEntry',
+  filename=None,
+  file=DESCRIPTOR,
+  containing_type=None,
+  create_key=_descriptor._internal_create_key,
+  fields=[
+    _descriptor.FieldDescriptor(
+      name='key', full_name='eigr.actors.Metadata.TagsEntry.key', index=0,
+      number=1, type=9, cpp_type=9, label=1,
+      has_default_value=False, default_value=b"".decode('utf-8'),
+      message_type=None, enum_type=None, containing_type=None,
+      is_extension=False, extension_scope=None,
+      serialized_options=None, file=DESCRIPTOR,  create_key=_descriptor._internal_create_key),
+    _descriptor.FieldDescriptor(
+      name='value', full_name='eigr.actors.Metadata.TagsEntry.value', index=1,
+      number=2, type=9, cpp_type=9, label=1,
+      has_default_value=False, default_value=b"".decode('utf-8'),
+      message_type=None, enum_type=None, containing_type=None,
+      is_extension=False, extension_scope=None,
+      serialized_options=None, file=DESCRIPTOR,  create_key=_descriptor._internal_create_key),
+  ],
+  extensions=[
+  ],
+  nested_types=[],
+  enum_types=[
+  ],
+  serialized_options=b'8\001',
+  is_extendable=False,
+  syntax='proto3',
+  extension_ranges=[],
+  oneofs=[
+  ],
+  serialized_start=685,
+  serialized_end=728,
+)
+
+_METADATA = _descriptor.Descriptor(
+  name='Metadata',
+  full_name='eigr.actors.Metadata',
   filename=None,
   file=DESCRIPTOR,
   containing_type=None,
   create_key=_descriptor._internal_create_key,
   fields=[
     _descriptor.FieldDescriptor(
-      name='name', full_name='eigr.actors.Actor.name', index=0,
+      name='channel_group', full_name='eigr.actors.Metadata.channel_group', index=0,
       number=1, type=9, cpp_type=9, label=1,
       has_default_value=False, default_value=b"".decode('utf-8'),
       message_type=None, enum_type=None, containing_type=None,
       is_extension=False, extension_scope=None,
       serialized_options=None, file=DESCRIPTOR,  create_key=_descriptor._internal_create_key),
     _descriptor.FieldDescriptor(
-      name='persistent', full_name='eigr.actors.Actor.persistent', index=1,
+      name='tags', full_name='eigr.actors.Metadata.tags', index=1,
+      number=2, type=11, cpp_type=10, label=3,
+      has_default_value=False, default_value=[],
+      message_type=None, enum_type=None, containing_type=None,
+      is_extension=False, extension_scope=None,
+      serialized_options=None, file=DESCRIPTOR,  create_key=_descriptor._internal_create_key),
+  ],
+  extensions=[
+  ],
+  nested_types=[_METADATA_TAGSENTRY, ],
+  enum_types=[
+  ],
+  serialized_options=None,
+  is_extendable=False,
+  syntax='proto3',
+  extension_ranges=[],
+  oneofs=[
+  ],
+  serialized_start=730,
+  serialized_end=855,
+)
+
+
+_ACTORSETTINGS = _descriptor.Descriptor(
+  name='ActorSettings',
+  full_name='eigr.actors.ActorSettings',
+  filename=None,
+  file=DESCRIPTOR,
+  containing_type=None,
+  create_key=_descriptor._internal_create_key,
+  fields=[
+    _descriptor.FieldDescriptor(
+      name='abstract', full_name='eigr.actors.ActorSettings.abstract', index=0,
+      number=1, type=8, cpp_type=7, label=1,
+      has_default_value=False, default_value=False,
+      message_type=None, enum_type=None, containing_type=None,
+      is_extension=False, extension_scope=None,
+      serialized_options=None, file=DESCRIPTOR,  create_key=_descriptor._internal_create_key),
+    _descriptor.FieldDescriptor(
+      name='persistent', full_name='eigr.actors.ActorSettings.persistent', index=1,
       number=2, type=8, cpp_type=7, label=1,
       has_default_value=False, default_value=False,
       message_type=None, enum_type=None, containing_type=None,
       is_extension=False, extension_scope=None,
       serialized_options=None, file=DESCRIPTOR,  create_key=_descriptor._internal_create_key),
     _descriptor.FieldDescriptor(
-      name='state', full_name='eigr.actors.Actor.state', index=2,
+      name='snapshot_strategy', full_name='eigr.actors.ActorSettings.snapshot_strategy', index=2,
       number=3, type=11, cpp_type=10, label=1,
       has_default_value=False, default_value=None,
       message_type=None, enum_type=None, containing_type=None,
       is_extension=False, extension_scope=None,
       serialized_options=None, file=DESCRIPTOR,  create_key=_descriptor._internal_create_key),
     _descriptor.FieldDescriptor(
-      name='snapshot_strategy', full_name='eigr.actors.Actor.snapshot_strategy', index=3,
+      name='deactivation_strategy', full_name='eigr.actors.ActorSettings.deactivation_strategy', index=3,
       number=4, type=11, cpp_type=10, label=1,
       has_default_value=False, default_value=None,
       message_type=None, enum_type=None, containing_type=None,
       is_extension=False, extension_scope=None,
       serialized_options=None, file=DESCRIPTOR,  create_key=_descriptor._internal_create_key),
+  ],
+  extensions=[
+  ],
+  nested_types=[],
+  enum_types=[
+  ],
+  serialized_options=None,
+  is_extendable=False,
+  syntax='proto3',
+  extension_ranges=[],
+  oneofs=[
+  ],
+  serialized_start=858,
+  serialized_end=1045,
+)
+
+
+_ACTORID = _descriptor.Descriptor(
+  name='ActorId',
+  full_name='eigr.actors.ActorId',
+  filename=None,
+  file=DESCRIPTOR,
+  containing_type=None,
+  create_key=_descriptor._internal_create_key,
+  fields=[
+    _descriptor.FieldDescriptor(
+      name='name', full_name='eigr.actors.ActorId.name', index=0,
+      number=1, type=9, cpp_type=9, label=1,
+      has_default_value=False, default_value=b"".decode('utf-8'),
+      message_type=None, enum_type=None, containing_type=None,
+      is_extension=False, extension_scope=None,
+      serialized_options=None, file=DESCRIPTOR,  create_key=_descriptor._internal_create_key),
     _descriptor.FieldDescriptor(
-      name='deactivate_strategy', full_name='eigr.actors.Actor.deactivate_strategy', index=4,
-      number=5, type=11, cpp_type=10, label=1,
+      name='system', full_name='eigr.actors.ActorId.system', index=1,
+      number=2, type=9, cpp_type=9, label=1,
+      has_default_value=False, default_value=b"".decode('utf-8'),
+      message_type=None, enum_type=None, containing_type=None,
+      is_extension=False, extension_scope=None,
+      serialized_options=None, file=DESCRIPTOR,  create_key=_descriptor._internal_create_key),
+  ],
+  extensions=[
+  ],
+  nested_types=[],
+  enum_types=[
+  ],
+  serialized_options=None,
+  is_extendable=False,
+  syntax='proto3',
+  extension_ranges=[],
+  oneofs=[
+  ],
+  serialized_start=1047,
+  serialized_end=1086,
+)
+
+
+_ACTOR = _descriptor.Descriptor(
+  name='Actor',
+  full_name='eigr.actors.Actor',
+  filename=None,
+  file=DESCRIPTOR,
+  containing_type=None,
+  create_key=_descriptor._internal_create_key,
+  fields=[
+    _descriptor.FieldDescriptor(
+      name='id', full_name='eigr.actors.Actor.id', index=0,
+      number=1, type=11, cpp_type=10, label=1,
+      has_default_value=False, default_value=None,
+      message_type=None, enum_type=None, containing_type=None,
+      is_extension=False, extension_scope=None,
+      serialized_options=None, file=DESCRIPTOR,  create_key=_descriptor._internal_create_key),
+    _descriptor.FieldDescriptor(
+      name='state', full_name='eigr.actors.Actor.state', index=1,
+      number=2, type=11, cpp_type=10, label=1,
+      has_default_value=False, default_value=None,
+      message_type=None, enum_type=None, containing_type=None,
+      is_extension=False, extension_scope=None,
+      serialized_options=None, file=DESCRIPTOR,  create_key=_descriptor._internal_create_key),
+    _descriptor.FieldDescriptor(
+      name='metadata', full_name='eigr.actors.Actor.metadata', index=2,
+      number=6, type=11, cpp_type=10, label=1,
+      has_default_value=False, default_value=None,
+      message_type=None, enum_type=None, containing_type=None,
+      is_extension=False, extension_scope=None,
+      serialized_options=None, file=DESCRIPTOR,  create_key=_descriptor._internal_create_key),
+    _descriptor.FieldDescriptor(
+      name='settings', full_name='eigr.actors.Actor.settings', index=3,
+      number=3, type=11, cpp_type=10, label=1,
       has_default_value=False, default_value=None,
       message_type=None, enum_type=None, containing_type=None,
       is_extension=False, extension_scope=None,
       serialized_options=None, file=DESCRIPTOR,  create_key=_descriptor._internal_create_key),
+    _descriptor.FieldDescriptor(
+      name='commands', full_name='eigr.actors.Actor.commands', index=4,
+      number=4, type=11, cpp_type=10, label=3,
+      has_default_value=False, default_value=[],
+      message_type=None, enum_type=None, containing_type=None,
+      is_extension=False, extension_scope=None,
+      serialized_options=None, file=DESCRIPTOR,  create_key=_descriptor._internal_create_key),
+    _descriptor.FieldDescriptor(
+      name='timer_commands', full_name='eigr.actors.Actor.timer_commands', index=5,
+      number=5, type=11, cpp_type=10, label=3,
+      has_default_value=False, default_value=[],
+      message_type=None, enum_type=None, containing_type=None,
+      is_extension=False, extension_scope=None,
+      serialized_options=None, file=DESCRIPTOR,  create_key=_descriptor._internal_create_key),
   ],
   extensions=[
   ],
@@ -374,8 +621,8 @@
   extension_ranges=[],
   oneofs=[
   ],
-  serialized_start=618,
-  serialized_end=829,
+  serialized_start=1089,
+  serialized_end=1353,
 )
 
 _REGISTRY_ACTORSENTRY.fields_by_name['value'].message_type = _ACTOR
@@ -386,22 +633,35 @@
 _ACTORSNAPSHOTSTRATEGY.oneofs_by_name['strategy'].fields.append(
   _ACTORSNAPSHOTSTRATEGY.fields_by_name['timeout'])
 _ACTORSNAPSHOTSTRATEGY.fields_by_name['timeout'].containing_oneof = _ACTORSNAPSHOTSTRATEGY.oneofs_by_name['strategy']
-_ACTORDEACTIVATESTRATEGY.fields_by_name['timeout'].message_type = _TIMEOUTSTRATEGY
-_ACTORDEACTIVATESTRATEGY.oneofs_by_name['strategy'].fields.append(
-  _ACTORDEACTIVATESTRATEGY.fields_by_name['timeout'])
-_ACTORDEACTIVATESTRATEGY.fields_by_name['timeout'].containing_oneof = _ACTORDEACTIVATESTRATEGY.oneofs_by_name['strategy']
+_ACTORDEACTIVATIONSTRATEGY.fields_by_name['timeout'].message_type = _TIMEOUTSTRATEGY
+_ACTORDEACTIVATIONSTRATEGY.oneofs_by_name['strategy'].fields.append(
+  _ACTORDEACTIVATIONSTRATEGY.fields_by_name['timeout'])
+_ACTORDEACTIVATIONSTRATEGY.fields_by_name['timeout'].containing_oneof = _ACTORDEACTIVATIONSTRATEGY.oneofs_by_name['strategy']
+_FIXEDTIMERCOMMAND.fields_by_name['command'].message_type = _COMMAND
 _ACTORSTATE_TAGSENTRY.containing_type = _ACTORSTATE
 _ACTORSTATE.fields_by_name['tags'].message_type = _ACTORSTATE_TAGSENTRY
 _ACTORSTATE.fields_by_name['state'].message_type = google_dot_protobuf_dot_any__pb2._ANY
+_METADATA_TAGSENTRY.containing_type = _METADATA
+_METADATA.fields_by_name['tags'].message_type = _METADATA_TAGSENTRY
+_ACTORSETTINGS.fields_by_name['snapshot_strategy'].message_type = _ACTORSNAPSHOTSTRATEGY
+_ACTORSETTINGS.fields_by_name['deactivation_strategy'].message_type = _ACTORDEACTIVATIONSTRATEGY
+_ACTOR.fields_by_name['id'].message_type = _ACTORID
 _ACTOR.fields_by_name['state'].message_type = _ACTORSTATE
-_ACTOR.fields_by_name['snapshot_strategy'].message_type = _ACTORSNAPSHOTSTRATEGY
-_ACTOR.fields_by_name['deactivate_strategy'].message_type = _ACTORDEACTIVATESTRATEGY
+_ACTOR.fields_by_name['metadata'].message_type = _METADATA
+_ACTOR.fields_by_name['settings'].message_type = _ACTORSETTINGS
+_ACTOR.fields_by_name['commands'].message_type = _COMMAND
+_ACTOR.fields_by_name['timer_commands'].message_type = _FIXEDTIMERCOMMAND
 DESCRIPTOR.message_types_by_name['Registry'] = _REGISTRY
 DESCRIPTOR.message_types_by_name['ActorSystem'] = _ACTORSYSTEM
 DESCRIPTOR.message_types_by_name['ActorSnapshotStrategy'] = _ACTORSNAPSHOTSTRATEGY
-DESCRIPTOR.message_types_by_name['ActorDeactivateStrategy'] = _ACTORDEACTIVATESTRATEGY
+DESCRIPTOR.message_types_by_name['ActorDeactivationStrategy'] = _ACTORDEACTIVATIONSTRATEGY
 DESCRIPTOR.message_types_by_name['TimeoutStrategy'] = _TIMEOUTSTRATEGY
+DESCRIPTOR.message_types_by_name['Command'] = _COMMAND
+DESCRIPTOR.message_types_by_name['FixedTimerCommand'] = _FIXEDTIMERCOMMAND
 DESCRIPTOR.message_types_by_name['ActorState'] = _ACTORSTATE
+DESCRIPTOR.message_types_by_name['Metadata'] = _METADATA
+DESCRIPTOR.message_types_by_name['ActorSettings'] = _ACTORSETTINGS
+DESCRIPTOR.message_types_by_name['ActorId'] = _ACTORID
 DESCRIPTOR.message_types_by_name['Actor'] = _ACTOR
 _sym_db.RegisterFileDescriptor(DESCRIPTOR)
 
@@ -409,12 +669,12 @@
 
   'ActorsEntry' : _reflection.GeneratedProtocolMessageType('ActorsEntry', (_message.Message,), {
     'DESCRIPTOR' : _REGISTRY_ACTORSENTRY,
-    '__module__' : 'eigr.actor_pb2'
+    '__module__' : 'protobuf.eigr.actor_pb2'
     # @@protoc_insertion_point(class_scope:eigr.actors.Registry.ActorsEntry)
     })
   ,
   'DESCRIPTOR' : _REGISTRY,
-  '__module__' : 'eigr.actor_pb2'
+  '__module__' : 'protobuf.eigr.actor_pb2'
   # @@protoc_insertion_point(class_scope:eigr.actors.Registry)
   })
 _sym_db.RegisterMessage(Registry)
@@ -422,50 +682,93 @@
 
 ActorSystem = _reflection.GeneratedProtocolMessageType('ActorSystem', (_message.Message,), {
   'DESCRIPTOR' : _ACTORSYSTEM,
-  '__module__' : 'eigr.actor_pb2'
+  '__module__' : 'protobuf.eigr.actor_pb2'
   # @@protoc_insertion_point(class_scope:eigr.actors.ActorSystem)
   })
 _sym_db.RegisterMessage(ActorSystem)
 
 ActorSnapshotStrategy = _reflection.GeneratedProtocolMessageType('ActorSnapshotStrategy', (_message.Message,), {
   'DESCRIPTOR' : _ACTORSNAPSHOTSTRATEGY,
-  '__module__' : 'eigr.actor_pb2'
+  '__module__' : 'protobuf.eigr.actor_pb2'
   # @@protoc_insertion_point(class_scope:eigr.actors.ActorSnapshotStrategy)
   })
 _sym_db.RegisterMessage(ActorSnapshotStrategy)
 
-ActorDeactivateStrategy = _reflection.GeneratedProtocolMessageType('ActorDeactivateStrategy', (_message.Message,), {
-  'DESCRIPTOR' : _ACTORDEACTIVATESTRATEGY,
-  '__module__' : 'eigr.actor_pb2'
-  # @@protoc_insertion_point(class_scope:eigr.actors.ActorDeactivateStrategy)
+ActorDeactivationStrategy = _reflection.GeneratedProtocolMessageType('ActorDeactivationStrategy', (_message.Message,), {
+  'DESCRIPTOR' : _ACTORDEACTIVATIONSTRATEGY,
+  '__module__' : 'protobuf.eigr.actor_pb2'
+  # @@protoc_insertion_point(class_scope:eigr.actors.ActorDeactivationStrategy)
   })
-_sym_db.RegisterMessage(ActorDeactivateStrategy)
+_sym_db.RegisterMessage(ActorDeactivationStrategy)
 
 TimeoutStrategy = _reflection.GeneratedProtocolMessageType('TimeoutStrategy', (_message.Message,), {
   'DESCRIPTOR' : _TIMEOUTSTRATEGY,
-  '__module__' : 'eigr.actor_pb2'
+  '__module__' : 'protobuf.eigr.actor_pb2'
   # @@protoc_insertion_point(class_scope:eigr.actors.TimeoutStrategy)
   })
 _sym_db.RegisterMessage(TimeoutStrategy)
 
+Command = _reflection.GeneratedProtocolMessageType('Command', (_message.Message,), {
+  'DESCRIPTOR' : _COMMAND,
+  '__module__' : 'protobuf.eigr.actor_pb2'
+  # @@protoc_insertion_point(class_scope:eigr.actors.Command)
+  })
+_sym_db.RegisterMessage(Command)
+
+FixedTimerCommand = _reflection.GeneratedProtocolMessageType('FixedTimerCommand', (_message.Message,), {
+  'DESCRIPTOR' : _FIXEDTIMERCOMMAND,
+  '__module__' : 'protobuf.eigr.actor_pb2'
+  # @@protoc_insertion_point(class_scope:eigr.actors.FixedTimerCommand)
+  })
+_sym_db.RegisterMessage(FixedTimerCommand)
+
 ActorState = _reflection.GeneratedProtocolMessageType('ActorState', (_message.Message,), {
 
   'TagsEntry' : _reflection.GeneratedProtocolMessageType('TagsEntry', (_message.Message,), {
     'DESCRIPTOR' : _ACTORSTATE_TAGSENTRY,
-    '__module__' : 'eigr.actor_pb2'
+    '__module__' : 'protobuf.eigr.actor_pb2'
     # @@protoc_insertion_point(class_scope:eigr.actors.ActorState.TagsEntry)
     })
   ,
   'DESCRIPTOR' : _ACTORSTATE,
-  '__module__' : 'eigr.actor_pb2'
+  '__module__' : 'protobuf.eigr.actor_pb2'
   # @@protoc_insertion_point(class_scope:eigr.actors.ActorState)
   })
 _sym_db.RegisterMessage(ActorState)
 _sym_db.RegisterMessage(ActorState.TagsEntry)
 
+Metadata = _reflection.GeneratedProtocolMessageType('Metadata', (_message.Message,), {
+
+  'TagsEntry' : _reflection.GeneratedProtocolMessageType('TagsEntry', (_message.Message,), {
+    'DESCRIPTOR' : _METADATA_TAGSENTRY,
+    '__module__' : 'protobuf.eigr.actor_pb2'
+    # @@protoc_insertion_point(class_scope:eigr.actors.Metadata.TagsEntry)
+    })
+  ,
+  'DESCRIPTOR' : _METADATA,
+  '__module__' : 'protobuf.eigr.actor_pb2'
+  # @@protoc_insertion_point(class_scope:eigr.actors.Metadata)
+  })
+_sym_db.RegisterMessage(Metadata)
+_sym_db.RegisterMessage(Metadata.TagsEntry)
+
+ActorSettings = _reflection.GeneratedProtocolMessageType('ActorSettings', (_message.Message,), {
+  'DESCRIPTOR' : _ACTORSETTINGS,
+  '__module__' : 'protobuf.eigr.actor_pb2'
+  # @@protoc_insertion_point(class_scope:eigr.actors.ActorSettings)
+  })
+_sym_db.RegisterMessage(ActorSettings)
+
+ActorId = _reflection.GeneratedProtocolMessageType('ActorId', (_message.Message,), {
+  'DESCRIPTOR' : _ACTORID,
+  '__module__' : 'protobuf.eigr.actor_pb2'
+  # @@protoc_insertion_point(class_scope:eigr.actors.ActorId)
+  })
+_sym_db.RegisterMessage(ActorId)
+
 Actor = _reflection.GeneratedProtocolMessageType('Actor', (_message.Message,), {
   'DESCRIPTOR' : _ACTOR,
-  '__module__' : 'eigr.actor_pb2'
+  '__module__' : 'protobuf.eigr.actor_pb2'
   # @@protoc_insertion_point(class_scope:eigr.actors.Actor)
   })
 _sym_db.RegisterMessage(Actor)
@@ -474,4 +777,5 @@
 DESCRIPTOR._options = None
 _REGISTRY_ACTORSENTRY._options = None
 _ACTORSTATE_TAGSENTRY._options = None
+_METADATA_TAGSENTRY._options = None
 # @@protoc_insertion_point(module_scope)
diff --git a/spawn/eigr/protocol_pb2.py b/spawn/eigr/protocol_pb2.py
index b8071be..84ea697 100644
--- a/spawn/eigr/protocol_pb2.py
+++ b/spawn/eigr/protocol_pb2.py
@@ -7,6 +7,7 @@
 from google.protobuf import message as _message
 from google.protobuf import reflection as _reflection
 from google.protobuf import symbol_database as _symbol_database
+
 # @@protoc_insertion_point(imports)
 
 _sym_db = _symbol_database.Default()
@@ -17,47 +18,62 @@
 
 
 DESCRIPTOR = _descriptor.FileDescriptor(
-  name='eigr/protocol.proto',
-  package='eigr.protocol',
-  syntax='proto3',
-  serialized_options=b'\n\032io.eigr.functions.protocolZ1github.com/eigr/go-support/eigr/protocol;protocol',
-  create_key=_descriptor._internal_create_key,
-  serialized_pb=b'\n\x13\x65igr/protocol.proto\x12\reigr.protocol\x1a\x10\x65igr/actor.proto\x1a\x19google/protobuf/any.proto\"w\n\x13RegistrationRequest\x12\x30\n\x0cservice_info\x18\x01 \x01(\x0b\x32\x1a.eigr.protocol.ServiceInfo\x12.\n\x0c\x61\x63tor_system\x18\x02 \x01(\x0b\x32\x18.eigr.actors.ActorSystem\"\xd4\x01\n\x0bServiceInfo\x12\x14\n\x0cservice_name\x18\x01 \x01(\t\x12\x17\n\x0fservice_version\x18\x02 \x01(\t\x12\x17\n\x0fservice_runtime\x18\x03 \x01(\t\x12\x1c\n\x14support_library_name\x18\x04 \x01(\t\x12\x1f\n\x17support_library_version\x18\x05 \x01(\t\x12\x1e\n\x16protocol_major_version\x18\x06 \x01(\x05\x12\x1e\n\x16protocol_minor_version\x18\x07 \x01(\x05\"v\n\tProxyInfo\x12\x1e\n\x16protocol_major_version\x18\x01 \x01(\x05\x12\x1e\n\x16protocol_minor_version\x18\x02 \x01(\x05\x12\x12\n\nproxy_name\x18\x03 \x01(\t\x12\x15\n\rproxy_version\x18\x04 \x01(\t\"r\n\x14RegistrationResponse\x12,\n\x06status\x18\x01 \x01(\x0b\x32\x1c.eigr.protocol.RequestStatus\x12,\n\nproxy_info\x18\x02 \x01(\x0b\x32\x18.eigr.protocol.ProxyInfo\".\n\x07\x43ontext\x12#\n\x05state\x18\x01 \x01(\x0b\x32\x14.google.protobuf.Any\"\xaa\x01\n\x11InvocationRequest\x12(\n\x06system\x18\x01 \x01(\x0b\x32\x18.eigr.actors.ActorSystem\x12!\n\x05\x61\x63tor\x18\x02 \x01(\x0b\x32\x12.eigr.actors.Actor\x12\x14\n\x0c\x63ommand_name\x18\x03 \x01(\t\x12#\n\x05value\x18\x04 \x01(\x0b\x32\x14.google.protobuf.Any\x12\r\n\x05\x61sync\x18\x05 \x01(\x08\"\xa7\x01\n\x0f\x41\x63torInvocation\x12\x12\n\nactor_name\x18\x01 \x01(\t\x12\x14\n\x0c\x61\x63tor_system\x18\x02 \x01(\t\x12\x14\n\x0c\x63ommand_name\x18\x03 \x01(\t\x12/\n\x0f\x63urrent_context\x18\x04 \x01(\x0b\x32\x16.eigr.protocol.Context\x12#\n\x05value\x18\x05 \x01(\x0b\x32\x14.google.protobuf.Any\"\x99\x01\n\x17\x41\x63torInvocationResponse\x12\x12\n\nactor_name\x18\x01 \x01(\t\x12\x14\n\x0c\x61\x63tor_system\x18\x02 \x01(\t\x12/\n\x0fupdated_context\x18\x03 \x01(\x0b\x32\x16.eigr.protocol.Context\x12#\n\x05value\x18\x04 \x01(\x0b\x32\x14.google.protobuf.Any\"\xb4\x01\n\x12InvocationResponse\x12,\n\x06status\x18\x01 \x01(\x0b\x32\x1c.eigr.protocol.RequestStatus\x12(\n\x06system\x18\x02 \x01(\x0b\x32\x18.eigr.actors.ActorSystem\x12!\n\x05\x61\x63tor\x18\x03 \x01(\x0b\x32\x12.eigr.actors.Actor\x12#\n\x05value\x18\x04 \x01(\x0b\x32\x14.google.protobuf.Any\"G\n\rRequestStatus\x12%\n\x06status\x18\x01 \x01(\x0e\x32\x15.eigr.protocol.Status\x12\x0f\n\x07message\x18\x02 \x01(\t*=\n\x06Status\x12\x0b\n\x07UNKNOWN\x10\x00\x12\x06\n\x02OK\x10\x01\x12\x13\n\x0f\x41\x43TOR_NOT_FOUND\x10\x02\x12\t\n\x05\x45RROR\x10\x03\x42O\n\x1aio.eigr.functions.protocolZ1github.com/eigr/go-support/eigr/protocol;protocolb\x06proto3'
-  ,
-  dependencies=[eigr_dot_actor__pb2.DESCRIPTOR,google_dot_protobuf_dot_any__pb2.DESCRIPTOR,])
+    name="eigr/protocol.proto",
+    package="eigr.protocol",
+    syntax="proto3",
+    serialized_options=b"\n\032io.eigr.functions.protocolZ1github.com/eigr/go-support/eigr/protocol;protocol",
+    create_key=_descriptor._internal_create_key,
+    serialized_pb=b'\n\x13\x65igr/protocol.proto\x12\reigr.protocol\x1a\x10\x65igr/actor.proto\x1a\x19google/protobuf/any.proto">\n\x0cSpawnRequest\x12.\n\x0c\x61\x63tor_system\x18\x02 \x01(\x0b\x32\x18.eigr.actors.ActorSystem"=\n\rSpawnResponse\x12,\n\x06status\x18\x01 \x01(\x0b\x32\x1c.eigr.protocol.RequestStatus"w\n\x13RegistrationRequest\x12\x30\n\x0cservice_info\x18\x01 \x01(\x0b\x32\x1a.eigr.protocol.ServiceInfo\x12.\n\x0c\x61\x63tor_system\x18\x02 \x01(\x0b\x32\x18.eigr.actors.ActorSystem"\xd4\x01\n\x0bServiceInfo\x12\x14\n\x0cservice_name\x18\x01 \x01(\t\x12\x17\n\x0fservice_version\x18\x02 \x01(\t\x12\x17\n\x0fservice_runtime\x18\x03 \x01(\t\x12\x1c\n\x14support_library_name\x18\x04 \x01(\t\x12\x1f\n\x17support_library_version\x18\x05 \x01(\t\x12\x1e\n\x16protocol_major_version\x18\x06 \x01(\x05\x12\x1e\n\x16protocol_minor_version\x18\x07 \x01(\x05"v\n\tProxyInfo\x12\x1e\n\x16protocol_major_version\x18\x01 \x01(\x05\x12\x1e\n\x16protocol_minor_version\x18\x02 \x01(\x05\x12\x12\n\nproxy_name\x18\x03 \x01(\t\x12\x15\n\rproxy_version\x18\x04 \x01(\t"r\n\x14RegistrationResponse\x12,\n\x06status\x18\x01 \x01(\x0b\x32\x1c.eigr.protocol.RequestStatus\x12,\n\nproxy_info\x18\x02 \x01(\x0b\x32\x18.eigr.protocol.ProxyInfo".\n\x07\x43ontext\x12#\n\x05state\x18\x01 \x01(\x0b\x32\x14.google.protobuf.Any"?\n\nSideEffect\x12\x31\n\x07request\x18\x01 \x01(\x0b\x32 .eigr.protocol.InvocationRequest"]\n\tBroadcast\x12\x15\n\rchannel_group\x18\x01 \x01(\t\x12\x14\n\x0c\x63ommand_name\x18\x02 \x01(\t\x12#\n\x05value\x18\x03 \x01(\x0b\x32\x14.google.protobuf.Any"+\n\x04Pipe\x12\r\n\x05\x61\x63tor\x18\x01 \x01(\t\x12\x14\n\x0c\x63ommand_name\x18\x02 \x01(\t".\n\x07\x46orward\x12\r\n\x05\x61\x63tor\x18\x01 \x01(\t\x12\x14\n\x0c\x63ommand_name\x18\x02 \x01(\t"\xbe\x01\n\x08Workflow\x12+\n\tbroadcast\x18\x02 \x01(\x0b\x32\x18.eigr.protocol.Broadcast\x12*\n\x07\x65\x66\x66\x65\x63ts\x18\x01 \x03(\x0b\x32\x19.eigr.protocol.SideEffect\x12#\n\x04pipe\x18\x03 \x01(\x0b\x32\x13.eigr.protocol.PipeH\x00\x12)\n\x07\x66orward\x18\x04 \x01(\x0b\x32\x16.eigr.protocol.ForwardH\x00\x42\t\n\x07routing"\xaa\x01\n\x11InvocationRequest\x12(\n\x06system\x18\x01 \x01(\x0b\x32\x18.eigr.actors.ActorSystem\x12!\n\x05\x61\x63tor\x18\x02 \x01(\x0b\x32\x12.eigr.actors.Actor\x12\x14\n\x0c\x63ommand_name\x18\x03 \x01(\t\x12#\n\x05value\x18\x04 \x01(\x0b\x32\x14.google.protobuf.Any\x12\r\n\x05\x61sync\x18\x05 \x01(\x08"\xa7\x01\n\x0f\x41\x63torInvocation\x12\x12\n\nactor_name\x18\x01 \x01(\t\x12\x14\n\x0c\x61\x63tor_system\x18\x02 \x01(\t\x12\x14\n\x0c\x63ommand_name\x18\x03 \x01(\t\x12/\n\x0f\x63urrent_context\x18\x04 \x01(\x0b\x32\x16.eigr.protocol.Context\x12#\n\x05value\x18\x05 \x01(\x0b\x32\x14.google.protobuf.Any"\xc4\x01\n\x17\x41\x63torInvocationResponse\x12\x12\n\nactor_name\x18\x01 \x01(\t\x12\x14\n\x0c\x61\x63tor_system\x18\x02 \x01(\t\x12/\n\x0fupdated_context\x18\x03 \x01(\x0b\x32\x16.eigr.protocol.Context\x12#\n\x05value\x18\x04 \x01(\x0b\x32\x14.google.protobuf.Any\x12)\n\x08workflow\x18\x05 \x01(\x0b\x32\x17.eigr.protocol.Workflow"\xb4\x01\n\x12InvocationResponse\x12,\n\x06status\x18\x01 \x01(\x0b\x32\x1c.eigr.protocol.RequestStatus\x12(\n\x06system\x18\x02 \x01(\x0b\x32\x18.eigr.actors.ActorSystem\x12!\n\x05\x61\x63tor\x18\x03 \x01(\x0b\x32\x12.eigr.actors.Actor\x12#\n\x05value\x18\x04 \x01(\x0b\x32\x14.google.protobuf.Any"G\n\rRequestStatus\x12%\n\x06status\x18\x01 \x01(\x0e\x32\x15.eigr.protocol.Status\x12\x0f\n\x07message\x18\x02 \x01(\t*=\n\x06Status\x12\x0b\n\x07UNKNOWN\x10\x00\x12\x06\n\x02OK\x10\x01\x12\x13\n\x0f\x41\x43TOR_NOT_FOUND\x10\x02\x12\t\n\x05\x45RROR\x10\x03\x42O\n\x1aio.eigr.functions.protocolZ1github.com/eigr/go-support/eigr/protocol;protocolb\x06proto3',
+    dependencies=[
+        eigr_dot_actor__pb2.DESCRIPTOR,
+        google_dot_protobuf_dot_any__pb2.DESCRIPTOR,
+    ],
+)
 
 _STATUS = _descriptor.EnumDescriptor(
-  name='Status',
-  full_name='eigr.protocol.Status',
-  filename=None,
-  file=DESCRIPTOR,
-  create_key=_descriptor._internal_create_key,
-  values=[
-    _descriptor.EnumValueDescriptor(
-      name='UNKNOWN', index=0, number=0,
-      serialized_options=None,
-      type=None,
-      create_key=_descriptor._internal_create_key),
-    _descriptor.EnumValueDescriptor(
-      name='OK', index=1, number=1,
-      serialized_options=None,
-      type=None,
-      create_key=_descriptor._internal_create_key),
-    _descriptor.EnumValueDescriptor(
-      name='ACTOR_NOT_FOUND', index=2, number=2,
-      serialized_options=None,
-      type=None,
-      create_key=_descriptor._internal_create_key),
-    _descriptor.EnumValueDescriptor(
-      name='ERROR', index=3, number=3,
-      serialized_options=None,
-      type=None,
-      create_key=_descriptor._internal_create_key),
-  ],
-  containing_type=None,
-  serialized_options=None,
-  serialized_start=1458,
-  serialized_end=1519,
+    name="Status",
+    full_name="eigr.protocol.Status",
+    filename=None,
+    file=DESCRIPTOR,
+    create_key=_descriptor._internal_create_key,
+    values=[
+        _descriptor.EnumValueDescriptor(
+            name="UNKNOWN",
+            index=0,
+            number=0,
+            serialized_options=None,
+            type=None,
+            create_key=_descriptor._internal_create_key,
+        ),
+        _descriptor.EnumValueDescriptor(
+            name="OK",
+            index=1,
+            number=1,
+            serialized_options=None,
+            type=None,
+            create_key=_descriptor._internal_create_key,
+        ),
+        _descriptor.EnumValueDescriptor(
+            name="ACTOR_NOT_FOUND",
+            index=2,
+            number=2,
+            serialized_options=None,
+            type=None,
+            create_key=_descriptor._internal_create_key,
+        ),
+        _descriptor.EnumValueDescriptor(
+            name="ERROR",
+            index=3,
+            number=3,
+            serialized_options=None,
+            type=None,
+            create_key=_descriptor._internal_create_key,
+        ),
+    ],
+    containing_type=None,
+    serialized_options=None,
+    serialized_start=2074,
+    serialized_end=2135,
 )
 _sym_db.RegisterEnumDescriptor(_STATUS)
 
@@ -68,606 +84,1610 @@
 ERROR = 3
 
 
+_SPAWNREQUEST = _descriptor.Descriptor(
+    name="SpawnRequest",
+    full_name="eigr.protocol.SpawnRequest",
+    filename=None,
+    file=DESCRIPTOR,
+    containing_type=None,
+    create_key=_descriptor._internal_create_key,
+    fields=[
+        _descriptor.FieldDescriptor(
+            name="actor_system",
+            full_name="eigr.protocol.SpawnRequest.actor_system",
+            index=0,
+            number=2,
+            type=11,
+            cpp_type=10,
+            label=1,
+            has_default_value=False,
+            default_value=None,
+            message_type=None,
+            enum_type=None,
+            containing_type=None,
+            is_extension=False,
+            extension_scope=None,
+            serialized_options=None,
+            file=DESCRIPTOR,
+            create_key=_descriptor._internal_create_key,
+        ),
+    ],
+    extensions=[],
+    nested_types=[],
+    enum_types=[],
+    serialized_options=None,
+    is_extendable=False,
+    syntax="proto3",
+    extension_ranges=[],
+    oneofs=[],
+    serialized_start=83,
+    serialized_end=145,
+)
+
+
+_SPAWNRESPONSE = _descriptor.Descriptor(
+    name="SpawnResponse",
+    full_name="eigr.protocol.SpawnResponse",
+    filename=None,
+    file=DESCRIPTOR,
+    containing_type=None,
+    create_key=_descriptor._internal_create_key,
+    fields=[
+        _descriptor.FieldDescriptor(
+            name="status",
+            full_name="eigr.protocol.SpawnResponse.status",
+            index=0,
+            number=1,
+            type=11,
+            cpp_type=10,
+            label=1,
+            has_default_value=False,
+            default_value=None,
+            message_type=None,
+            enum_type=None,
+            containing_type=None,
+            is_extension=False,
+            extension_scope=None,
+            serialized_options=None,
+            file=DESCRIPTOR,
+            create_key=_descriptor._internal_create_key,
+        ),
+    ],
+    extensions=[],
+    nested_types=[],
+    enum_types=[],
+    serialized_options=None,
+    is_extendable=False,
+    syntax="proto3",
+    extension_ranges=[],
+    oneofs=[],
+    serialized_start=147,
+    serialized_end=208,
+)
+
 
 _REGISTRATIONREQUEST = _descriptor.Descriptor(
-  name='RegistrationRequest',
-  full_name='eigr.protocol.RegistrationRequest',
-  filename=None,
-  file=DESCRIPTOR,
-  containing_type=None,
-  create_key=_descriptor._internal_create_key,
-  fields=[
-    _descriptor.FieldDescriptor(
-      name='service_info', full_name='eigr.protocol.RegistrationRequest.service_info', index=0,
-      number=1, type=11, cpp_type=10, label=1,
-      has_default_value=False, default_value=None,
-      message_type=None, enum_type=None, containing_type=None,
-      is_extension=False, extension_scope=None,
-      serialized_options=None, file=DESCRIPTOR,  create_key=_descriptor._internal_create_key),
-    _descriptor.FieldDescriptor(
-      name='actor_system', full_name='eigr.protocol.RegistrationRequest.actor_system', index=1,
-      number=2, type=11, cpp_type=10, label=1,
-      has_default_value=False, default_value=None,
-      message_type=None, enum_type=None, containing_type=None,
-      is_extension=False, extension_scope=None,
-      serialized_options=None, file=DESCRIPTOR,  create_key=_descriptor._internal_create_key),
-  ],
-  extensions=[
-  ],
-  nested_types=[],
-  enum_types=[
-  ],
-  serialized_options=None,
-  is_extendable=False,
-  syntax='proto3',
-  extension_ranges=[],
-  oneofs=[
-  ],
-  serialized_start=83,
-  serialized_end=202,
+    name="RegistrationRequest",
+    full_name="eigr.protocol.RegistrationRequest",
+    filename=None,
+    file=DESCRIPTOR,
+    containing_type=None,
+    create_key=_descriptor._internal_create_key,
+    fields=[
+        _descriptor.FieldDescriptor(
+            name="service_info",
+            full_name="eigr.protocol.RegistrationRequest.service_info",
+            index=0,
+            number=1,
+            type=11,
+            cpp_type=10,
+            label=1,
+            has_default_value=False,
+            default_value=None,
+            message_type=None,
+            enum_type=None,
+            containing_type=None,
+            is_extension=False,
+            extension_scope=None,
+            serialized_options=None,
+            file=DESCRIPTOR,
+            create_key=_descriptor._internal_create_key,
+        ),
+        _descriptor.FieldDescriptor(
+            name="actor_system",
+            full_name="eigr.protocol.RegistrationRequest.actor_system",
+            index=1,
+            number=2,
+            type=11,
+            cpp_type=10,
+            label=1,
+            has_default_value=False,
+            default_value=None,
+            message_type=None,
+            enum_type=None,
+            containing_type=None,
+            is_extension=False,
+            extension_scope=None,
+            serialized_options=None,
+            file=DESCRIPTOR,
+            create_key=_descriptor._internal_create_key,
+        ),
+    ],
+    extensions=[],
+    nested_types=[],
+    enum_types=[],
+    serialized_options=None,
+    is_extendable=False,
+    syntax="proto3",
+    extension_ranges=[],
+    oneofs=[],
+    serialized_start=210,
+    serialized_end=329,
 )
 
 
 _SERVICEINFO = _descriptor.Descriptor(
-  name='ServiceInfo',
-  full_name='eigr.protocol.ServiceInfo',
-  filename=None,
-  file=DESCRIPTOR,
-  containing_type=None,
-  create_key=_descriptor._internal_create_key,
-  fields=[
-    _descriptor.FieldDescriptor(
-      name='service_name', full_name='eigr.protocol.ServiceInfo.service_name', index=0,
-      number=1, type=9, cpp_type=9, label=1,
-      has_default_value=False, default_value=b"".decode('utf-8'),
-      message_type=None, enum_type=None, containing_type=None,
-      is_extension=False, extension_scope=None,
-      serialized_options=None, file=DESCRIPTOR,  create_key=_descriptor._internal_create_key),
-    _descriptor.FieldDescriptor(
-      name='service_version', full_name='eigr.protocol.ServiceInfo.service_version', index=1,
-      number=2, type=9, cpp_type=9, label=1,
-      has_default_value=False, default_value=b"".decode('utf-8'),
-      message_type=None, enum_type=None, containing_type=None,
-      is_extension=False, extension_scope=None,
-      serialized_options=None, file=DESCRIPTOR,  create_key=_descriptor._internal_create_key),
-    _descriptor.FieldDescriptor(
-      name='service_runtime', full_name='eigr.protocol.ServiceInfo.service_runtime', index=2,
-      number=3, type=9, cpp_type=9, label=1,
-      has_default_value=False, default_value=b"".decode('utf-8'),
-      message_type=None, enum_type=None, containing_type=None,
-      is_extension=False, extension_scope=None,
-      serialized_options=None, file=DESCRIPTOR,  create_key=_descriptor._internal_create_key),
-    _descriptor.FieldDescriptor(
-      name='support_library_name', full_name='eigr.protocol.ServiceInfo.support_library_name', index=3,
-      number=4, type=9, cpp_type=9, label=1,
-      has_default_value=False, default_value=b"".decode('utf-8'),
-      message_type=None, enum_type=None, containing_type=None,
-      is_extension=False, extension_scope=None,
-      serialized_options=None, file=DESCRIPTOR,  create_key=_descriptor._internal_create_key),
-    _descriptor.FieldDescriptor(
-      name='support_library_version', full_name='eigr.protocol.ServiceInfo.support_library_version', index=4,
-      number=5, type=9, cpp_type=9, label=1,
-      has_default_value=False, default_value=b"".decode('utf-8'),
-      message_type=None, enum_type=None, containing_type=None,
-      is_extension=False, extension_scope=None,
-      serialized_options=None, file=DESCRIPTOR,  create_key=_descriptor._internal_create_key),
-    _descriptor.FieldDescriptor(
-      name='protocol_major_version', full_name='eigr.protocol.ServiceInfo.protocol_major_version', index=5,
-      number=6, type=5, cpp_type=1, label=1,
-      has_default_value=False, default_value=0,
-      message_type=None, enum_type=None, containing_type=None,
-      is_extension=False, extension_scope=None,
-      serialized_options=None, file=DESCRIPTOR,  create_key=_descriptor._internal_create_key),
-    _descriptor.FieldDescriptor(
-      name='protocol_minor_version', full_name='eigr.protocol.ServiceInfo.protocol_minor_version', index=6,
-      number=7, type=5, cpp_type=1, label=1,
-      has_default_value=False, default_value=0,
-      message_type=None, enum_type=None, containing_type=None,
-      is_extension=False, extension_scope=None,
-      serialized_options=None, file=DESCRIPTOR,  create_key=_descriptor._internal_create_key),
-  ],
-  extensions=[
-  ],
-  nested_types=[],
-  enum_types=[
-  ],
-  serialized_options=None,
-  is_extendable=False,
-  syntax='proto3',
-  extension_ranges=[],
-  oneofs=[
-  ],
-  serialized_start=205,
-  serialized_end=417,
+    name="ServiceInfo",
+    full_name="eigr.protocol.ServiceInfo",
+    filename=None,
+    file=DESCRIPTOR,
+    containing_type=None,
+    create_key=_descriptor._internal_create_key,
+    fields=[
+        _descriptor.FieldDescriptor(
+            name="service_name",
+            full_name="eigr.protocol.ServiceInfo.service_name",
+            index=0,
+            number=1,
+            type=9,
+            cpp_type=9,
+            label=1,
+            has_default_value=False,
+            default_value=b"".decode("utf-8"),
+            message_type=None,
+            enum_type=None,
+            containing_type=None,
+            is_extension=False,
+            extension_scope=None,
+            serialized_options=None,
+            file=DESCRIPTOR,
+            create_key=_descriptor._internal_create_key,
+        ),
+        _descriptor.FieldDescriptor(
+            name="service_version",
+            full_name="eigr.protocol.ServiceInfo.service_version",
+            index=1,
+            number=2,
+            type=9,
+            cpp_type=9,
+            label=1,
+            has_default_value=False,
+            default_value=b"".decode("utf-8"),
+            message_type=None,
+            enum_type=None,
+            containing_type=None,
+            is_extension=False,
+            extension_scope=None,
+            serialized_options=None,
+            file=DESCRIPTOR,
+            create_key=_descriptor._internal_create_key,
+        ),
+        _descriptor.FieldDescriptor(
+            name="service_runtime",
+            full_name="eigr.protocol.ServiceInfo.service_runtime",
+            index=2,
+            number=3,
+            type=9,
+            cpp_type=9,
+            label=1,
+            has_default_value=False,
+            default_value=b"".decode("utf-8"),
+            message_type=None,
+            enum_type=None,
+            containing_type=None,
+            is_extension=False,
+            extension_scope=None,
+            serialized_options=None,
+            file=DESCRIPTOR,
+            create_key=_descriptor._internal_create_key,
+        ),
+        _descriptor.FieldDescriptor(
+            name="support_library_name",
+            full_name="eigr.protocol.ServiceInfo.support_library_name",
+            index=3,
+            number=4,
+            type=9,
+            cpp_type=9,
+            label=1,
+            has_default_value=False,
+            default_value=b"".decode("utf-8"),
+            message_type=None,
+            enum_type=None,
+            containing_type=None,
+            is_extension=False,
+            extension_scope=None,
+            serialized_options=None,
+            file=DESCRIPTOR,
+            create_key=_descriptor._internal_create_key,
+        ),
+        _descriptor.FieldDescriptor(
+            name="support_library_version",
+            full_name="eigr.protocol.ServiceInfo.support_library_version",
+            index=4,
+            number=5,
+            type=9,
+            cpp_type=9,
+            label=1,
+            has_default_value=False,
+            default_value=b"".decode("utf-8"),
+            message_type=None,
+            enum_type=None,
+            containing_type=None,
+            is_extension=False,
+            extension_scope=None,
+            serialized_options=None,
+            file=DESCRIPTOR,
+            create_key=_descriptor._internal_create_key,
+        ),
+        _descriptor.FieldDescriptor(
+            name="protocol_major_version",
+            full_name="eigr.protocol.ServiceInfo.protocol_major_version",
+            index=5,
+            number=6,
+            type=5,
+            cpp_type=1,
+            label=1,
+            has_default_value=False,
+            default_value=0,
+            message_type=None,
+            enum_type=None,
+            containing_type=None,
+            is_extension=False,
+            extension_scope=None,
+            serialized_options=None,
+            file=DESCRIPTOR,
+            create_key=_descriptor._internal_create_key,
+        ),
+        _descriptor.FieldDescriptor(
+            name="protocol_minor_version",
+            full_name="eigr.protocol.ServiceInfo.protocol_minor_version",
+            index=6,
+            number=7,
+            type=5,
+            cpp_type=1,
+            label=1,
+            has_default_value=False,
+            default_value=0,
+            message_type=None,
+            enum_type=None,
+            containing_type=None,
+            is_extension=False,
+            extension_scope=None,
+            serialized_options=None,
+            file=DESCRIPTOR,
+            create_key=_descriptor._internal_create_key,
+        ),
+    ],
+    extensions=[],
+    nested_types=[],
+    enum_types=[],
+    serialized_options=None,
+    is_extendable=False,
+    syntax="proto3",
+    extension_ranges=[],
+    oneofs=[],
+    serialized_start=332,
+    serialized_end=544,
 )
 
 
 _PROXYINFO = _descriptor.Descriptor(
-  name='ProxyInfo',
-  full_name='eigr.protocol.ProxyInfo',
-  filename=None,
-  file=DESCRIPTOR,
-  containing_type=None,
-  create_key=_descriptor._internal_create_key,
-  fields=[
-    _descriptor.FieldDescriptor(
-      name='protocol_major_version', full_name='eigr.protocol.ProxyInfo.protocol_major_version', index=0,
-      number=1, type=5, cpp_type=1, label=1,
-      has_default_value=False, default_value=0,
-      message_type=None, enum_type=None, containing_type=None,
-      is_extension=False, extension_scope=None,
-      serialized_options=None, file=DESCRIPTOR,  create_key=_descriptor._internal_create_key),
-    _descriptor.FieldDescriptor(
-      name='protocol_minor_version', full_name='eigr.protocol.ProxyInfo.protocol_minor_version', index=1,
-      number=2, type=5, cpp_type=1, label=1,
-      has_default_value=False, default_value=0,
-      message_type=None, enum_type=None, containing_type=None,
-      is_extension=False, extension_scope=None,
-      serialized_options=None, file=DESCRIPTOR,  create_key=_descriptor._internal_create_key),
-    _descriptor.FieldDescriptor(
-      name='proxy_name', full_name='eigr.protocol.ProxyInfo.proxy_name', index=2,
-      number=3, type=9, cpp_type=9, label=1,
-      has_default_value=False, default_value=b"".decode('utf-8'),
-      message_type=None, enum_type=None, containing_type=None,
-      is_extension=False, extension_scope=None,
-      serialized_options=None, file=DESCRIPTOR,  create_key=_descriptor._internal_create_key),
-    _descriptor.FieldDescriptor(
-      name='proxy_version', full_name='eigr.protocol.ProxyInfo.proxy_version', index=3,
-      number=4, type=9, cpp_type=9, label=1,
-      has_default_value=False, default_value=b"".decode('utf-8'),
-      message_type=None, enum_type=None, containing_type=None,
-      is_extension=False, extension_scope=None,
-      serialized_options=None, file=DESCRIPTOR,  create_key=_descriptor._internal_create_key),
-  ],
-  extensions=[
-  ],
-  nested_types=[],
-  enum_types=[
-  ],
-  serialized_options=None,
-  is_extendable=False,
-  syntax='proto3',
-  extension_ranges=[],
-  oneofs=[
-  ],
-  serialized_start=419,
-  serialized_end=537,
+    name="ProxyInfo",
+    full_name="eigr.protocol.ProxyInfo",
+    filename=None,
+    file=DESCRIPTOR,
+    containing_type=None,
+    create_key=_descriptor._internal_create_key,
+    fields=[
+        _descriptor.FieldDescriptor(
+            name="protocol_major_version",
+            full_name="eigr.protocol.ProxyInfo.protocol_major_version",
+            index=0,
+            number=1,
+            type=5,
+            cpp_type=1,
+            label=1,
+            has_default_value=False,
+            default_value=0,
+            message_type=None,
+            enum_type=None,
+            containing_type=None,
+            is_extension=False,
+            extension_scope=None,
+            serialized_options=None,
+            file=DESCRIPTOR,
+            create_key=_descriptor._internal_create_key,
+        ),
+        _descriptor.FieldDescriptor(
+            name="protocol_minor_version",
+            full_name="eigr.protocol.ProxyInfo.protocol_minor_version",
+            index=1,
+            number=2,
+            type=5,
+            cpp_type=1,
+            label=1,
+            has_default_value=False,
+            default_value=0,
+            message_type=None,
+            enum_type=None,
+            containing_type=None,
+            is_extension=False,
+            extension_scope=None,
+            serialized_options=None,
+            file=DESCRIPTOR,
+            create_key=_descriptor._internal_create_key,
+        ),
+        _descriptor.FieldDescriptor(
+            name="proxy_name",
+            full_name="eigr.protocol.ProxyInfo.proxy_name",
+            index=2,
+            number=3,
+            type=9,
+            cpp_type=9,
+            label=1,
+            has_default_value=False,
+            default_value=b"".decode("utf-8"),
+            message_type=None,
+            enum_type=None,
+            containing_type=None,
+            is_extension=False,
+            extension_scope=None,
+            serialized_options=None,
+            file=DESCRIPTOR,
+            create_key=_descriptor._internal_create_key,
+        ),
+        _descriptor.FieldDescriptor(
+            name="proxy_version",
+            full_name="eigr.protocol.ProxyInfo.proxy_version",
+            index=3,
+            number=4,
+            type=9,
+            cpp_type=9,
+            label=1,
+            has_default_value=False,
+            default_value=b"".decode("utf-8"),
+            message_type=None,
+            enum_type=None,
+            containing_type=None,
+            is_extension=False,
+            extension_scope=None,
+            serialized_options=None,
+            file=DESCRIPTOR,
+            create_key=_descriptor._internal_create_key,
+        ),
+    ],
+    extensions=[],
+    nested_types=[],
+    enum_types=[],
+    serialized_options=None,
+    is_extendable=False,
+    syntax="proto3",
+    extension_ranges=[],
+    oneofs=[],
+    serialized_start=546,
+    serialized_end=664,
 )
 
 
 _REGISTRATIONRESPONSE = _descriptor.Descriptor(
-  name='RegistrationResponse',
-  full_name='eigr.protocol.RegistrationResponse',
-  filename=None,
-  file=DESCRIPTOR,
-  containing_type=None,
-  create_key=_descriptor._internal_create_key,
-  fields=[
-    _descriptor.FieldDescriptor(
-      name='status', full_name='eigr.protocol.RegistrationResponse.status', index=0,
-      number=1, type=11, cpp_type=10, label=1,
-      has_default_value=False, default_value=None,
-      message_type=None, enum_type=None, containing_type=None,
-      is_extension=False, extension_scope=None,
-      serialized_options=None, file=DESCRIPTOR,  create_key=_descriptor._internal_create_key),
-    _descriptor.FieldDescriptor(
-      name='proxy_info', full_name='eigr.protocol.RegistrationResponse.proxy_info', index=1,
-      number=2, type=11, cpp_type=10, label=1,
-      has_default_value=False, default_value=None,
-      message_type=None, enum_type=None, containing_type=None,
-      is_extension=False, extension_scope=None,
-      serialized_options=None, file=DESCRIPTOR,  create_key=_descriptor._internal_create_key),
-  ],
-  extensions=[
-  ],
-  nested_types=[],
-  enum_types=[
-  ],
-  serialized_options=None,
-  is_extendable=False,
-  syntax='proto3',
-  extension_ranges=[],
-  oneofs=[
-  ],
-  serialized_start=539,
-  serialized_end=653,
+    name="RegistrationResponse",
+    full_name="eigr.protocol.RegistrationResponse",
+    filename=None,
+    file=DESCRIPTOR,
+    containing_type=None,
+    create_key=_descriptor._internal_create_key,
+    fields=[
+        _descriptor.FieldDescriptor(
+            name="status",
+            full_name="eigr.protocol.RegistrationResponse.status",
+            index=0,
+            number=1,
+            type=11,
+            cpp_type=10,
+            label=1,
+            has_default_value=False,
+            default_value=None,
+            message_type=None,
+            enum_type=None,
+            containing_type=None,
+            is_extension=False,
+            extension_scope=None,
+            serialized_options=None,
+            file=DESCRIPTOR,
+            create_key=_descriptor._internal_create_key,
+        ),
+        _descriptor.FieldDescriptor(
+            name="proxy_info",
+            full_name="eigr.protocol.RegistrationResponse.proxy_info",
+            index=1,
+            number=2,
+            type=11,
+            cpp_type=10,
+            label=1,
+            has_default_value=False,
+            default_value=None,
+            message_type=None,
+            enum_type=None,
+            containing_type=None,
+            is_extension=False,
+            extension_scope=None,
+            serialized_options=None,
+            file=DESCRIPTOR,
+            create_key=_descriptor._internal_create_key,
+        ),
+    ],
+    extensions=[],
+    nested_types=[],
+    enum_types=[],
+    serialized_options=None,
+    is_extendable=False,
+    syntax="proto3",
+    extension_ranges=[],
+    oneofs=[],
+    serialized_start=666,
+    serialized_end=780,
 )
 
 
 _CONTEXT = _descriptor.Descriptor(
-  name='Context',
-  full_name='eigr.protocol.Context',
-  filename=None,
-  file=DESCRIPTOR,
-  containing_type=None,
-  create_key=_descriptor._internal_create_key,
-  fields=[
-    _descriptor.FieldDescriptor(
-      name='state', full_name='eigr.protocol.Context.state', index=0,
-      number=1, type=11, cpp_type=10, label=1,
-      has_default_value=False, default_value=None,
-      message_type=None, enum_type=None, containing_type=None,
-      is_extension=False, extension_scope=None,
-      serialized_options=None, file=DESCRIPTOR,  create_key=_descriptor._internal_create_key),
-  ],
-  extensions=[
-  ],
-  nested_types=[],
-  enum_types=[
-  ],
-  serialized_options=None,
-  is_extendable=False,
-  syntax='proto3',
-  extension_ranges=[],
-  oneofs=[
-  ],
-  serialized_start=655,
-  serialized_end=701,
+    name="Context",
+    full_name="eigr.protocol.Context",
+    filename=None,
+    file=DESCRIPTOR,
+    containing_type=None,
+    create_key=_descriptor._internal_create_key,
+    fields=[
+        _descriptor.FieldDescriptor(
+            name="state",
+            full_name="eigr.protocol.Context.state",
+            index=0,
+            number=1,
+            type=11,
+            cpp_type=10,
+            label=1,
+            has_default_value=False,
+            default_value=None,
+            message_type=None,
+            enum_type=None,
+            containing_type=None,
+            is_extension=False,
+            extension_scope=None,
+            serialized_options=None,
+            file=DESCRIPTOR,
+            create_key=_descriptor._internal_create_key,
+        ),
+    ],
+    extensions=[],
+    nested_types=[],
+    enum_types=[],
+    serialized_options=None,
+    is_extendable=False,
+    syntax="proto3",
+    extension_ranges=[],
+    oneofs=[],
+    serialized_start=782,
+    serialized_end=828,
+)
+
+
+_SIDEEFFECT = _descriptor.Descriptor(
+    name="SideEffect",
+    full_name="eigr.protocol.SideEffect",
+    filename=None,
+    file=DESCRIPTOR,
+    containing_type=None,
+    create_key=_descriptor._internal_create_key,
+    fields=[
+        _descriptor.FieldDescriptor(
+            name="request",
+            full_name="eigr.protocol.SideEffect.request",
+            index=0,
+            number=1,
+            type=11,
+            cpp_type=10,
+            label=1,
+            has_default_value=False,
+            default_value=None,
+            message_type=None,
+            enum_type=None,
+            containing_type=None,
+            is_extension=False,
+            extension_scope=None,
+            serialized_options=None,
+            file=DESCRIPTOR,
+            create_key=_descriptor._internal_create_key,
+        ),
+    ],
+    extensions=[],
+    nested_types=[],
+    enum_types=[],
+    serialized_options=None,
+    is_extendable=False,
+    syntax="proto3",
+    extension_ranges=[],
+    oneofs=[],
+    serialized_start=830,
+    serialized_end=893,
+)
+
+
+_BROADCAST = _descriptor.Descriptor(
+    name="Broadcast",
+    full_name="eigr.protocol.Broadcast",
+    filename=None,
+    file=DESCRIPTOR,
+    containing_type=None,
+    create_key=_descriptor._internal_create_key,
+    fields=[
+        _descriptor.FieldDescriptor(
+            name="channel_group",
+            full_name="eigr.protocol.Broadcast.channel_group",
+            index=0,
+            number=1,
+            type=9,
+            cpp_type=9,
+            label=1,
+            has_default_value=False,
+            default_value=b"".decode("utf-8"),
+            message_type=None,
+            enum_type=None,
+            containing_type=None,
+            is_extension=False,
+            extension_scope=None,
+            serialized_options=None,
+            file=DESCRIPTOR,
+            create_key=_descriptor._internal_create_key,
+        ),
+        _descriptor.FieldDescriptor(
+            name="command_name",
+            full_name="eigr.protocol.Broadcast.command_name",
+            index=1,
+            number=2,
+            type=9,
+            cpp_type=9,
+            label=1,
+            has_default_value=False,
+            default_value=b"".decode("utf-8"),
+            message_type=None,
+            enum_type=None,
+            containing_type=None,
+            is_extension=False,
+            extension_scope=None,
+            serialized_options=None,
+            file=DESCRIPTOR,
+            create_key=_descriptor._internal_create_key,
+        ),
+        _descriptor.FieldDescriptor(
+            name="value",
+            full_name="eigr.protocol.Broadcast.value",
+            index=2,
+            number=3,
+            type=11,
+            cpp_type=10,
+            label=1,
+            has_default_value=False,
+            default_value=None,
+            message_type=None,
+            enum_type=None,
+            containing_type=None,
+            is_extension=False,
+            extension_scope=None,
+            serialized_options=None,
+            file=DESCRIPTOR,
+            create_key=_descriptor._internal_create_key,
+        ),
+    ],
+    extensions=[],
+    nested_types=[],
+    enum_types=[],
+    serialized_options=None,
+    is_extendable=False,
+    syntax="proto3",
+    extension_ranges=[],
+    oneofs=[],
+    serialized_start=895,
+    serialized_end=988,
+)
+
+
+_PIPE = _descriptor.Descriptor(
+    name="Pipe",
+    full_name="eigr.protocol.Pipe",
+    filename=None,
+    file=DESCRIPTOR,
+    containing_type=None,
+    create_key=_descriptor._internal_create_key,
+    fields=[
+        _descriptor.FieldDescriptor(
+            name="actor",
+            full_name="eigr.protocol.Pipe.actor",
+            index=0,
+            number=1,
+            type=9,
+            cpp_type=9,
+            label=1,
+            has_default_value=False,
+            default_value=b"".decode("utf-8"),
+            message_type=None,
+            enum_type=None,
+            containing_type=None,
+            is_extension=False,
+            extension_scope=None,
+            serialized_options=None,
+            file=DESCRIPTOR,
+            create_key=_descriptor._internal_create_key,
+        ),
+        _descriptor.FieldDescriptor(
+            name="command_name",
+            full_name="eigr.protocol.Pipe.command_name",
+            index=1,
+            number=2,
+            type=9,
+            cpp_type=9,
+            label=1,
+            has_default_value=False,
+            default_value=b"".decode("utf-8"),
+            message_type=None,
+            enum_type=None,
+            containing_type=None,
+            is_extension=False,
+            extension_scope=None,
+            serialized_options=None,
+            file=DESCRIPTOR,
+            create_key=_descriptor._internal_create_key,
+        ),
+    ],
+    extensions=[],
+    nested_types=[],
+    enum_types=[],
+    serialized_options=None,
+    is_extendable=False,
+    syntax="proto3",
+    extension_ranges=[],
+    oneofs=[],
+    serialized_start=990,
+    serialized_end=1033,
+)
+
+
+_FORWARD = _descriptor.Descriptor(
+    name="Forward",
+    full_name="eigr.protocol.Forward",
+    filename=None,
+    file=DESCRIPTOR,
+    containing_type=None,
+    create_key=_descriptor._internal_create_key,
+    fields=[
+        _descriptor.FieldDescriptor(
+            name="actor",
+            full_name="eigr.protocol.Forward.actor",
+            index=0,
+            number=1,
+            type=9,
+            cpp_type=9,
+            label=1,
+            has_default_value=False,
+            default_value=b"".decode("utf-8"),
+            message_type=None,
+            enum_type=None,
+            containing_type=None,
+            is_extension=False,
+            extension_scope=None,
+            serialized_options=None,
+            file=DESCRIPTOR,
+            create_key=_descriptor._internal_create_key,
+        ),
+        _descriptor.FieldDescriptor(
+            name="command_name",
+            full_name="eigr.protocol.Forward.command_name",
+            index=1,
+            number=2,
+            type=9,
+            cpp_type=9,
+            label=1,
+            has_default_value=False,
+            default_value=b"".decode("utf-8"),
+            message_type=None,
+            enum_type=None,
+            containing_type=None,
+            is_extension=False,
+            extension_scope=None,
+            serialized_options=None,
+            file=DESCRIPTOR,
+            create_key=_descriptor._internal_create_key,
+        ),
+    ],
+    extensions=[],
+    nested_types=[],
+    enum_types=[],
+    serialized_options=None,
+    is_extendable=False,
+    syntax="proto3",
+    extension_ranges=[],
+    oneofs=[],
+    serialized_start=1035,
+    serialized_end=1081,
+)
+
+
+_WORKFLOW = _descriptor.Descriptor(
+    name="Workflow",
+    full_name="eigr.protocol.Workflow",
+    filename=None,
+    file=DESCRIPTOR,
+    containing_type=None,
+    create_key=_descriptor._internal_create_key,
+    fields=[
+        _descriptor.FieldDescriptor(
+            name="broadcast",
+            full_name="eigr.protocol.Workflow.broadcast",
+            index=0,
+            number=2,
+            type=11,
+            cpp_type=10,
+            label=1,
+            has_default_value=False,
+            default_value=None,
+            message_type=None,
+            enum_type=None,
+            containing_type=None,
+            is_extension=False,
+            extension_scope=None,
+            serialized_options=None,
+            file=DESCRIPTOR,
+            create_key=_descriptor._internal_create_key,
+        ),
+        _descriptor.FieldDescriptor(
+            name="effects",
+            full_name="eigr.protocol.Workflow.effects",
+            index=1,
+            number=1,
+            type=11,
+            cpp_type=10,
+            label=3,
+            has_default_value=False,
+            default_value=[],
+            message_type=None,
+            enum_type=None,
+            containing_type=None,
+            is_extension=False,
+            extension_scope=None,
+            serialized_options=None,
+            file=DESCRIPTOR,
+            create_key=_descriptor._internal_create_key,
+        ),
+        _descriptor.FieldDescriptor(
+            name="pipe",
+            full_name="eigr.protocol.Workflow.pipe",
+            index=2,
+            number=3,
+            type=11,
+            cpp_type=10,
+            label=1,
+            has_default_value=False,
+            default_value=None,
+            message_type=None,
+            enum_type=None,
+            containing_type=None,
+            is_extension=False,
+            extension_scope=None,
+            serialized_options=None,
+            file=DESCRIPTOR,
+            create_key=_descriptor._internal_create_key,
+        ),
+        _descriptor.FieldDescriptor(
+            name="forward",
+            full_name="eigr.protocol.Workflow.forward",
+            index=3,
+            number=4,
+            type=11,
+            cpp_type=10,
+            label=1,
+            has_default_value=False,
+            default_value=None,
+            message_type=None,
+            enum_type=None,
+            containing_type=None,
+            is_extension=False,
+            extension_scope=None,
+            serialized_options=None,
+            file=DESCRIPTOR,
+            create_key=_descriptor._internal_create_key,
+        ),
+    ],
+    extensions=[],
+    nested_types=[],
+    enum_types=[],
+    serialized_options=None,
+    is_extendable=False,
+    syntax="proto3",
+    extension_ranges=[],
+    oneofs=[
+        _descriptor.OneofDescriptor(
+            name="routing",
+            full_name="eigr.protocol.Workflow.routing",
+            index=0,
+            containing_type=None,
+            create_key=_descriptor._internal_create_key,
+            fields=[],
+        ),
+    ],
+    serialized_start=1084,
+    serialized_end=1274,
 )
 
 
 _INVOCATIONREQUEST = _descriptor.Descriptor(
-  name='InvocationRequest',
-  full_name='eigr.protocol.InvocationRequest',
-  filename=None,
-  file=DESCRIPTOR,
-  containing_type=None,
-  create_key=_descriptor._internal_create_key,
-  fields=[
-    _descriptor.FieldDescriptor(
-      name='system', full_name='eigr.protocol.InvocationRequest.system', index=0,
-      number=1, type=11, cpp_type=10, label=1,
-      has_default_value=False, default_value=None,
-      message_type=None, enum_type=None, containing_type=None,
-      is_extension=False, extension_scope=None,
-      serialized_options=None, file=DESCRIPTOR,  create_key=_descriptor._internal_create_key),
-    _descriptor.FieldDescriptor(
-      name='actor', full_name='eigr.protocol.InvocationRequest.actor', index=1,
-      number=2, type=11, cpp_type=10, label=1,
-      has_default_value=False, default_value=None,
-      message_type=None, enum_type=None, containing_type=None,
-      is_extension=False, extension_scope=None,
-      serialized_options=None, file=DESCRIPTOR,  create_key=_descriptor._internal_create_key),
-    _descriptor.FieldDescriptor(
-      name='command_name', full_name='eigr.protocol.InvocationRequest.command_name', index=2,
-      number=3, type=9, cpp_type=9, label=1,
-      has_default_value=False, default_value=b"".decode('utf-8'),
-      message_type=None, enum_type=None, containing_type=None,
-      is_extension=False, extension_scope=None,
-      serialized_options=None, file=DESCRIPTOR,  create_key=_descriptor._internal_create_key),
-    _descriptor.FieldDescriptor(
-      name='value', full_name='eigr.protocol.InvocationRequest.value', index=3,
-      number=4, type=11, cpp_type=10, label=1,
-      has_default_value=False, default_value=None,
-      message_type=None, enum_type=None, containing_type=None,
-      is_extension=False, extension_scope=None,
-      serialized_options=None, file=DESCRIPTOR,  create_key=_descriptor._internal_create_key),
-    _descriptor.FieldDescriptor(
-      name='async', full_name='eigr.protocol.InvocationRequest.async', index=4,
-      number=5, type=8, cpp_type=7, label=1,
-      has_default_value=False, default_value=False,
-      message_type=None, enum_type=None, containing_type=None,
-      is_extension=False, extension_scope=None,
-      serialized_options=None, file=DESCRIPTOR,  create_key=_descriptor._internal_create_key),
-  ],
-  extensions=[
-  ],
-  nested_types=[],
-  enum_types=[
-  ],
-  serialized_options=None,
-  is_extendable=False,
-  syntax='proto3',
-  extension_ranges=[],
-  oneofs=[
-  ],
-  serialized_start=704,
-  serialized_end=874,
+    name="InvocationRequest",
+    full_name="eigr.protocol.InvocationRequest",
+    filename=None,
+    file=DESCRIPTOR,
+    containing_type=None,
+    create_key=_descriptor._internal_create_key,
+    fields=[
+        _descriptor.FieldDescriptor(
+            name="system",
+            full_name="eigr.protocol.InvocationRequest.system",
+            index=0,
+            number=1,
+            type=11,
+            cpp_type=10,
+            label=1,
+            has_default_value=False,
+            default_value=None,
+            message_type=None,
+            enum_type=None,
+            containing_type=None,
+            is_extension=False,
+            extension_scope=None,
+            serialized_options=None,
+            file=DESCRIPTOR,
+            create_key=_descriptor._internal_create_key,
+        ),
+        _descriptor.FieldDescriptor(
+            name="actor",
+            full_name="eigr.protocol.InvocationRequest.actor",
+            index=1,
+            number=2,
+            type=11,
+            cpp_type=10,
+            label=1,
+            has_default_value=False,
+            default_value=None,
+            message_type=None,
+            enum_type=None,
+            containing_type=None,
+            is_extension=False,
+            extension_scope=None,
+            serialized_options=None,
+            file=DESCRIPTOR,
+            create_key=_descriptor._internal_create_key,
+        ),
+        _descriptor.FieldDescriptor(
+            name="command_name",
+            full_name="eigr.protocol.InvocationRequest.command_name",
+            index=2,
+            number=3,
+            type=9,
+            cpp_type=9,
+            label=1,
+            has_default_value=False,
+            default_value=b"".decode("utf-8"),
+            message_type=None,
+            enum_type=None,
+            containing_type=None,
+            is_extension=False,
+            extension_scope=None,
+            serialized_options=None,
+            file=DESCRIPTOR,
+            create_key=_descriptor._internal_create_key,
+        ),
+        _descriptor.FieldDescriptor(
+            name="value",
+            full_name="eigr.protocol.InvocationRequest.value",
+            index=3,
+            number=4,
+            type=11,
+            cpp_type=10,
+            label=1,
+            has_default_value=False,
+            default_value=None,
+            message_type=None,
+            enum_type=None,
+            containing_type=None,
+            is_extension=False,
+            extension_scope=None,
+            serialized_options=None,
+            file=DESCRIPTOR,
+            create_key=_descriptor._internal_create_key,
+        ),
+        _descriptor.FieldDescriptor(
+            name="async",
+            full_name="eigr.protocol.InvocationRequest.async",
+            index=4,
+            number=5,
+            type=8,
+            cpp_type=7,
+            label=1,
+            has_default_value=False,
+            default_value=False,
+            message_type=None,
+            enum_type=None,
+            containing_type=None,
+            is_extension=False,
+            extension_scope=None,
+            serialized_options=None,
+            file=DESCRIPTOR,
+            create_key=_descriptor._internal_create_key,
+        ),
+    ],
+    extensions=[],
+    nested_types=[],
+    enum_types=[],
+    serialized_options=None,
+    is_extendable=False,
+    syntax="proto3",
+    extension_ranges=[],
+    oneofs=[],
+    serialized_start=1277,
+    serialized_end=1447,
 )
 
 
 _ACTORINVOCATION = _descriptor.Descriptor(
-  name='ActorInvocation',
-  full_name='eigr.protocol.ActorInvocation',
-  filename=None,
-  file=DESCRIPTOR,
-  containing_type=None,
-  create_key=_descriptor._internal_create_key,
-  fields=[
-    _descriptor.FieldDescriptor(
-      name='actor_name', full_name='eigr.protocol.ActorInvocation.actor_name', index=0,
-      number=1, type=9, cpp_type=9, label=1,
-      has_default_value=False, default_value=b"".decode('utf-8'),
-      message_type=None, enum_type=None, containing_type=None,
-      is_extension=False, extension_scope=None,
-      serialized_options=None, file=DESCRIPTOR,  create_key=_descriptor._internal_create_key),
-    _descriptor.FieldDescriptor(
-      name='actor_system', full_name='eigr.protocol.ActorInvocation.actor_system', index=1,
-      number=2, type=9, cpp_type=9, label=1,
-      has_default_value=False, default_value=b"".decode('utf-8'),
-      message_type=None, enum_type=None, containing_type=None,
-      is_extension=False, extension_scope=None,
-      serialized_options=None, file=DESCRIPTOR,  create_key=_descriptor._internal_create_key),
-    _descriptor.FieldDescriptor(
-      name='command_name', full_name='eigr.protocol.ActorInvocation.command_name', index=2,
-      number=3, type=9, cpp_type=9, label=1,
-      has_default_value=False, default_value=b"".decode('utf-8'),
-      message_type=None, enum_type=None, containing_type=None,
-      is_extension=False, extension_scope=None,
-      serialized_options=None, file=DESCRIPTOR,  create_key=_descriptor._internal_create_key),
-    _descriptor.FieldDescriptor(
-      name='current_context', full_name='eigr.protocol.ActorInvocation.current_context', index=3,
-      number=4, type=11, cpp_type=10, label=1,
-      has_default_value=False, default_value=None,
-      message_type=None, enum_type=None, containing_type=None,
-      is_extension=False, extension_scope=None,
-      serialized_options=None, file=DESCRIPTOR,  create_key=_descriptor._internal_create_key),
-    _descriptor.FieldDescriptor(
-      name='value', full_name='eigr.protocol.ActorInvocation.value', index=4,
-      number=5, type=11, cpp_type=10, label=1,
-      has_default_value=False, default_value=None,
-      message_type=None, enum_type=None, containing_type=None,
-      is_extension=False, extension_scope=None,
-      serialized_options=None, file=DESCRIPTOR,  create_key=_descriptor._internal_create_key),
-  ],
-  extensions=[
-  ],
-  nested_types=[],
-  enum_types=[
-  ],
-  serialized_options=None,
-  is_extendable=False,
-  syntax='proto3',
-  extension_ranges=[],
-  oneofs=[
-  ],
-  serialized_start=877,
-  serialized_end=1044,
+    name="ActorInvocation",
+    full_name="eigr.protocol.ActorInvocation",
+    filename=None,
+    file=DESCRIPTOR,
+    containing_type=None,
+    create_key=_descriptor._internal_create_key,
+    fields=[
+        _descriptor.FieldDescriptor(
+            name="actor_name",
+            full_name="eigr.protocol.ActorInvocation.actor_name",
+            index=0,
+            number=1,
+            type=9,
+            cpp_type=9,
+            label=1,
+            has_default_value=False,
+            default_value=b"".decode("utf-8"),
+            message_type=None,
+            enum_type=None,
+            containing_type=None,
+            is_extension=False,
+            extension_scope=None,
+            serialized_options=None,
+            file=DESCRIPTOR,
+            create_key=_descriptor._internal_create_key,
+        ),
+        _descriptor.FieldDescriptor(
+            name="actor_system",
+            full_name="eigr.protocol.ActorInvocation.actor_system",
+            index=1,
+            number=2,
+            type=9,
+            cpp_type=9,
+            label=1,
+            has_default_value=False,
+            default_value=b"".decode("utf-8"),
+            message_type=None,
+            enum_type=None,
+            containing_type=None,
+            is_extension=False,
+            extension_scope=None,
+            serialized_options=None,
+            file=DESCRIPTOR,
+            create_key=_descriptor._internal_create_key,
+        ),
+        _descriptor.FieldDescriptor(
+            name="command_name",
+            full_name="eigr.protocol.ActorInvocation.command_name",
+            index=2,
+            number=3,
+            type=9,
+            cpp_type=9,
+            label=1,
+            has_default_value=False,
+            default_value=b"".decode("utf-8"),
+            message_type=None,
+            enum_type=None,
+            containing_type=None,
+            is_extension=False,
+            extension_scope=None,
+            serialized_options=None,
+            file=DESCRIPTOR,
+            create_key=_descriptor._internal_create_key,
+        ),
+        _descriptor.FieldDescriptor(
+            name="current_context",
+            full_name="eigr.protocol.ActorInvocation.current_context",
+            index=3,
+            number=4,
+            type=11,
+            cpp_type=10,
+            label=1,
+            has_default_value=False,
+            default_value=None,
+            message_type=None,
+            enum_type=None,
+            containing_type=None,
+            is_extension=False,
+            extension_scope=None,
+            serialized_options=None,
+            file=DESCRIPTOR,
+            create_key=_descriptor._internal_create_key,
+        ),
+        _descriptor.FieldDescriptor(
+            name="value",
+            full_name="eigr.protocol.ActorInvocation.value",
+            index=4,
+            number=5,
+            type=11,
+            cpp_type=10,
+            label=1,
+            has_default_value=False,
+            default_value=None,
+            message_type=None,
+            enum_type=None,
+            containing_type=None,
+            is_extension=False,
+            extension_scope=None,
+            serialized_options=None,
+            file=DESCRIPTOR,
+            create_key=_descriptor._internal_create_key,
+        ),
+    ],
+    extensions=[],
+    nested_types=[],
+    enum_types=[],
+    serialized_options=None,
+    is_extendable=False,
+    syntax="proto3",
+    extension_ranges=[],
+    oneofs=[],
+    serialized_start=1450,
+    serialized_end=1617,
 )
 
 
 _ACTORINVOCATIONRESPONSE = _descriptor.Descriptor(
-  name='ActorInvocationResponse',
-  full_name='eigr.protocol.ActorInvocationResponse',
-  filename=None,
-  file=DESCRIPTOR,
-  containing_type=None,
-  create_key=_descriptor._internal_create_key,
-  fields=[
-    _descriptor.FieldDescriptor(
-      name='actor_name', full_name='eigr.protocol.ActorInvocationResponse.actor_name', index=0,
-      number=1, type=9, cpp_type=9, label=1,
-      has_default_value=False, default_value=b"".decode('utf-8'),
-      message_type=None, enum_type=None, containing_type=None,
-      is_extension=False, extension_scope=None,
-      serialized_options=None, file=DESCRIPTOR,  create_key=_descriptor._internal_create_key),
-    _descriptor.FieldDescriptor(
-      name='actor_system', full_name='eigr.protocol.ActorInvocationResponse.actor_system', index=1,
-      number=2, type=9, cpp_type=9, label=1,
-      has_default_value=False, default_value=b"".decode('utf-8'),
-      message_type=None, enum_type=None, containing_type=None,
-      is_extension=False, extension_scope=None,
-      serialized_options=None, file=DESCRIPTOR,  create_key=_descriptor._internal_create_key),
-    _descriptor.FieldDescriptor(
-      name='updated_context', full_name='eigr.protocol.ActorInvocationResponse.updated_context', index=2,
-      number=3, type=11, cpp_type=10, label=1,
-      has_default_value=False, default_value=None,
-      message_type=None, enum_type=None, containing_type=None,
-      is_extension=False, extension_scope=None,
-      serialized_options=None, file=DESCRIPTOR,  create_key=_descriptor._internal_create_key),
-    _descriptor.FieldDescriptor(
-      name='value', full_name='eigr.protocol.ActorInvocationResponse.value', index=3,
-      number=4, type=11, cpp_type=10, label=1,
-      has_default_value=False, default_value=None,
-      message_type=None, enum_type=None, containing_type=None,
-      is_extension=False, extension_scope=None,
-      serialized_options=None, file=DESCRIPTOR,  create_key=_descriptor._internal_create_key),
-  ],
-  extensions=[
-  ],
-  nested_types=[],
-  enum_types=[
-  ],
-  serialized_options=None,
-  is_extendable=False,
-  syntax='proto3',
-  extension_ranges=[],
-  oneofs=[
-  ],
-  serialized_start=1047,
-  serialized_end=1200,
+    name="ActorInvocationResponse",
+    full_name="eigr.protocol.ActorInvocationResponse",
+    filename=None,
+    file=DESCRIPTOR,
+    containing_type=None,
+    create_key=_descriptor._internal_create_key,
+    fields=[
+        _descriptor.FieldDescriptor(
+            name="actor_name",
+            full_name="eigr.protocol.ActorInvocationResponse.actor_name",
+            index=0,
+            number=1,
+            type=9,
+            cpp_type=9,
+            label=1,
+            has_default_value=False,
+            default_value=b"".decode("utf-8"),
+            message_type=None,
+            enum_type=None,
+            containing_type=None,
+            is_extension=False,
+            extension_scope=None,
+            serialized_options=None,
+            file=DESCRIPTOR,
+            create_key=_descriptor._internal_create_key,
+        ),
+        _descriptor.FieldDescriptor(
+            name="actor_system",
+            full_name="eigr.protocol.ActorInvocationResponse.actor_system",
+            index=1,
+            number=2,
+            type=9,
+            cpp_type=9,
+            label=1,
+            has_default_value=False,
+            default_value=b"".decode("utf-8"),
+            message_type=None,
+            enum_type=None,
+            containing_type=None,
+            is_extension=False,
+            extension_scope=None,
+            serialized_options=None,
+            file=DESCRIPTOR,
+            create_key=_descriptor._internal_create_key,
+        ),
+        _descriptor.FieldDescriptor(
+            name="updated_context",
+            full_name="eigr.protocol.ActorInvocationResponse.updated_context",
+            index=2,
+            number=3,
+            type=11,
+            cpp_type=10,
+            label=1,
+            has_default_value=False,
+            default_value=None,
+            message_type=None,
+            enum_type=None,
+            containing_type=None,
+            is_extension=False,
+            extension_scope=None,
+            serialized_options=None,
+            file=DESCRIPTOR,
+            create_key=_descriptor._internal_create_key,
+        ),
+        _descriptor.FieldDescriptor(
+            name="value",
+            full_name="eigr.protocol.ActorInvocationResponse.value",
+            index=3,
+            number=4,
+            type=11,
+            cpp_type=10,
+            label=1,
+            has_default_value=False,
+            default_value=None,
+            message_type=None,
+            enum_type=None,
+            containing_type=None,
+            is_extension=False,
+            extension_scope=None,
+            serialized_options=None,
+            file=DESCRIPTOR,
+            create_key=_descriptor._internal_create_key,
+        ),
+        _descriptor.FieldDescriptor(
+            name="workflow",
+            full_name="eigr.protocol.ActorInvocationResponse.workflow",
+            index=4,
+            number=5,
+            type=11,
+            cpp_type=10,
+            label=1,
+            has_default_value=False,
+            default_value=None,
+            message_type=None,
+            enum_type=None,
+            containing_type=None,
+            is_extension=False,
+            extension_scope=None,
+            serialized_options=None,
+            file=DESCRIPTOR,
+            create_key=_descriptor._internal_create_key,
+        ),
+    ],
+    extensions=[],
+    nested_types=[],
+    enum_types=[],
+    serialized_options=None,
+    is_extendable=False,
+    syntax="proto3",
+    extension_ranges=[],
+    oneofs=[],
+    serialized_start=1620,
+    serialized_end=1816,
 )
 
 
 _INVOCATIONRESPONSE = _descriptor.Descriptor(
-  name='InvocationResponse',
-  full_name='eigr.protocol.InvocationResponse',
-  filename=None,
-  file=DESCRIPTOR,
-  containing_type=None,
-  create_key=_descriptor._internal_create_key,
-  fields=[
-    _descriptor.FieldDescriptor(
-      name='status', full_name='eigr.protocol.InvocationResponse.status', index=0,
-      number=1, type=11, cpp_type=10, label=1,
-      has_default_value=False, default_value=None,
-      message_type=None, enum_type=None, containing_type=None,
-      is_extension=False, extension_scope=None,
-      serialized_options=None, file=DESCRIPTOR,  create_key=_descriptor._internal_create_key),
-    _descriptor.FieldDescriptor(
-      name='system', full_name='eigr.protocol.InvocationResponse.system', index=1,
-      number=2, type=11, cpp_type=10, label=1,
-      has_default_value=False, default_value=None,
-      message_type=None, enum_type=None, containing_type=None,
-      is_extension=False, extension_scope=None,
-      serialized_options=None, file=DESCRIPTOR,  create_key=_descriptor._internal_create_key),
-    _descriptor.FieldDescriptor(
-      name='actor', full_name='eigr.protocol.InvocationResponse.actor', index=2,
-      number=3, type=11, cpp_type=10, label=1,
-      has_default_value=False, default_value=None,
-      message_type=None, enum_type=None, containing_type=None,
-      is_extension=False, extension_scope=None,
-      serialized_options=None, file=DESCRIPTOR,  create_key=_descriptor._internal_create_key),
-    _descriptor.FieldDescriptor(
-      name='value', full_name='eigr.protocol.InvocationResponse.value', index=3,
-      number=4, type=11, cpp_type=10, label=1,
-      has_default_value=False, default_value=None,
-      message_type=None, enum_type=None, containing_type=None,
-      is_extension=False, extension_scope=None,
-      serialized_options=None, file=DESCRIPTOR,  create_key=_descriptor._internal_create_key),
-  ],
-  extensions=[
-  ],
-  nested_types=[],
-  enum_types=[
-  ],
-  serialized_options=None,
-  is_extendable=False,
-  syntax='proto3',
-  extension_ranges=[],
-  oneofs=[
-  ],
-  serialized_start=1203,
-  serialized_end=1383,
+    name="InvocationResponse",
+    full_name="eigr.protocol.InvocationResponse",
+    filename=None,
+    file=DESCRIPTOR,
+    containing_type=None,
+    create_key=_descriptor._internal_create_key,
+    fields=[
+        _descriptor.FieldDescriptor(
+            name="status",
+            full_name="eigr.protocol.InvocationResponse.status",
+            index=0,
+            number=1,
+            type=11,
+            cpp_type=10,
+            label=1,
+            has_default_value=False,
+            default_value=None,
+            message_type=None,
+            enum_type=None,
+            containing_type=None,
+            is_extension=False,
+            extension_scope=None,
+            serialized_options=None,
+            file=DESCRIPTOR,
+            create_key=_descriptor._internal_create_key,
+        ),
+        _descriptor.FieldDescriptor(
+            name="system",
+            full_name="eigr.protocol.InvocationResponse.system",
+            index=1,
+            number=2,
+            type=11,
+            cpp_type=10,
+            label=1,
+            has_default_value=False,
+            default_value=None,
+            message_type=None,
+            enum_type=None,
+            containing_type=None,
+            is_extension=False,
+            extension_scope=None,
+            serialized_options=None,
+            file=DESCRIPTOR,
+            create_key=_descriptor._internal_create_key,
+        ),
+        _descriptor.FieldDescriptor(
+            name="actor",
+            full_name="eigr.protocol.InvocationResponse.actor",
+            index=2,
+            number=3,
+            type=11,
+            cpp_type=10,
+            label=1,
+            has_default_value=False,
+            default_value=None,
+            message_type=None,
+            enum_type=None,
+            containing_type=None,
+            is_extension=False,
+            extension_scope=None,
+            serialized_options=None,
+            file=DESCRIPTOR,
+            create_key=_descriptor._internal_create_key,
+        ),
+        _descriptor.FieldDescriptor(
+            name="value",
+            full_name="eigr.protocol.InvocationResponse.value",
+            index=3,
+            number=4,
+            type=11,
+            cpp_type=10,
+            label=1,
+            has_default_value=False,
+            default_value=None,
+            message_type=None,
+            enum_type=None,
+            containing_type=None,
+            is_extension=False,
+            extension_scope=None,
+            serialized_options=None,
+            file=DESCRIPTOR,
+            create_key=_descriptor._internal_create_key,
+        ),
+    ],
+    extensions=[],
+    nested_types=[],
+    enum_types=[],
+    serialized_options=None,
+    is_extendable=False,
+    syntax="proto3",
+    extension_ranges=[],
+    oneofs=[],
+    serialized_start=1819,
+    serialized_end=1999,
 )
 
 
 _REQUESTSTATUS = _descriptor.Descriptor(
-  name='RequestStatus',
-  full_name='eigr.protocol.RequestStatus',
-  filename=None,
-  file=DESCRIPTOR,
-  containing_type=None,
-  create_key=_descriptor._internal_create_key,
-  fields=[
-    _descriptor.FieldDescriptor(
-      name='status', full_name='eigr.protocol.RequestStatus.status', index=0,
-      number=1, type=14, cpp_type=8, label=1,
-      has_default_value=False, default_value=0,
-      message_type=None, enum_type=None, containing_type=None,
-      is_extension=False, extension_scope=None,
-      serialized_options=None, file=DESCRIPTOR,  create_key=_descriptor._internal_create_key),
-    _descriptor.FieldDescriptor(
-      name='message', full_name='eigr.protocol.RequestStatus.message', index=1,
-      number=2, type=9, cpp_type=9, label=1,
-      has_default_value=False, default_value=b"".decode('utf-8'),
-      message_type=None, enum_type=None, containing_type=None,
-      is_extension=False, extension_scope=None,
-      serialized_options=None, file=DESCRIPTOR,  create_key=_descriptor._internal_create_key),
-  ],
-  extensions=[
-  ],
-  nested_types=[],
-  enum_types=[
-  ],
-  serialized_options=None,
-  is_extendable=False,
-  syntax='proto3',
-  extension_ranges=[],
-  oneofs=[
-  ],
-  serialized_start=1385,
-  serialized_end=1456,
-)
-
-_REGISTRATIONREQUEST.fields_by_name['service_info'].message_type = _SERVICEINFO
-_REGISTRATIONREQUEST.fields_by_name['actor_system'].message_type = eigr_dot_actor__pb2._ACTORSYSTEM
-_REGISTRATIONRESPONSE.fields_by_name['status'].message_type = _REQUESTSTATUS
-_REGISTRATIONRESPONSE.fields_by_name['proxy_info'].message_type = _PROXYINFO
-_CONTEXT.fields_by_name['state'].message_type = google_dot_protobuf_dot_any__pb2._ANY
-_INVOCATIONREQUEST.fields_by_name['system'].message_type = eigr_dot_actor__pb2._ACTORSYSTEM
-_INVOCATIONREQUEST.fields_by_name['actor'].message_type = eigr_dot_actor__pb2._ACTOR
-_INVOCATIONREQUEST.fields_by_name['value'].message_type = google_dot_protobuf_dot_any__pb2._ANY
-_ACTORINVOCATION.fields_by_name['current_context'].message_type = _CONTEXT
-_ACTORINVOCATION.fields_by_name['value'].message_type = google_dot_protobuf_dot_any__pb2._ANY
-_ACTORINVOCATIONRESPONSE.fields_by_name['updated_context'].message_type = _CONTEXT
-_ACTORINVOCATIONRESPONSE.fields_by_name['value'].message_type = google_dot_protobuf_dot_any__pb2._ANY
-_INVOCATIONRESPONSE.fields_by_name['status'].message_type = _REQUESTSTATUS
-_INVOCATIONRESPONSE.fields_by_name['system'].message_type = eigr_dot_actor__pb2._ACTORSYSTEM
-_INVOCATIONRESPONSE.fields_by_name['actor'].message_type = eigr_dot_actor__pb2._ACTOR
-_INVOCATIONRESPONSE.fields_by_name['value'].message_type = google_dot_protobuf_dot_any__pb2._ANY
-_REQUESTSTATUS.fields_by_name['status'].enum_type = _STATUS
-DESCRIPTOR.message_types_by_name['RegistrationRequest'] = _REGISTRATIONREQUEST
-DESCRIPTOR.message_types_by_name['ServiceInfo'] = _SERVICEINFO
-DESCRIPTOR.message_types_by_name['ProxyInfo'] = _PROXYINFO
-DESCRIPTOR.message_types_by_name['RegistrationResponse'] = _REGISTRATIONRESPONSE
-DESCRIPTOR.message_types_by_name['Context'] = _CONTEXT
-DESCRIPTOR.message_types_by_name['InvocationRequest'] = _INVOCATIONREQUEST
-DESCRIPTOR.message_types_by_name['ActorInvocation'] = _ACTORINVOCATION
-DESCRIPTOR.message_types_by_name['ActorInvocationResponse'] = _ACTORINVOCATIONRESPONSE
-DESCRIPTOR.message_types_by_name['InvocationResponse'] = _INVOCATIONRESPONSE
-DESCRIPTOR.message_types_by_name['RequestStatus'] = _REQUESTSTATUS
-DESCRIPTOR.enum_types_by_name['Status'] = _STATUS
+    name="RequestStatus",
+    full_name="eigr.protocol.RequestStatus",
+    filename=None,
+    file=DESCRIPTOR,
+    containing_type=None,
+    create_key=_descriptor._internal_create_key,
+    fields=[
+        _descriptor.FieldDescriptor(
+            name="status",
+            full_name="eigr.protocol.RequestStatus.status",
+            index=0,
+            number=1,
+            type=14,
+            cpp_type=8,
+            label=1,
+            has_default_value=False,
+            default_value=0,
+            message_type=None,
+            enum_type=None,
+            containing_type=None,
+            is_extension=False,
+            extension_scope=None,
+            serialized_options=None,
+            file=DESCRIPTOR,
+            create_key=_descriptor._internal_create_key,
+        ),
+        _descriptor.FieldDescriptor(
+            name="message",
+            full_name="eigr.protocol.RequestStatus.message",
+            index=1,
+            number=2,
+            type=9,
+            cpp_type=9,
+            label=1,
+            has_default_value=False,
+            default_value=b"".decode("utf-8"),
+            message_type=None,
+            enum_type=None,
+            containing_type=None,
+            is_extension=False,
+            extension_scope=None,
+            serialized_options=None,
+            file=DESCRIPTOR,
+            create_key=_descriptor._internal_create_key,
+        ),
+    ],
+    extensions=[],
+    nested_types=[],
+    enum_types=[],
+    serialized_options=None,
+    is_extendable=False,
+    syntax="proto3",
+    extension_ranges=[],
+    oneofs=[],
+    serialized_start=2001,
+    serialized_end=2072,
+)
+
+_SPAWNREQUEST.fields_by_name[
+    "actor_system"
+].message_type = eigr_dot_actor__pb2._ACTORSYSTEM
+_SPAWNRESPONSE.fields_by_name["status"].message_type = _REQUESTSTATUS
+_REGISTRATIONREQUEST.fields_by_name["service_info"].message_type = _SERVICEINFO
+_REGISTRATIONREQUEST.fields_by_name[
+    "actor_system"
+].message_type = eigr_dot_actor__pb2._ACTORSYSTEM
+_REGISTRATIONRESPONSE.fields_by_name["status"].message_type = _REQUESTSTATUS
+_REGISTRATIONRESPONSE.fields_by_name["proxy_info"].message_type = _PROXYINFO
+_CONTEXT.fields_by_name["state"].message_type = google_dot_protobuf_dot_any__pb2._ANY
+_SIDEEFFECT.fields_by_name["request"].message_type = _INVOCATIONREQUEST
+_BROADCAST.fields_by_name["value"].message_type = google_dot_protobuf_dot_any__pb2._ANY
+_WORKFLOW.fields_by_name["broadcast"].message_type = _BROADCAST
+_WORKFLOW.fields_by_name["effects"].message_type = _SIDEEFFECT
+_WORKFLOW.fields_by_name["pipe"].message_type = _PIPE
+_WORKFLOW.fields_by_name["forward"].message_type = _FORWARD
+_WORKFLOW.oneofs_by_name["routing"].fields.append(_WORKFLOW.fields_by_name["pipe"])
+_WORKFLOW.fields_by_name["pipe"].containing_oneof = _WORKFLOW.oneofs_by_name["routing"]
+_WORKFLOW.oneofs_by_name["routing"].fields.append(_WORKFLOW.fields_by_name["forward"])
+_WORKFLOW.fields_by_name["forward"].containing_oneof = _WORKFLOW.oneofs_by_name[
+    "routing"
+]
+_INVOCATIONREQUEST.fields_by_name[
+    "system"
+].message_type = eigr_dot_actor__pb2._ACTORSYSTEM
+_INVOCATIONREQUEST.fields_by_name["actor"].message_type = eigr_dot_actor__pb2._ACTOR
+_INVOCATIONREQUEST.fields_by_name[
+    "value"
+].message_type = google_dot_protobuf_dot_any__pb2._ANY
+_ACTORINVOCATION.fields_by_name["current_context"].message_type = _CONTEXT
+_ACTORINVOCATION.fields_by_name[
+    "value"
+].message_type = google_dot_protobuf_dot_any__pb2._ANY
+_ACTORINVOCATIONRESPONSE.fields_by_name["updated_context"].message_type = _CONTEXT
+_ACTORINVOCATIONRESPONSE.fields_by_name[
+    "value"
+].message_type = google_dot_protobuf_dot_any__pb2._ANY
+_ACTORINVOCATIONRESPONSE.fields_by_name["workflow"].message_type = _WORKFLOW
+_INVOCATIONRESPONSE.fields_by_name["status"].message_type = _REQUESTSTATUS
+_INVOCATIONRESPONSE.fields_by_name[
+    "system"
+].message_type = eigr_dot_actor__pb2._ACTORSYSTEM
+_INVOCATIONRESPONSE.fields_by_name["actor"].message_type = eigr_dot_actor__pb2._ACTOR
+_INVOCATIONRESPONSE.fields_by_name[
+    "value"
+].message_type = google_dot_protobuf_dot_any__pb2._ANY
+_REQUESTSTATUS.fields_by_name["status"].enum_type = _STATUS
+DESCRIPTOR.message_types_by_name["SpawnRequest"] = _SPAWNREQUEST
+DESCRIPTOR.message_types_by_name["SpawnResponse"] = _SPAWNRESPONSE
+DESCRIPTOR.message_types_by_name["RegistrationRequest"] = _REGISTRATIONREQUEST
+DESCRIPTOR.message_types_by_name["ServiceInfo"] = _SERVICEINFO
+DESCRIPTOR.message_types_by_name["ProxyInfo"] = _PROXYINFO
+DESCRIPTOR.message_types_by_name["RegistrationResponse"] = _REGISTRATIONRESPONSE
+DESCRIPTOR.message_types_by_name["Context"] = _CONTEXT
+DESCRIPTOR.message_types_by_name["SideEffect"] = _SIDEEFFECT
+DESCRIPTOR.message_types_by_name["Broadcast"] = _BROADCAST
+DESCRIPTOR.message_types_by_name["Pipe"] = _PIPE
+DESCRIPTOR.message_types_by_name["Forward"] = _FORWARD
+DESCRIPTOR.message_types_by_name["Workflow"] = _WORKFLOW
+DESCRIPTOR.message_types_by_name["InvocationRequest"] = _INVOCATIONREQUEST
+DESCRIPTOR.message_types_by_name["ActorInvocation"] = _ACTORINVOCATION
+DESCRIPTOR.message_types_by_name["ActorInvocationResponse"] = _ACTORINVOCATIONRESPONSE
+DESCRIPTOR.message_types_by_name["InvocationResponse"] = _INVOCATIONRESPONSE
+DESCRIPTOR.message_types_by_name["RequestStatus"] = _REQUESTSTATUS
+DESCRIPTOR.enum_types_by_name["Status"] = _STATUS
 _sym_db.RegisterFileDescriptor(DESCRIPTOR)
 
-RegistrationRequest = _reflection.GeneratedProtocolMessageType('RegistrationRequest', (_message.Message,), {
-  'DESCRIPTOR' : _REGISTRATIONREQUEST,
-  '__module__' : 'eigr.protocol_pb2'
-  # @@protoc_insertion_point(class_scope:eigr.protocol.RegistrationRequest)
-  })
+SpawnRequest = _reflection.GeneratedProtocolMessageType(
+    "SpawnRequest",
+    (_message.Message,),
+    {
+        "DESCRIPTOR": _SPAWNREQUEST,
+        "__module__": "eigr.protocol_pb2"
+        # @@protoc_insertion_point(class_scope:eigr.protocol.SpawnRequest)
+    },
+)
+_sym_db.RegisterMessage(SpawnRequest)
+
+SpawnResponse = _reflection.GeneratedProtocolMessageType(
+    "SpawnResponse",
+    (_message.Message,),
+    {
+        "DESCRIPTOR": _SPAWNRESPONSE,
+        "__module__": "eigr.protocol_pb2"
+        # @@protoc_insertion_point(class_scope:eigr.protocol.SpawnResponse)
+    },
+)
+_sym_db.RegisterMessage(SpawnResponse)
+
+RegistrationRequest = _reflection.GeneratedProtocolMessageType(
+    "RegistrationRequest",
+    (_message.Message,),
+    {
+        "DESCRIPTOR": _REGISTRATIONREQUEST,
+        "__module__": "eigr.protocol_pb2"
+        # @@protoc_insertion_point(class_scope:eigr.protocol.RegistrationRequest)
+    },
+)
 _sym_db.RegisterMessage(RegistrationRequest)
 
-ServiceInfo = _reflection.GeneratedProtocolMessageType('ServiceInfo', (_message.Message,), {
-  'DESCRIPTOR' : _SERVICEINFO,
-  '__module__' : 'eigr.protocol_pb2'
-  # @@protoc_insertion_point(class_scope:eigr.protocol.ServiceInfo)
-  })
+ServiceInfo = _reflection.GeneratedProtocolMessageType(
+    "ServiceInfo",
+    (_message.Message,),
+    {
+        "DESCRIPTOR": _SERVICEINFO,
+        "__module__": "eigr.protocol_pb2"
+        # @@protoc_insertion_point(class_scope:eigr.protocol.ServiceInfo)
+    },
+)
 _sym_db.RegisterMessage(ServiceInfo)
 
-ProxyInfo = _reflection.GeneratedProtocolMessageType('ProxyInfo', (_message.Message,), {
-  'DESCRIPTOR' : _PROXYINFO,
-  '__module__' : 'eigr.protocol_pb2'
-  # @@protoc_insertion_point(class_scope:eigr.protocol.ProxyInfo)
-  })
+ProxyInfo = _reflection.GeneratedProtocolMessageType(
+    "ProxyInfo",
+    (_message.Message,),
+    {
+        "DESCRIPTOR": _PROXYINFO,
+        "__module__": "eigr.protocol_pb2"
+        # @@protoc_insertion_point(class_scope:eigr.protocol.ProxyInfo)
+    },
+)
 _sym_db.RegisterMessage(ProxyInfo)
 
-RegistrationResponse = _reflection.GeneratedProtocolMessageType('RegistrationResponse', (_message.Message,), {
-  'DESCRIPTOR' : _REGISTRATIONRESPONSE,
-  '__module__' : 'eigr.protocol_pb2'
-  # @@protoc_insertion_point(class_scope:eigr.protocol.RegistrationResponse)
-  })
+RegistrationResponse = _reflection.GeneratedProtocolMessageType(
+    "RegistrationResponse",
+    (_message.Message,),
+    {
+        "DESCRIPTOR": _REGISTRATIONRESPONSE,
+        "__module__": "eigr.protocol_pb2"
+        # @@protoc_insertion_point(class_scope:eigr.protocol.RegistrationResponse)
+    },
+)
 _sym_db.RegisterMessage(RegistrationResponse)
 
-Context = _reflection.GeneratedProtocolMessageType('Context', (_message.Message,), {
-  'DESCRIPTOR' : _CONTEXT,
-  '__module__' : 'eigr.protocol_pb2'
-  # @@protoc_insertion_point(class_scope:eigr.protocol.Context)
-  })
+Context = _reflection.GeneratedProtocolMessageType(
+    "Context",
+    (_message.Message,),
+    {
+        "DESCRIPTOR": _CONTEXT,
+        "__module__": "eigr.protocol_pb2"
+        # @@protoc_insertion_point(class_scope:eigr.protocol.Context)
+    },
+)
 _sym_db.RegisterMessage(Context)
 
-InvocationRequest = _reflection.GeneratedProtocolMessageType('InvocationRequest', (_message.Message,), {
-  'DESCRIPTOR' : _INVOCATIONREQUEST,
-  '__module__' : 'eigr.protocol_pb2'
-  # @@protoc_insertion_point(class_scope:eigr.protocol.InvocationRequest)
-  })
+SideEffect = _reflection.GeneratedProtocolMessageType(
+    "SideEffect",
+    (_message.Message,),
+    {
+        "DESCRIPTOR": _SIDEEFFECT,
+        "__module__": "eigr.protocol_pb2"
+        # @@protoc_insertion_point(class_scope:eigr.protocol.SideEffect)
+    },
+)
+_sym_db.RegisterMessage(SideEffect)
+
+Broadcast = _reflection.GeneratedProtocolMessageType(
+    "Broadcast",
+    (_message.Message,),
+    {
+        "DESCRIPTOR": _BROADCAST,
+        "__module__": "eigr.protocol_pb2"
+        # @@protoc_insertion_point(class_scope:eigr.protocol.Broadcast)
+    },
+)
+_sym_db.RegisterMessage(Broadcast)
+
+Pipe = _reflection.GeneratedProtocolMessageType(
+    "Pipe",
+    (_message.Message,),
+    {
+        "DESCRIPTOR": _PIPE,
+        "__module__": "eigr.protocol_pb2"
+        # @@protoc_insertion_point(class_scope:eigr.protocol.Pipe)
+    },
+)
+_sym_db.RegisterMessage(Pipe)
+
+Forward = _reflection.GeneratedProtocolMessageType(
+    "Forward",
+    (_message.Message,),
+    {
+        "DESCRIPTOR": _FORWARD,
+        "__module__": "eigr.protocol_pb2"
+        # @@protoc_insertion_point(class_scope:eigr.protocol.Forward)
+    },
+)
+_sym_db.RegisterMessage(Forward)
+
+Workflow = _reflection.GeneratedProtocolMessageType(
+    "Workflow",
+    (_message.Message,),
+    {
+        "DESCRIPTOR": _WORKFLOW,
+        "__module__": "eigr.protocol_pb2"
+        # @@protoc_insertion_point(class_scope:eigr.protocol.Workflow)
+    },
+)
+_sym_db.RegisterMessage(Workflow)
+
+InvocationRequest = _reflection.GeneratedProtocolMessageType(
+    "InvocationRequest",
+    (_message.Message,),
+    {
+        "DESCRIPTOR": _INVOCATIONREQUEST,
+        "__module__": "eigr.protocol_pb2"
+        # @@protoc_insertion_point(class_scope:eigr.protocol.InvocationRequest)
+    },
+)
 _sym_db.RegisterMessage(InvocationRequest)
 
-ActorInvocation = _reflection.GeneratedProtocolMessageType('ActorInvocation', (_message.Message,), {
-  'DESCRIPTOR' : _ACTORINVOCATION,
-  '__module__' : 'eigr.protocol_pb2'
-  # @@protoc_insertion_point(class_scope:eigr.protocol.ActorInvocation)
-  })
+ActorInvocation = _reflection.GeneratedProtocolMessageType(
+    "ActorInvocation",
+    (_message.Message,),
+    {
+        "DESCRIPTOR": _ACTORINVOCATION,
+        "__module__": "eigr.protocol_pb2"
+        # @@protoc_insertion_point(class_scope:eigr.protocol.ActorInvocation)
+    },
+)
 _sym_db.RegisterMessage(ActorInvocation)
 
-ActorInvocationResponse = _reflection.GeneratedProtocolMessageType('ActorInvocationResponse', (_message.Message,), {
-  'DESCRIPTOR' : _ACTORINVOCATIONRESPONSE,
-  '__module__' : 'eigr.protocol_pb2'
-  # @@protoc_insertion_point(class_scope:eigr.protocol.ActorInvocationResponse)
-  })
+ActorInvocationResponse = _reflection.GeneratedProtocolMessageType(
+    "ActorInvocationResponse",
+    (_message.Message,),
+    {
+        "DESCRIPTOR": _ACTORINVOCATIONRESPONSE,
+        "__module__": "eigr.protocol_pb2"
+        # @@protoc_insertion_point(class_scope:eigr.protocol.ActorInvocationResponse)
+    },
+)
 _sym_db.RegisterMessage(ActorInvocationResponse)
 
-InvocationResponse = _reflection.GeneratedProtocolMessageType('InvocationResponse', (_message.Message,), {
-  'DESCRIPTOR' : _INVOCATIONRESPONSE,
-  '__module__' : 'eigr.protocol_pb2'
-  # @@protoc_insertion_point(class_scope:eigr.protocol.InvocationResponse)
-  })
+InvocationResponse = _reflection.GeneratedProtocolMessageType(
+    "InvocationResponse",
+    (_message.Message,),
+    {
+        "DESCRIPTOR": _INVOCATIONRESPONSE,
+        "__module__": "eigr.protocol_pb2"
+        # @@protoc_insertion_point(class_scope:eigr.protocol.InvocationResponse)
+    },
+)
 _sym_db.RegisterMessage(InvocationResponse)
 
-RequestStatus = _reflection.GeneratedProtocolMessageType('RequestStatus', (_message.Message,), {
-  'DESCRIPTOR' : _REQUESTSTATUS,
-  '__module__' : 'eigr.protocol_pb2'
-  # @@protoc_insertion_point(class_scope:eigr.protocol.RequestStatus)
-  })
+RequestStatus = _reflection.GeneratedProtocolMessageType(
+    "RequestStatus",
+    (_message.Message,),
+    {
+        "DESCRIPTOR": _REQUESTSTATUS,
+        "__module__": "eigr.protocol_pb2"
+        # @@protoc_insertion_point(class_scope:eigr.protocol.RequestStatus)
+    },
+)
 _sym_db.RegisterMessage(RequestStatus)