arcon 0.2.1

A runtime for writing streaming applications
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15

/// Available Channel Strategies
pub mod strategy;

use crate::data::{flight_serde::FlightSerde, ArconMessage, ArconType};
use kompact::prelude::{ActorPath, ActorRefStrong};

/// A Channel represents a connection to another Component
#[derive(Clone)]
pub enum Channel<A: ArconType> {
    /// A typed local queue
    Local(ActorRefStrong<ArconMessage<A>>),
    /// Remote based queue containing a remote ActorPath identifier and an Arcon Serialiser
    #[allow(dead_code)]
    Remote(ActorPath, FlightSerde),
}