mssf-util 0.7.0

mssf utilites and extensions for tokio and more
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
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56

// ------------------------------------------------------------
// Copyright (c) Microsoft Corporation.  All rights reserved.
// Licensed under the MIT License (MIT). See License.txt in the repo root for license information.
// ------------------------------------------------------------

use std::sync::Arc;

use mssf_core::{runtime::IStatelessServicePartition, types::ServicePartitionInformation};

/// Mock for IStatelessServicePartition
/// Currently does not react to any reports
pub struct StatelessServicePartitionMock {
    info: ServicePartitionInformation,
}

impl StatelessServicePartitionMock {
    /// Create a new mock with given partition info
    pub fn new(info: ServicePartitionInformation) -> Self {
        Self { info }
    }
    pub fn new_arc(info: ServicePartitionInformation) -> Arc<dyn IStatelessServicePartition> {
        Arc::new(Self::new(info))
    }
}

impl IStatelessServicePartition for StatelessServicePartitionMock {
    fn get_partition_info(&self) -> mssf_core::Result<ServicePartitionInformation> {
        Ok(self.info.clone())
    }

    fn report_load(&self, _metrics: &[mssf_core::types::LoadMetric]) -> mssf_core::Result<()> {
        Ok(())
    }

    fn report_fault(&self, _fault_type: mssf_core::types::FaultType) -> mssf_core::Result<()> {
        Ok(())
    }

    fn report_move_cost(&self, _move_cost: mssf_core::types::MoveCost) -> mssf_core::Result<()> {
        Ok(())
    }

    fn report_partition_health(
        &self,
        _healthinfo: &mssf_core::types::HealthInformation,
    ) -> mssf_core::Result<()> {
        Ok(())
    }

    fn report_instance_health(
        &self,
        _health_info: &mssf_core::types::HealthInformation,
    ) -> mssf_core::Result<()> {
        Ok(())
    }
}