Struct declarative_dataflow::server::Server

pub struct Server<T, Token> where
    T: Timestamp + Lattice,
    Token: Hash + Eq + Copy,  {
    pub config: Configuration,
    pub t0: Instant,
    pub context: Context<T>,
    pub interests: HashMap<String, HashSet<Token>>,
    pub probe: ProbeHandle<T>,
    pub scheduler: Rc<RefCell<Scheduler>>,
    // some fields omitted
}

Server context maintaining globally registered arrangements and input handles.

Fields

config: Configuration

Server configuration.

t0: Instant

A timer started at the initation of the timely computation (copied from worker).

context: Context<T>

Implementation context.

interests: HashMap<String, HashSet<Token>>

Mapping from query names to interested client tokens.

probe: ProbeHandle<T>

Probe keeping track of overall dataflow progress.

scheduler: Rc<RefCell<Scheduler>>

Scheduler managing deferred operator activations.

Methods

impl<T, Token> Server<T, Token> where
    T: Timestamp + Lattice + Default + Rewind,
    Token: Hash + Eq + Copy, 

pub fn new(config: Configuration) -> Self

Creates a new server state from a configuration.

pub fn new_at(config: Configuration, t0: Instant) -> Self

Creates a new server state from a configuration with an additionally specified beginning of the computation: an instant in relation to which all durations will be measured.

pub fn builtins() -> Vec<Request>

Returns commands to install built-in plans.

pub fn transact(
    &mut self,
    tx_data: Vec<TxData>,
    owner: usize,
    worker_index: usize
) -> Result<(), Error>

Handle a Transact request.

pub fn interest<S: Scope<Timestamp = T>>(
    &mut self,
    name: &str,
    scope: &mut S
) -> Result<Collection<S, Vec<Value>, isize>, Error>

Handles an Interest request.

pub fn register(&mut self, req: Register) -> Result<(), Error>

Handle a Register request.

pub fn register_source<S: Scope<Timestamp = T>>(
    &mut self,
    source: Box<dyn Sourceable<S>>,
    scope: &mut S
) -> Result<(), Error>

Handle a RegisterSource request.

pub fn advance_domain(
    &mut self,
    name: Option<String>,
    next: T
) -> Result<(), Error>

Handle an AdvanceDomain request.

pub fn uninterest(&mut self, client: Token, name: &str) -> Result<(), Error>

Handles an Uninterest request, possibly cleaning up dataflows that are no longer interesting to any client.

pub fn disconnect_client(&mut self, client: Token) -> Result<(), Error>

Cleans up all bookkeeping state for the specified client.

pub fn is_any_outdated(&self) -> bool

Returns true iff the probe is behind any input handle. Mostly used as a convenience method during testing. Using this within step_while is not safe in general and might lead to stalls.

pub fn test_single<S: Scope<Timestamp = T>>(
    &mut self,
    scope: &mut S,
    rule: Rule
) -> Collection<S, Vec<Value>, isize>

Helper for registering, publishing, and indicating interest in a single, named query. Used for testing.

impl<Token> Server<Duration, Token> where
    Token: Hash + Eq + Copy, 

pub fn enable_logging<A: Allocate>(
    &self,
    worker: &mut Worker<A>
) -> Result<(), Error>

Registers loggers for use in the various logging sources.

pub fn shutdown_logging<A: Allocate>(
    &self,
    worker: &mut Worker<A>
) -> Result<(), Error>

Unregisters loggers.