statefun 0.1.1

A Rust SDK for the Apache Flink Stateful Functions (StateFun) project. See: https://flink.apache.org/stateful-functions.html
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13

//! Transports are used to serve stateful functions to make them invokable.

use crate::function_registry::FunctionRegistry;

pub mod hyper;

/// Serves up stateful functions in a [FunctionRegistry](crate::FunctionRegistry) to make them
/// invokable in a Statefun deployment.
pub trait Transport {
    /// Serves the stateful functions in the given `FunctionRegistry`. This will usually be a
    /// blocking method and should be the last method you call in your program.
    fn run(self, function_registry: FunctionRegistry) -> Result<(), failure::Error>;
}