[Brook] Added Link Records and the client Link Follower.

changelog/added/linking-lynx.md

@@ -0,0 +1 @@
+Experimental `temporalio.contrib.streams`: a producer writes `LINK` records with `link()` and `join()` to name a child Workflow's stream, and `StreamHandle.follow()` reads a stream and every stream its links open in one order, from client or Activity code. Each batch end gives a `FollowPosition` that resumes every open link with no loss and no repeat.

scripts/gen_protos.py

@@ -47,6 +47,9 @@ def find_streams_proto_dir() -> Path:
 
 
 streams_proto_dir = find_streams_proto_dir()
+# The stream API that the crate carries until it lands upstream. Core's api_upstream does not have
+# it, so its modules go into temporalio.api from here.
+streams_api_proto_dir = streams_proto_dir / "api_stream"
 
 # Exclude testsrv dependencies protos
 proto_paths = [
@@ -58,6 +61,7 @@ def find_streams_proto_dir() -> Path:
 ]
 # The crate's api_include copy is left out, since api_upstream generates those modules.
 proto_paths.extend((streams_proto_dir / "temporal").glob("**/*.proto"))
+proto_paths.extend(streams_api_proto_dir.glob("**/*.proto"))
 proto_paths.extend(test_proto_dir.glob("**/*.proto"))
 proto_paths.extend(additional_proto_dir.glob("**/*.proto"))
 
@@ -216,6 +220,7 @@ def generate_protos(output_dir: Path):
             sys.executable,
             "-mgrpc_tools.protoc",
             f"--proto_path={api_proto_dir}",
+            f"--proto_path={streams_api_proto_dir}",
             f"--proto_path={api_cloud_proto_dir}",
             f"--proto_path={core_proto_dir}",
             f"--proto_path={testsrv_proto_dir}",

temporalio/bridge/Cargo.toml

@@ -91,7 +91,7 @@ url = "2.2"
 # makes it use the submodule's crates, so the bridge sees one `Connection` type.
 [dependencies.temporalio-streams]
 git = "https://github.com/moetemp/sdk-streams"
-rev = "7efd5ad9fb0ba72f14ab60676440346bf1e62092"
+rev = "dc5d8bfa9b734a6b8fc7f76b2f97344306ea8427"
 default-features = false
 features = ["envconfig", "redis"]