Enum SubnetCommand

pub enum SubnetCommand {
    AllocateTask {
        task_type: String,
        transactions: Vec<WorkUnit>,
        tx: Sender<Result<(), NetworkError>>,
    },
    Connect {
        address: Multiaddr,
        tx: Sender<Result<NodeId, NetworkError>>,
    },
    DistributeSurfacePatterns {
        tx: Sender<Result<(), NetworkError>>,
    },
    DynamicWorkDistribution {
        operations: Vec<(EdgeId, Vec<LPR>)>,
        tx: Sender<Result<(), NetworkError>>,
    },
    FormProcessingCluster {
        task_type: String,
        tx: Sender<Result<Vec<PeerId>, NetworkError>>,
    },
    LearnNetworkPatterns {
        tx: Sender<Result<(), NetworkError>>,
    },
    PatternShare {
        node_id: NodeId,
        pattern_id: String,
        chord_class: Triads,
        input: [f32; 3],
        output: f32,
        tx: Sender<Result<(), NetworkError>>,
    },
    PatternBatchShare {
        node_id: NodeId,
        chord_class: Triads,
        patterns: Vec<([f32; 3], f32)>,
        tx: Sender<Result<(), NetworkError>>,
    },
    Publish {
        topic: String,
        data: Vec<u8>,
        tx: Sender<Result<(), NetworkError>>,
    },
    RequestPatternSharing {
        tx: Sender<Result<(), NetworkError>>,
    },
    RequestResourceStatus {
        tx: Sender<Result<(), NetworkError>>,
    },
    Shutdown {
        tx: Sender<Result<(), NetworkError>>,
    },
    SynchronizeMemory {
        tx: Sender<Result<(), NetworkError>>,
    },
    TopologyAwareLearning {
        tx: Sender<Result<(), NetworkError>>,
    },
}

Commands to control the network

Variants

AllocateTask

Allocate task to peers

Fields

task_type: String

transactions: Vec<WorkUnit>

tx: Sender<Result<(), NetworkError>>

Connect

Connect to a peer

Fields

address: Multiaddr

tx: Sender<Result<NodeId, NetworkError>>

DistributeSurfacePatterns

Distribute surface patterns

Fields

tx: Sender<Result<(), NetworkError>>

DynamicWorkDistribution

Create dynamic work distribution

Fields

operations: Vec<(EdgeId, Vec<LPR>)>

tx: Sender<Result<(), NetworkError>>

FormProcessingCluster

Form processing cluster

Fields

task_type: String

tx: Sender<Result<Vec<PeerId>, NetworkError>>

LearnNetworkPatterns

Learn patterns from the network

Fields

tx: Sender<Result<(), NetworkError>>

PatternShare

Pattern sharing between nodes

Fields

node_id: NodeId

pattern_id: String

chord_class: Triads

input: [f32; 3]

output: f32

tx: Sender<Result<(), NetworkError>>

PatternBatchShare

Share a batch of patterns for a specific chord class

Fields

node_id: NodeId

chord_class: Triads

patterns: Vec<([f32; 3], f32)>

tx: Sender<Result<(), NetworkError>>

Publish

Publish data to a topic

Fields

topic: String

data: Vec<u8>

tx: Sender<Result<(), NetworkError>>

RequestPatternSharing

Request patterns from all nodes

Fields

tx: Sender<Result<(), NetworkError>>

RequestResourceStatus

Request resource status from peers

Fields

tx: Sender<Result<(), NetworkError>>

Shutdown

Fields

tx: Sender<Result<(), NetworkError>>

SynchronizeMemory

Synchronize memory

Fields

tx: Sender<Result<(), NetworkError>>

TopologyAwareLearning

Create topology-aware learning

Fields

tx: Sender<Result<(), NetworkError>>

Implementations

impl SubnetCommand

pub const fn is_allocate_task(&self) -> bool

Returns true if the enum is SubnetCommand::AllocateTask otherwise false

pub const fn is_connect(&self) -> bool

Returns true if the enum is SubnetCommand::Connect otherwise false

pub const fn is_distribute_surface_patterns(&self) -> bool

Returns true if the enum is SubnetCommand::DistributeSurfacePatterns otherwise false

pub const fn is_dynamic_work_distribution(&self) -> bool

Returns true if the enum is SubnetCommand::DynamicWorkDistribution otherwise false

pub const fn is_form_processing_cluster(&self) -> bool

Returns true if the enum is SubnetCommand::FormProcessingCluster otherwise false

pub const fn is_learn_network_patterns(&self) -> bool

Returns true if the enum is SubnetCommand::LearnNetworkPatterns otherwise false

pub const fn is_pattern_share(&self) -> bool

Returns true if the enum is SubnetCommand::PatternShare otherwise false

pub const fn is_pattern_batch_share(&self) -> bool

Returns true if the enum is SubnetCommand::PatternBatchShare otherwise false

pub const fn is_publish(&self) -> bool

Returns true if the enum is SubnetCommand::Publish otherwise false

pub const fn is_request_pattern_sharing(&self) -> bool

Returns true if the enum is SubnetCommand::RequestPatternSharing otherwise false

pub const fn is_request_resource_status(&self) -> bool

Returns true if the enum is SubnetCommand::RequestResourceStatus otherwise false

pub const fn is_shutdown(&self) -> bool

Returns true if the enum is SubnetCommand::Shutdown otherwise false

pub const fn is_synchronize_memory(&self) -> bool

Returns true if the enum is SubnetCommand::SynchronizeMemory otherwise false

pub const fn is_topology_aware_learning(&self) -> bool

Returns true if the enum is SubnetCommand::TopologyAwareLearning otherwise false

Trait Implementations

impl Debug for SubnetCommand

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

Formats the value using the given formatter.