Remove gRPC from the public API

README.md

@@ -13,18 +13,18 @@ as part of long-running processes, or as FaaS (AWS Lambda).
 ```typescript
 // note that there is no failure handling in this example, because the combination of durable execution,
 // communication, and state storage makes this unnecessary here.
-const addToCart = async (ctx: restate.RpcContext, cartId: string /* the key */, ticketId: string) => {
+const addToCart = async (ctx: restateObjectContext,  ticketId: string) => {
   // RPC participates in durable execution, so guaranteed to eventually happen and
   // will never get duplicated. would suspend if the other takes too long
-  const success = await ctx.rpc<ticketApi>({ path: "tickets" }).reserve(ticketId);
+  const success = await ctx.service(ticketApi).reserve(ticketId);
 
   if (success) {
     const cart = (await ctx.get<string[]>("cart")) || []; // gets state 'cart' bound to current cartId
     cart.push(ticketId);
     ctx.set("cart", cart);                                // writes state bound to current cartId
 
     // reliable delayed call sent from Restate, which also participaes in durable execution
-    ctx.sendDelayed<cartApi>({path: "cart"}, minutes(15)).expireTicket(ticketId);
+    ctx.objectSendDelayed(cartApi, minutes(15)).expireTicket(ticketId);
   }
   return success;
 }
@@ -33,7 +33,7 @@ const addToCart = async (ctx: restate.RpcContext, cartId: string /* the key */,
 
 restate
   .createServer()
-  .bindKeyedRouter("cart", restate.keyedRouter({ addToCart, expireTicket }))
+  .object("cart", restate.object({ addToCart, expireTicket }))
   .listen(9080);
 ```
 

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

@@ -9,30 +9,18 @@
  * https://github.com/restatedev/sdk-typescript/blob/main/LICENSE
  */
 
-/*
- * A simple example program using the Restate dynamic RPC-based API.
- *
- * This example primarily exists to make it simple to test the code against
- * a running Restate instance.
- */
-
 import * as restate from "../src/public_api";
 
-//
-// The main entry point for the service, receiving the greeting request and name.
-//
-const greeter = restate.router({
+const greeter = restate.service({
   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" })
-      .count(name);
+    const countSoFar = await ctx.object(counterApi, name).count();
 
     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;
   },
@@ -47,21 +35,21 @@ const greeter = restate.router({
 // This could in principle be the same service as the greet service, we just separate
 // them here to have this multi-service setup for testing.
 //
-const counter = restate.keyedRouter({
-  count: async (ctx: restate.KeyedContext): Promise<number> => {
+const counter = restate.object({
+  count: async (ctx: restate.ObjectContext): Promise<number> => {
     const seen = (await ctx.get<number>("seen")) ?? 0;
     ctx.set("seen", seen + 1);
     return seen;
   },
 });
 
-const greeterApi: restate.ServiceApi<typeof greeter> = { path: "greeter" };
-type counterApiType = typeof counter;
+const greeterApi = restate.serviceApi("greeter", greeter);
+const counterApi = restate.objectApi("counter", counter);
 
 // restate server
 
 restate
   .endpoint()
-  .bindRouter("greeter", greeter)
-  .bindKeyedRouter("counter", counter)
+  .service(greeterApi.path, greeter)
+  .object(counterApi.path, counter)
   .listen(9080);

package.json

@@ -30,10 +30,7 @@
     "verify": "npm run format-check && npm run lint && npm run test && npm run build",
     "release": "release-it",
     "example": "RESTATE_DEBUG_LOGGING=OFF ts-node-dev --transpile-only ./examples/example.ts",
-    "grpcexample": "RESTATE_DEBUG_LOGGING=OFF ts-node-dev --transpile-only ./examples/grpc_example.ts",
-    "workflowexample": "RESTATE_DEBUG_LOGGING=OFF ts-node-dev --transpile-only ./examples/workflow_example.ts",
-    "handlerexample": "RESTATE_DEBUG_LOGGING=OFF ts-node-dev --transpile-only ./examples/handler_example.ts",
-    "expressexample": "RESTATE_DEBUG_LOGGING=OFF ts-node-dev --transpile-only ./examples/embedded_example.ts"
+    "workflowexample": "RESTATE_DEBUG_LOGGING=OFF ts-node-dev --transpile-only ./examples/workflow_example.ts"
   },
   "dependencies": {
     "protobufjs": "^7.2.2",