Struct fluvio_cluster::ClusterInstaller[][src]

pub struct ClusterInstaller { /* fields omitted */ }

Allows installing Fluvio on a Kubernetes cluster

Fluvio's Kubernetes components are distributed as Helm Charts, which allow them to be easily installed on any Kubernetes cluster. A ClusterInstaller takes care of installing all of the pieces in the right order, with sane defaults.

If you want to try out Fluvio on Kubernetes, you can use Minikube as an installation target. This is the default target that the ClusterInstaller uses, so it doesn't require any complex setup.

Example

let config = ClusterConfig::builder("0.7.0-alpha.1").build()?;
let installer = ClusterInstaller::from_config(config)?;
let _status = installer.install_fluvio().await?;

Implementations

impl ClusterInstaller[src]

pub fn from_config(config: ClusterConfig) -> Result<Self, ClusterError>[src]

Creates a ClusterInstaller from a ClusterConfig

Example

let installer = ClusterInstaller::from_config(config)?;

pub fn versions() -> Result<Vec<Chart>, ClusterError>[src]

Get all the available versions of fluvio chart

pub async fn setup(&self) -> CheckResults[src]

Checks if all of the prerequisites for installing Fluvio are met

This will attempt to automatically fix any missing prerequisites, depending on the installer configuration. See the following options for more details:

pub async fn install_fluvio(&self) -> Result<StartStatus, ClusterError>[src]

Installs Fluvio according to the installer's configuration

Returns the external address of the new cluster's SC

Trait Implementations

impl Debug for ClusterInstaller[src]

Auto Trait Implementations

Blanket Implementations

impl<T> Any for T where
    T: 'static + ?Sized
[src]

impl<T> Borrow<T> for T where
    T: ?Sized
[src]

impl<T> BorrowMut<T> for T where
    T: ?Sized
[src]

impl<T> Erased for T

impl<T> From<T> for T[src]

impl<T> Instrument for T[src]

impl<T> Instrument for T[src]

impl<T, U> Into<U> for T where
    U: From<T>, 
[src]

impl<T, U> TryFrom<U> for T where
    U: Into<T>, 
[src]

type Error = Infallible

The type returned in the event of a conversion error.

impl<T, U> TryInto<U> for T where
    U: TryFrom<T>, 
[src]

type Error = <U as TryFrom<T>>::Error

The type returned in the event of a conversion error.

impl<V, T> VZip<V> for T where
    V: MultiLane<T>, 

impl<T> WithSubscriber for T[src]