Struct KubernetesDiscoveryConfig 

pub struct KubernetesDiscoveryConfig {
    pub namespace: String,
    pub port_name: Option<String>,
    pub scheme: String,
    pub startup_timeout: Duration,
    pub reconnect_backoff: DiscoveryReconnectBackoff,
}

Namespace, port, and URI settings for Kubernetes EndpointSlice discovery.

Fields

namespace: String

port_name: Option<String>

scheme: String

startup_timeout: Duration

reconnect_backoff: DiscoveryReconnectBackoff

Implementations

impl KubernetesDiscoveryConfig

pub fn new(namespace: impl Into<String>) -> Self

Examples found in repository

examples/kubernetes_discovery.rs (line 10)

async fn main() -> Result<(), Box<dyn std::error::Error>> {
    let namespace = env::var("KUBERNETES_NAMESPACE").unwrap_or_else(|_| "default".to_owned());
    let service = env::var("KUBERNETES_SERVICE").unwrap_or_else(|_| "users".to_owned());
    let port = env::var("KUBERNETES_PORT_NAME").unwrap_or_else(|_| "grpc".to_owned());
    let discovery =
        KubernetesDiscovery::infer(KubernetesDiscoveryConfig::new(namespace).with_port_name(port))
            .await?;
    let mut subscription = discovery.subscribe(service).await?;

    println!("ready endpoints: {:?}", subscription.endpoints());
    loop {
        println!("updated endpoints: {:?}", subscription.changed().await?);
    }
}

pub fn with_port_name(self, port_name: impl Into<String>) -> Self

Examples found in repository

examples/kubernetes_discovery.rs (line 10)

async fn main() -> Result<(), Box<dyn std::error::Error>> {
    let namespace = env::var("KUBERNETES_NAMESPACE").unwrap_or_else(|_| "default".to_owned());
    let service = env::var("KUBERNETES_SERVICE").unwrap_or_else(|_| "users".to_owned());
    let port = env::var("KUBERNETES_PORT_NAME").unwrap_or_else(|_| "grpc".to_owned());
    let discovery =
        KubernetesDiscovery::infer(KubernetesDiscoveryConfig::new(namespace).with_port_name(port))
            .await?;
    let mut subscription = discovery.subscribe(service).await?;

    println!("ready endpoints: {:?}", subscription.endpoints());
    loop {
        println!("updated endpoints: {:?}", subscription.changed().await?);
    }
}

pub fn with_scheme(self, scheme: impl Into<String>) -> Self

pub fn with_startup_timeout(self, timeout: Duration) -> Self

pub fn with_reconnect_backoff(self, backoff: DiscoveryReconnectBackoff) -> Self

Trait Implementations

impl Clone for KubernetesDiscoveryConfig

fn clone(&self) -> KubernetesDiscoveryConfig

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for KubernetesDiscoveryConfig

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

Formats the value using the given formatter.

impl Eq for KubernetesDiscoveryConfig

impl PartialEq for KubernetesDiscoveryConfig

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

Equality operator ==.

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

Inequality operator !=.

impl StructuralPartialEq for KubernetesDiscoveryConfig