Solve importing issues in context client docs

Author: gvdongen

examples/services/mod.rs

@@ -0,0 +1,3 @@
+mod my_service;
+mod my_virtual_object;
+mod my_workflow;

examples/my_service.rs renamed to examples/services/my_service.rs

@@ -8,7 +8,7 @@ pub trait MyService {
 pub struct MyServiceImpl;
 
 impl MyService for MyServiceImpl {
-    async fn my_handler(&self, ctx: Context<'_>, greeting: String) -> Result<String, HandlerError> {
+    async fn my_handler(&self, _ctx: Context<'_>, greeting: String) -> Result<String, HandlerError> {
         Ok(format!("{greeting}!"))
     }
 }

examples/my_virtual_object.rs renamed to examples/services/my_virtual_object.rs

@@ -17,7 +17,7 @@ impl MyWorkflow for MyWorkflowImpl {
     }
     async fn interact_with_workflow(
         &self,
-        ctx: SharedWorkflowContext<'_>,
+        _ctx: SharedWorkflowContext<'_>,
     ) -> Result<(), HandlerError> {
         // implement interaction logic here
         // e.g. resolve a promise that the workflow is waiting on

examples/my_workflow.rs renamed to examples/services/my_workflow.rs

@@ -268,12 +268,14 @@ impl<'ctx, CTX: private::SealedContext<'ctx>> ContextTimers<'ctx> for CTX {}
 /// You can do request-response calls to Services, Virtual Objects, and Workflows, in the following way:
 ///
 /// ```
-/// # use crate::_examples::my_service::MyServiceClient;
-/// # use crate::_examples::my_virtual_object::MyVirtualObjectClient;
-/// # use crate::_examples::my_workflow::MyWorkflowClient;
+/// # #[path = "../examples/services"]
+/// # mod services;
+/// # use services::my_service::MyServiceClient;
+/// # use services::my_virtual_object::MyVirtualObjectClient;
+/// # use services::my_workflow::MyWorkflowClient;
 /// # use restate_sdk::prelude::*;
 /// #
-/// # async fn greet1(ctx: Context<'_>, greeting: String) -> Result<(), HandlerError> {
+/// # async fn greet(ctx: Context<'_>, greeting: String) -> Result<(), HandlerError> {
 ///     // To a Service:
 ///     let service_response = ctx
 ///         .service_client::<MyServiceClient>()
@@ -329,13 +331,14 @@ impl<'ctx, CTX: private::SealedContext<'ctx>> ContextTimers<'ctx> for CTX {}
 /// Handlers can send messages (a.k.a. one-way calls, or fire-and-forget calls), as follows:
 ///
 /// ```
-/// # use crate::_examples::my_service::MyServiceClient;
-/// # use crate::_examples::my_virtual_object::MyVirtualObjectClient;
-/// # use crate::_examples::my_workflow::MyWorkflowClient;
+/// # #[path = "../examples/services"]
+/// # mod services;
+/// # use services::my_service::MyServiceClient;
+/// # use services::my_virtual_object::MyVirtualObjectClient;
+/// # use services::my_workflow::MyWorkflowClient;
 /// # use restate_sdk::prelude::*;
 /// #
-/// #
-/// # async fn greet2(ctx: Context<'_>, greeting: String) -> Result<(), HandlerError> {
+/// # async fn greet(ctx: Context<'_>, greeting: String) -> Result<(), HandlerError> {
 ///     // To a Service:
 ///     ctx.service_client::<MyServiceClient>()
 ///         .my_handler(String::from("Hi!"))
@@ -368,13 +371,15 @@ impl<'ctx, CTX: private::SealedContext<'ctx>> ContextTimers<'ctx> for CTX {}
 /// To schedule a delayed call, send a message with a delay parameter, as follows:
 ///
 /// ```
-/// /// # use crate::_examples::my_service::MyServiceClient;
-/// # use crate::_examples::my_virtual_object::MyVirtualObjectClient;
-/// # use crate::_examples::my_workflow::MyWorkflowClient;
+/// # #[path = "../examples/services"]
+/// # mod services;
+/// # use services::my_service::MyServiceClient;
+/// # use services::my_virtual_object::MyVirtualObjectClient;
+/// # use services::my_workflow::MyWorkflowClient;
 /// # use restate_sdk::prelude::*;
 /// # use std::time::Duration;
 /// #
-/// # async fn greet2(ctx: Context<'_>, greeting: String) -> Result<(), HandlerError> {
+/// # async fn greet(ctx: Context<'_>, greeting: String) -> Result<(), HandlerError> {
 ///     // To a Service:
 ///     ctx.service_client::<MyServiceClient>()
 ///         .my_handler(String::from("Hi!"))
@@ -406,9 +411,11 @@ impl<'ctx, CTX: private::SealedContext<'ctx>> ContextTimers<'ctx> for CTX {}
 /// For example, assume a handler calls the same Virtual Object twice:
 ///
 /// ```
-/// # use crate::_examples::my_virtual_object::MyVirtualObjectClient;
+/// # #[path = "../examples/services"]
+/// # mod services;
+/// # use services::my_virtual_object::MyVirtualObjectClient;
 /// # use restate_sdk::prelude::*;
-/// # async fn greet4(ctx: Context<'_>, greeting: String) -> Result<(), HandlerError> {
+/// # async fn greet(ctx: Context<'_>, greeting: String) -> Result<(), HandlerError> {
 ///     ctx.object_client::<MyVirtualObjectClient>("Mary")
 ///         .my_handler(String::from("I'm call A!"))
 ///         .send();