Struct kube_runtime::watcher::Config

pub struct Config {
    pub label_selector: Option<String>,
    pub field_selector: Option<String>,
    pub timeout: Option<u32>,
    pub list_semantic: ListSemantic,
    pub page_size: Option<u32>,
    pub bookmarks: bool,
}

Accumulates all options that can be used on the watcher invocation.

Fields

label_selector: Option<String>

A selector to restrict the list of returned objects by their labels.

Defaults to everything if None.

field_selector: Option<String>

A selector to restrict the list of returned objects by their fields.

Defaults to everything if None.

timeout: Option<u32>

Timeout for the list/watch call.

This limits the duration of the call, regardless of any activity or inactivity. If unset for a watch call, we will use 290s. We limit this to 295s due to inherent watch limitations.

list_semantic: ListSemantic

Semantics for list calls.

Configures re-list for performance vs. consistency.

page_size: Option<u32>

Maximum number of objects retrieved per list operation resyncs.

This can reduce the memory consumption during resyncs, at the cost of requiring more API roundtrips to complete.

Defaults to 500. Note that None represents unbounded.

bookmarks: bool

Enables watch events with type “BOOKMARK”.

Requests watch bookmarks from the apiserver when enabled for improved watch precision and reduced list calls. This is default enabled and should generally not be turned off.

Implementations

impl Config

Builder interface to Config

Usage:

use kube::runtime::watcher::Config;
let wc = Config::default()
    .timeout(60)
    .labels("kubernetes.io/lifecycle=spot");

pub fn timeout(self, timeout_secs: u32) -> Self

Configure the timeout for list/watch calls

This limits the duration of the call, regardless of any activity or inactivity. Defaults to 290s

pub fn fields(self, field_selector: &str) -> Self

Configure the selector to restrict the list of returned objects by their fields.

Defaults to everything. Supports =, ==, !=, and can be comma separated: key1=value1,key2=value2. The server only supports a limited number of field queries per type.

pub fn labels(self, label_selector: &str) -> Self

Configure the selector to restrict the list of returned objects by their labels.

Defaults to everything. Supports =, ==, !=, and can be comma separated: key1=value1,key2=value2.

pub fn list_semantic(self, semantic: ListSemantic) -> Self

Sets list semantic to configure re-list performance and consistency

pub fn any_semantic(self) -> Self

Sets list semantic to Any to improve list performance

pub fn disable_bookmarks(self) -> Self

Disables watch bookmarks to simplify watch handling

This is not recommended to use with production watchers as it can cause desyncs. See #219 for details.

pub fn page_size(self, page_size: u32) -> Self

Limits the number of objects retrieved in each list operation during resync.

This can reduce the memory consumption during resyncs, at the cost of requiring more API roundtrips to complete.

Trait Implementations

impl Clone for Config

fn clone(&self) -> Config

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for Config

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

Formats the value using the given formatter.

impl Default for Config

fn default() -> Self

Returns the “default value” for a type.

impl PartialEq<Config> for Config

fn eq(&self, other: &Config) -> bool

This method tests for self and other values to be equal, and is used by ==.

fn ne(&self, other: &Rhs) -> bool

This method tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl StructuralPartialEq for Config