[−][src]Struct fluvio_cluster::ClusterInstaller
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
To install Fluvio using all the default settings, use
ClusterInstaller::new()
let installer = ClusterInstaller::new() .build() .expect("should initialize installer"); // Installing Fluvio is asynchronous, so you'll need an async runtime let result = fluvio_future::task::run_block_on(async { installer.install_fluvio().await });
Implementations
impl ClusterInstaller
[src]
pub fn new() -> ClusterInstallerBuilder
[src]
Creates a default ClusterInstallerBuilder
which can build a ClusterInstaller
Example
The easiest way to build a ClusterInstaller
is as follows:
use fluvio_cluster::ClusterInstaller; let installer = ClusterInstaller::new().build().unwrap();
Building a ClusterInstaller
may fail if there is trouble connecting to
Kubernetes or if the helm
executable is not locally installed.
You may also set custom installation options before calling .build()
.
For example, if you wanted to specify a custom namespace and RUST_LOG,
you could use with_namespace
and with_rust_log
. See
ClusterInstallerBuilder
for the full set of options.
use fluvio_cluster::ClusterInstaller; let installer = ClusterInstaller::new() .with_namespace("my_namespace") .with_rust_log("debug") .build() .expect("should build ClusterInstaller");
pub fn versions() -> Result<Vec<Chart>, ClusterError>
[src]
Get all the available versions of fluvio chart
pub fn sys_charts() -> Result<Vec<InstalledChart>, K8InstallError>
[src]
Get installed system 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
Auto Trait Implementations
impl !RefUnwindSafe for ClusterInstaller
[src]
impl Send for ClusterInstaller
[src]
impl Sync for ClusterInstaller
[src]
impl Unpin for ClusterInstaller
[src]
impl !UnwindSafe for ClusterInstaller
[src]
Blanket Implementations
impl<T> Any for T where
T: 'static + ?Sized,
[src]
T: 'static + ?Sized,
impl<T> Borrow<T> for T where
T: ?Sized,
[src]
T: ?Sized,
impl<T> BorrowMut<T> for T where
T: ?Sized,
[src]
T: ?Sized,
pub fn borrow_mut(&mut self) -> &mut T
[src]
impl<T> Erased for T
impl<T> From<T> for T
[src]
impl<T> Instrument for T
[src]
pub fn instrument(self, span: Span) -> Instrumented<Self>
[src]
pub fn in_current_span(self) -> Instrumented<Self>
[src]
impl<T> Instrument for T
[src]
pub fn instrument(self, span: Span) -> Instrumented<Self>
[src]
pub fn in_current_span(self) -> Instrumented<Self>
[src]
impl<T, U> Into<U> for T where
U: From<T>,
[src]
U: From<T>,
impl<T, U> TryFrom<U> for T where
U: Into<T>,
[src]
U: Into<T>,
type Error = Infallible
The type returned in the event of a conversion error.
pub fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>
[src]
impl<T, U> TryInto<U> for T where
U: TryFrom<T>,
[src]
U: TryFrom<T>,
type Error = <U as TryFrom<T>>::Error
The type returned in the event of a conversion error.
pub fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>
[src]
impl<V, T> VZip<V> for T where
V: MultiLane<T>,
V: MultiLane<T>,
pub fn vzip(self) -> V
impl<T> WithSubscriber for T
[src]
pub fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self> where
S: Into<Dispatch>,
[src]
S: Into<Dispatch>,