Squashed 'sdk-core/src/main/service-protocol/' changes from 1898426f..0d6b476e

0d6b476e Update retry count comment
0d35aad2 Add fields for the Side effect retry feature (#95)
89224c68 Add buf configuration

git-subtree-dir: sdk-core/src/main/service-protocol
git-subtree-split: 0d6b476ea4bb78253fb21edcf151d9c401aecdb1

Author: slinkydeveloper

buf.lock

@@ -0,0 +1,2 @@
+# Generated by buf. DO NOT EDIT.
+version: v2

buf.yaml

@@ -0,0 +1,8 @@
+version: v2
+name: buf.build/restatedev/service-protocol
+lint:
+  use:
+    - DEFAULT
+breaking:
+  use:
+    - FILE

sdk-core/src/main/service-protocol/dev/restate/service/protocol.proto

@@ -19,6 +19,9 @@ enum ServiceProtocolVersion {
   SERVICE_PROTOCOL_VERSION_UNSPECIFIED = 0;
   // initial service protocol version
   V1 = 1;
+  // Added
+  // * Entry retry mechanism: ErrorMessage.next_retry_delay, StartMessage.retry_count_since_last_stored_entry and StartMessage.duration_since_last_stored_entry
+  V2 = 2;
 }
 
 // --- Core frames ---
@@ -47,6 +50,18 @@ message StartMessage {
 
   // If this invocation has a key associated (e.g. for objects and workflows), then this key is filled in. Empty otherwise.
   string key = 6;
+
+  // Retry count since the last stored entry.
+  //
+  // Please note that this count might not be accurate, as it's not durably stored,
+  // thus it might get reset in case Restate crashes/changes leader.
+  uint32 retry_count_since_last_stored_entry = 7;
+
+  // Duration since the last stored entry, in milliseconds.
+  //
+  // Please note this duration might not be accurate,
+  // and might change depending on which Restate replica executes the request.
+  uint64 duration_since_last_stored_entry = 8;
 }
 
 // Type: 0x0000 + 1
@@ -90,6 +105,10 @@ message ErrorMessage {
   optional string related_entry_name = 5;
   // Entry type.
   optional uint32 related_entry_type = 6;
+
+  // Delay before executing the next retry, specified as duration in milliseconds.
+  // If provided, it will override the default retry policy used by Restate's invoker ONLY for the next retry attempt.
+  optional uint64 next_retry_delay = 8;
 }
 
 // Type: 0x0000 + 4