wip

buf.lock

@@ -1,8 +1,2 @@
 # Generated by buf. DO NOT EDIT.
 version: v1
-deps:
-  - remote: buf.build
-    owner: restatedev
-    repository: proto
-    commit: 6ea2d15aed8f408590a1465844df5a8e
-    digest: shake256:e6599809ff13490a631f87d1a4b13ef1886d1bd1c0aa001ccb92806c0acc373d047a6ead761f8a21dfbd57a4fd9acd5915a52e47bd5b4e4a02dd1766f78511b3

buf.yaml

@@ -1,6 +1,6 @@
 version: v1
-deps:
-  - buf.build/restatedev/proto
+#deps:
+#  - buf.build/restatedev/proto
 build:
   excludes:
     - node_modules

examples/example.ts

@@ -25,14 +25,14 @@ const greeter = restate.router({
   greet: async (ctx: restate.Context, name: string) => {
     // blocking RPC call to a keyed service (here supplying type and path separately)
     const countSoFar = await ctx
-      .rpc<counterApiType>({ path: "counter" })
+      .object<counterApiType>({ path: "counter" }, name)
       .count(name);
 
     const message = `Hello ${name}, for the ${countSoFar + 1}th time!`;
 
     // sending messages to ourselves, immediately and delayed
-    ctx.send(greeterApi).logger(message);
-    ctx.sendDelayed(greeterApi, 100).logger("delayed " + message);
+    ctx.serviceSend(greeterApi).logger(message);
+    ctx.serviceSendDelayed(greeterApi, 100).logger("delayed " + message);
 
     return message;
   },

src/context.ts

@@ -249,7 +249,9 @@ export interface Context {
    * const result2 = await ctx.rpc(myApi).anotherAction(1337);
    * ```
    */
-  rpc<M>(opts: ServiceApi<M>): Client<M>;
+  service<M>(opts: ServiceApi<M>): Client<M>;
+
+  object<M>(opts: ServiceApi<M>, key: string): Client<M>;
 
   /**
    * Makes a type-safe one-way RPC to the specified target service. This method effectively behaves
@@ -290,7 +292,8 @@ export interface Context {
    * ctx.send(myApi).anotherAction(1337);
    * ```
    */
-  send<M>(opts: ServiceApi<M>): SendClient<M>;
+  objectSend<M>(opts: ServiceApi<M>, key: string): SendClient<M>;
+  serviceSend<M>(opts: ServiceApi<M>): SendClient<M>;
 
   /**
    * Makes a type-safe one-way RPC to the specified target service, after a delay specified by the
@@ -337,7 +340,12 @@ export interface Context {
    * ctx.sendDelayed(myApi, 60_000).anotherAction(1337);
    * ```
    */
-  sendDelayed<M>(opts: ServiceApi<M>, delay: number): SendClient<M>;
+  objectSendDelayed<M>(
+    opts: ServiceApi<M>,
+    delay: number,
+    key: string
+  ): SendClient<M>;
+  serviceSendDelayed<M>(opts: ServiceApi<M>, delay: number): SendClient<M>;
 }
 
 /**
@@ -352,7 +360,9 @@ export interface Context {
  * This context can be used only within keyed services/routers.
  *
  */
-export interface KeyedContext extends Context, KeyValueStore {}
+export interface KeyedContext extends Context, KeyValueStore {
+  key(): string;
+}
 
 export interface Rand {
   /**