logimesh 0.1.9

logimesh is a Rust RPC Microservice 2.0 framework.
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36

// Modifications Copyright Andeya Lee 2024
// Based on original source code from Volo Contributors licensed under MIT OR Apache-2.0
//
// Use of this source code is governed by an MIT-style
// license that can be found in the LICENSE file or at
// https://opensource.org/licenses/MIT.
//!
//! Dummy discover.

use super::{Discover, Discovery, InstanceCluster};
use crate::client::ClientError;
use crate::component::Endpoint;
use async_broadcast::Receiver;
use faststr::FastStr;
use std::future::Future;

/// [`DummyDiscover`] always returns an empty list.
///
/// Users that don't specify the address directly need to use their own [`Discover`].
#[derive(Clone)]
pub struct DummyDiscover;

impl Discover for DummyDiscover {
    fn discover<'s>(&'s self, endpoint: &'s Endpoint) -> impl Future<Output = Result<Discovery, ClientError>> + Send {
        async move {
            Ok(Discovery {
                key: endpoint.key(),
                instance_cluster: InstanceCluster::Rpc(vec![]),
            })
        }
    }

    fn watch(&self, _: Option<&[FastStr]>) -> Option<Receiver<Discovery>> {
        None
    }
}