Enum DaemonInterfaceInternalRequest 

pub enum DaemonInterfaceInternalRequest {
    Prepare {
        instance_id: Uuid,
    },
    Clean {
        instance_id: Uuid,
    },
    Start {
        instance_id: Uuid,
    },
    StartSources {
        instance_id: Uuid,
    },
    Stop {
        instance_id: Uuid,
    },
    StopSources {
        instance_id: Uuid,
    },
    NotifyRuntime {
        instance_id: Uuid,
        runtime: String,
        message: ControlMessage,
    },
    CheckOperatorCompatibility {
        operator: OperatorDescriptor,
    },
    CheckSourceCompatibility {
        source: SourceDescriptor,
    },
    CheckSinkCompatibility {
        sink: SinkDescriptor,
    },
}

The request sent over the wire from the client to the server.

Variants

Prepare

Fields

instance_id: Uuid

Clean

Fields

instance_id: Uuid

Start

Fields

instance_id: Uuid

StartSources

Fields

instance_id: Uuid

Stop

Fields

instance_id: Uuid

StopSources

Fields

instance_id: Uuid

NotifyRuntime

Fields

instance_id: Uuid

runtime: String

message: ControlMessage

CheckOperatorCompatibility

Fields

operator: OperatorDescriptor

CheckSourceCompatibility

Fields

source: SourceDescriptor

CheckSinkCompatibility

Fields

sink: SinkDescriptor

Trait Implementations

impl Clone for DaemonInterfaceInternalRequest

fn clone(&self) -> DaemonInterfaceInternalRequest

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for DaemonInterfaceInternalRequest

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for DaemonInterfaceInternalRequest

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for DaemonInterfaceInternalRequest

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.

impl<S> ZServe<DaemonInterfaceInternalRequest> for ServeDaemonInterfaceInternal<S>

where S: DaemonInterfaceInternal + Send + 'static,

type Resp = DaemonInterfaceInternalResponse

Type of the response

fn instance_uuid(&self) -> ZenohId

fn connect( &self, ) -> Pin<Box<dyn Future<Output = ZRPCResult<(AbortHandle, JoinHandle<Result<ZRPCResult<()>, Aborted>>)>> + '_>>

Connects to Zenoh, do nothing in this case, state is HALTED

fn initialize(&self) -> Pin<Box<dyn Future<Output = ZRPCResult<()>> + '_>>

Authenticates to Zenoh, state changes to INITIALIZING

fn register(&self) -> Pin<Box<dyn Future<Output = ZRPCResult<()>> + '_>>

fn start( &self, ) -> Pin<Box<dyn Future<Output = ZRPCResult<(AbortHandle, JoinHandle<Result<ZRPCResult<()>, Aborted>>)>> + '_>>

State changes to SERVING, calls serve on a task::spawn, returns a stop sender and the serve task handle

fn run(&self) -> Pin<Box<dyn Future<Output = ZRPCResult<()>> + '_>>

The actual run loop serving the queriable

fn serve( &self, barrier: Arc<Barrier>, ) -> Pin<Box<dyn Future<Output = ZRPCResult<()>> + '_>>

Starts serving all requests

fn stop( &self, stop: AbortHandle, ) -> Pin<Box<dyn Future<Output = ZRPCResult<()>> + '_>>

State changes to REGISTERED, will stop serve/work

fn unregister(&self) -> Pin<Box<dyn Future<Output = ZRPCResult<()>> + '_>>

fn disconnect( &self, stop: AbortHandle, ) -> Pin<Box<dyn Future<Output = ZRPCResult<()>> + '_>>

removes state from Zenoh