Struct FlinkContainer 

pub struct FlinkContainer { /* private fields */ }

An Apache Flink JobManager, with an optional companion TaskManager (see FlinkContainer::with_task_manager).

Implementations

impl FlinkContainer

pub fn new() -> Self

Builds a container from the pinned default image (flink:1.20.5).

pub fn with_image(image: &str) -> Self

Builds a container from a caller-chosen image.

pub fn with_task_manager(self) -> Result<Self>

Adds a companion TaskManager, giving the cluster real task slots. Docker only — returns RightsizeError::UnsupportedByBackend on microsandbox (see the module doc’s backend-support section); the remedy is to run this test under the docker backend instead. Must be called before FlinkContainer::start.

pub async fn start(self) -> Result<FlinkGuard>

Boots the JobManager, then (if FlinkContainer::with_task_manager was called) the companion TaskManager.

Trait Implementations

impl Default for FlinkContainer

fn default() -> Self

Returns the “default value” for a type.