Skip to content
Closed
Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
20 commits
Select commit Hold shift + click to select a range
3e3ad0a
server 1: add service discovery to dist runtime
mohammedabdulwahhab Oct 23, 2025
b6f0b22
server 2: add register_instance to happen in create_service (add_stat…
mohammedabdulwahhab Oct 23, 2025
d343061
server 3: call instance ready and make nats listener subscribe to ins…
mohammedabdulwahhab Oct 23, 2025
1e07bb3
client 1: .client()
mohammedabdulwahhab Oct 24, 2025
92055d0
client 1: missed a spot
mohammedabdulwahhab Oct 26, 2025
7b4455b
mocker 1: add fs based mocker impl of service discovery
mohammedabdulwahhab Oct 26, 2025
9d39a84
fix: cleanup
mohammedabdulwahhab Oct 26, 2025
cc6404b
fix: got hello world working with filesystem based discovery
mohammedabdulwahhab Oct 26, 2025
9fbc5d7
fix: unit test of k8s endpointslice watch works with real cluster
mohammedabdulwahhab Oct 27, 2025
83b1627
fix: k8s local e2e test working
mohammedabdulwahhab Oct 27, 2025
f88d068
fix: k8s local e2e testing working
mohammedabdulwahhab Oct 27, 2025
c29bd1d
cleanup 1: lib.rs, component.rs
mohammedabdulwahhab Oct 27, 2025
de9aee0
cleanup 2: endpoint.rs
mohammedabdulwahhab Oct 27, 2025
51cc1d5
cleanup 3: client.rs
mohammedabdulwahhab Oct 27, 2025
ae6b5f4
cleanup 3: delete extraneous files
mohammedabdulwahhab Oct 27, 2025
511e69e
cleanup 4: more files
mohammedabdulwahhab Oct 27, 2025
c53f1b5
cleanup 4: distributed.rs and lib.rs
mohammedabdulwahhab Oct 27, 2025
0217151
cleanup 5: remove test changes
mohammedabdulwahhab Oct 27, 2025
b26a8ee
fix: resolve merge conflicts
mohammedabdulwahhab Oct 27, 2025
5a601b1
fix: clippy, fmt
mohammedabdulwahhab Oct 27, 2025
File filter

Filter by extension

Filter by extension


Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
301 changes: 299 additions & 2 deletions Cargo.lock

Large diffs are not rendered by default.

2 changes: 1 addition & 1 deletion examples/custom_backend/hello_world/client.py
Original file line number Diff line number Diff line change
Expand Up @@ -24,7 +24,7 @@
async def worker(runtime: DistributedRuntime):
# Get endpoint
endpoint = (
runtime.namespace("hello_world").component("backend").endpoint("generate")
runtime.namespace("test").component("backend").endpoint("generate")
)

# Create client and wait for service to be ready
Expand Down
2 changes: 1 addition & 1 deletion examples/custom_backend/hello_world/hello_world.py
Original file line number Diff line number Diff line change
Expand Up @@ -23,7 +23,7 @@ async def content_generator(request: str):

@dynamo_worker()
async def worker(runtime: DistributedRuntime):
namespace_name = "hello_world"
namespace_name = "test"
component_name = "backend"
endpoint_name = "generate"

Expand Down
Loading
Loading