Struct turbolift::kubernetes::K8s

pub struct K8s { /* fields omitted */ }

K8s is the interface for turning rust functions into autoscaling microservices using turbolift. It requires docker and kubernetes / kubectl to already be setup on the device at runtime.

Access to the kubernetes cluster must be inferrable from the env variables at runtime per kube-rs’s try_default().

Implementations

impl K8s

pub fn new(
    deploy_container: Box<dyn Fn(String) + Send + 'static, Global>,
    max: u32
) -> K8s

returns a K8s object. If max is equal to 1, then autoscaling is not enabled. Otherwise, autoscale is automatically activated with cluster defaults and a max number of replicas per distributed function of max. Panics if max < 1.

The deploy container function is used for making containers accessible to the cluster. See K8s::deploy_container.

Trait Implementations

impl Debug for K8s

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

Formats the value using the given formatter.

impl DistributionPlatform for K8s

pub fn declare<'life0, 'life1, 'life2, 'async_trait>(
    &'life0 mut self,
    function_name: &'life1 str,
    project_tar: &'life2 [u8]
) -> Pin<Box<dyn Future<Output = Result<(), Box<dyn Error + 'static, Global>>> + Send + 'async_trait, Global>> where
    'life0: 'async_trait,
    'life1: 'async_trait,
    'life2: 'async_trait,
    K8s: 'async_trait, 

declare a function

pub fn dispatch<'life0, 'life1, 'async_trait>(
    &'life0 mut self,
    function_name: &'life1 str,
    params: String
) -> Pin<Box<dyn Future<Output = Result<String, Box<dyn Error + 'static, Global>>> + Send + 'async_trait, Global>> where
    'life0: 'async_trait,
    'life1: 'async_trait,
    K8s: 'async_trait, 

pub fn has_declared(&self, fn_name: &str) -> bool

impl Drop for K8s

pub fn drop(&mut self)

Executes the destructor for this type.