Struct kubert::runtime::Builder

source · 
pub struct Builder<S = NoServer> { /* private fields */ }
Available on crate feature runtime only.
Expand description

Configures a controller Runtime

Implementations§

source§

impl<S> Builder<S>

source

pub fn with_admin(self, admin: impl Into<Builder>) -> Self

Configures the runtime to use the given Builder

source

pub fn with_client(self, client: ClientArgs) -> Self

Configures the runtime to use the given ClientArgs

source

pub fn with_log(self, filter: LogFilter, format: LogFormat) -> Self

Configures the runtime to use the given logging configuration

source

pub fn with_fixed_delay_on_error(self, delay: Duration) -> Self

Configures the runtime to use the given fixed delay when a stream fails

source

pub fn with_metrics(self, metrics: RuntimeMetrics) -> Self

Configures the runtime to record watch metrics with the given registry

source§

impl Builder<NoServer>

source

pub fn with_server(self, server: ServerArgs) -> Builder<ServerArgs>

Available on features="runtime" and crate feature server only.

Configures the runtime to start a server with the given ServerArgs

source

pub fn with_optional_server( self, server: Option<ServerArgs> ) -> Builder<Option<ServerArgs>>

Available on features="runtime" and crate feature server only.

Configures the runtime to optionally start a server with the given ServerArgs

This is useful for runtimes that usually run an admission controller, but may want to support running without it when running outside the cluster.

source§

impl Builder<NoServer>

source

pub async fn build(self) -> Result<Runtime<NoServer>, BuildError>

Attempts to build a runtime by initializing logs, loading the default Kubernetes client, registering signal handlers and binding an admin server

source§

impl Builder<ServerArgs>

source

pub async fn build(self) -> Result<Runtime<Bound>, BuildError>

Available on features="runtime" and crate feature server only.

Attempts to build a runtime by initializing logs, loading the default Kubernetes client, registering signal handlers and binding admin and HTTPS servers

source§

impl Builder<Option<ServerArgs>>

source

pub async fn build(self) -> Result<Runtime<Option<Bound>>, BuildError>

Available on features="runtime" and crate feature server only.

Attempts to build a runtime by initializing logs, loading the default Kubernetes client, registering signal handlers and binding admin and HTTPS servers

Trait Implementations§

source§

impl<S: Debug> Debug for Builder<S>

source§

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

Formats the value using the given formatter. Read more
source§

impl<S: Default> Default for Builder<S>

source§

fn default() -> Builder<S>

Returns the “default value” for a type. Read more

Auto Trait Implementations§

§

impl<S> Freeze for Builder<S>
where S: Freeze,

§

impl<S = NoServer> !RefUnwindSafe for Builder<S>

§

impl<S> Send for Builder<S>
where S: Send,

§

impl<S> Sync for Builder<S>
where S: Sync,

§

impl<S> Unpin for Builder<S>
where S: Unpin,

§

impl<S = NoServer> !UnwindSafe for Builder<S>

Blanket Implementations§

source§

impl<T> Any for T
where T: 'static + ?Sized,

source§

fn type_id(&self) -> TypeId

Gets the TypeId of self. Read more
source§

impl<T> Borrow<T> for T
where T: ?Sized,

source§

fn borrow(&self) -> &T

Immutably borrows from an owned value. Read more
source§

impl<T> BorrowMut<T> for T
where T: ?Sized,

source§

fn borrow_mut(&mut self) -> &mut T

Mutably borrows from an owned value. Read more
source§

impl<T> From<T> for T

source§

fn from(t: T) -> T

Returns the argument unchanged.

source§

impl<T> Instrument for T

source§

fn instrument(self, span: Span) -> Instrumented<Self>

Instruments this type with the provided Span, returning an Instrumented wrapper. Read more
source§

fn in_current_span(self) -> Instrumented<Self>

Instruments this type with the current Span, returning an Instrumented wrapper. Read more
source§

impl<T, U> Into<U> for T
where U: From<T>,

source§

fn into(self) -> U

Calls U::from(self).

That is, this conversion is whatever the implementation of From<T> for U chooses to do.

source§

impl<T> IntoEither for T

source§

fn into_either(self, into_left: bool) -> Either<Self, Self>

Converts self into a Left variant of Either<Self, Self> if into_left is true. Converts self into a Right variant of Either<Self, Self> otherwise. Read more
source§

fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
where F: FnOnce(&Self) -> bool,

Converts self into a Left variant of Either<Self, Self> if into_left(&self) returns true. Converts self into a Right variant of Either<Self, Self> otherwise. Read more
source§

impl<T, U> TryFrom<U> for T
where U: Into<T>,

§

type Error = Infallible

The type returned in the event of a conversion error.
source§

fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>

Performs the conversion.
source§

impl<T, U> TryInto<U> for T
where U: TryFrom<T>,

§

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

The type returned in the event of a conversion error.
source§

fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>

Performs the conversion.
source§

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

source§

fn vzip(self) -> V

source§

impl<T> WithSubscriber for T

source§

fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self>
where S: Into<Dispatch>,

Attaches the provided Subscriber to this type, returning a WithDispatch wrapper. Read more
source§

fn with_current_subscriber(self) -> WithDispatch<Self>

Attaches the current default Subscriber to this type, returning a WithDispatch wrapper. Read more