From 09f46e23e61fc93584c33fb786cfe528612a645d Mon Sep 17 00:00:00 2001
From: Magne Helleborg <magne.helleborg@gmail.com>
Date: Tue, 6 Jun 2023 15:58:09 +0200
Subject: [PATCH] Added ability to reprocess from a specific timestamp

---
 .../Events.Processing/EventHandlers.proto          | 14 ++++++++++++++
 1 file changed, 14 insertions(+)

diff --git a/Source/Runtime/Management/Events.Processing/EventHandlers.proto b/Source/Runtime/Management/Events.Processing/EventHandlers.proto
index e97aee0..59c2257 100644
--- a/Source/Runtime/Management/Events.Processing/EventHandlers.proto
+++ b/Source/Runtime/Management/Events.Processing/EventHandlers.proto
@@ -7,6 +7,7 @@ import "Artifacts/Artifact.proto";
 import "Protobuf/Uuid.proto";
 import "Protobuf/Failure.proto";
 import "Runtime/Management/Events.Processing/StreamProcessors.proto";
+import "google/protobuf/timestamp.proto";
 
 package dolittle.runtime.events.processing.management;
 
@@ -25,6 +26,18 @@ message ReprocessEventsFromResponse {
     protobuf.Failure failure = 1; // not set if not failed
 }
 
+message ReprocessEventsFromTimestampRequest {
+    // Tenant is optional here, allowing to update multiple tenants at once if not specified
+    optional protobuf.Uuid tenantId = 1;
+    protobuf.Uuid scopeId = 2;
+    protobuf.Uuid eventHandlerId = 3;
+    uint64 streamPosition = 4;
+}
+
+message ReprocessEventsFromTimestampResponse {
+    protobuf.Failure failure = 1; // not set if not failed
+}
+
 message ReprocessAllEventsRequest {
     // TODO: Do we want another kind of execution context here?
     protobuf.Uuid scopeId = 1;
@@ -68,6 +81,7 @@ message GetOneResponse {
 
 service EventHandlers {
     rpc ReprocessEventsFrom(ReprocessEventsFromRequest) returns(ReprocessEventsFromResponse);
+    rpc ReprocessEventsFromTimestamp(ReprocessEventsFromTimestampRequest) returns(ReprocessEventsFromTimestampResponse);
     rpc ReprocessAllEvents(ReprocessAllEventsRequest) returns(ReprocessAllEventsResponse);
     rpc GetAll(GetAllRequest) returns(GetAllResponse);
     rpc GetOne(GetOneRequest) returns(GetOneResponse);