Merge pull request #98 from dolittle/unbreak-event-horizon

Event Horizon unbreaking

Source/Runtime/EventHorizon/Consumer.proto

@@ -3,29 +3,47 @@
 
 syntax = "proto3";
 
+import "Fundamentals/Artifacts/Artifact.proto";
+import "Fundamentals/Execution/ExecutionContext.proto";
 import "Fundamentals/Protobuf/Failure.proto";
 import "Fundamentals/Protobuf/Uuid.proto";
 import "Fundamentals/Services/ReverseCallContext.proto";
 import "Fundamentals/Services/Ping.proto";
 import "Runtime/EventHorizon/Subscriptions.proto";
-import "Runtime/Events/Committed.proto";
+import "google/protobuf/timestamp.proto";
 
 package dolittle.runtime.eventhorizon;
 
 option csharp_namespace = "Dolittle.Runtime.EventHorizon.Contracts";
 option go_package = "go.dolittle.io/contracts/runtime/eventhorizon";
 
+
+message EventHorizonCommittedEvent {
+    uint64 eventLogSequenceNumber = 1; 
+    google.protobuf.Timestamp occurred = 2;
+    protobuf.Uuid eventSourceId = 3;
+    execution.ExecutionContext executionContext = 4;
+    artifacts.Artifact eventType = 5;
+    bool public = 6;
+    string content = 7;
+    bool external = 8;
+    uint64 externalEventLogSequenceNumber = 9;
+    google.protobuf.Timestamp externalEventReceived = 10;
+    string eventSourceIdString = 11;
+}
+
 message EventHorizonEvent {
     uint64 streamSequenceNumber = 1;
-    events.CommittedEvent event = 2; 
+    EventHorizonCommittedEvent event = 2; 
 }
 
 message ConsumerSubscriptionRequest {
     services.ReverseCallArgumentsContext callContext = 1;
     protobuf.Uuid tenantId = 2;
     protobuf.Uuid streamId = 3;
-    string partitionId = 4;
+    protobuf.Uuid partitionId = 4;
     uint64 streamPosition = 5;
+    string partitionIdString = 6;
 }
 
 message ConsumerResponse {