pub struct Builder<S = NoServer> { /* private fields */ }
runtime
only.Expand description
Configures a controller Runtime
Implementations
sourceimpl<S> Builder<S>
impl<S> Builder<S>
sourcepub fn with_admin(self, admin: AdminArgs) -> Self
pub fn with_admin(self, admin: AdminArgs) -> Self
Configures the runtime to use the given AdminArgs
sourcepub fn with_client(self, client: ClientArgs) -> Self
pub fn with_client(self, client: ClientArgs) -> Self
Configures the runtime to use the given ClientArgs
sourcepub fn with_log(self, filter: LogFilter, format: LogFormat) -> Self
pub fn with_log(self, filter: LogFilter, format: LogFormat) -> Self
Configures the runtime to use the given logging configuration
sourcepub fn with_fixed_delay_on_error(self, delay: Duration) -> Self
pub fn with_fixed_delay_on_error(self, delay: Duration) -> Self
Configures the runtime to use the given fixed delay when a stream fails
sourceimpl Builder<NoServer>
impl Builder<NoServer>
sourcepub fn with_server(self, server: ServerArgs) -> Builder<ServerArgs>
This is supported on features="runtime"
and crate feature server
only.
pub fn with_server(self, server: ServerArgs) -> Builder<ServerArgs>
features="runtime"
and crate feature server
only.Configures the runtime to start a server with the given ServerArgs
sourcepub fn with_optional_server(
self,
server: Option<ServerArgs>
) -> Builder<Option<ServerArgs>>
This is supported on features="runtime"
and crate feature server
only.
pub fn with_optional_server(
self,
server: Option<ServerArgs>
) -> Builder<Option<ServerArgs>>
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.
sourceimpl Builder<ServerArgs>
impl Builder<ServerArgs>
sourceimpl Builder<Option<ServerArgs>>
impl Builder<Option<ServerArgs>>
Trait Implementations
Auto Trait Implementations
impl<S> RefUnwindSafe for Builder<S> where
S: RefUnwindSafe,
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> UnwindSafe for Builder<S> where
S: UnwindSafe,
Blanket Implementations
sourceimpl<T> BorrowMut<T> for T where
T: ?Sized,
impl<T> BorrowMut<T> for T where
T: ?Sized,
const: unstable · sourcefn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more
sourceimpl<T> Instrument for T
impl<T> Instrument for T
sourcefn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
sourcefn in_current_span(self) -> Instrumented<Self>
fn in_current_span(self) -> Instrumented<Self>
impl<V, T> VZip<V> for T where
V: MultiLane<T>,
impl<V, T> VZip<V> for T where
V: MultiLane<T>,
fn vzip(self) -> V
sourceimpl<T> WithSubscriber for T
impl<T> WithSubscriber for T
sourcefn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self> where
S: Into<Dispatch>,
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
sourcefn with_current_subscriber(self) -> WithDispatch<Self>
fn with_current_subscriber(self) -> WithDispatch<Self>
Attaches the current default Subscriber
to this type, returning a
WithDispatch
wrapper. Read more