Struct PodApi 

pub struct PodApi {
    pub api: Api<Pod>,
    /* private fields */
}

Wrapper around the kube::Api type for the Vault pod

Fields

api: Api<Pod>

Implementations

impl PodApi

pub fn new(api: Api<Pod>, tls: bool, domain: String) -> Self

impl PodApi

pub async fn portforward( &self, pod: &str, port: u16, ) -> Result<impl AsyncRead + AsyncWrite + Unpin>

Get a stream to a port on a pod The stream can be used to send HTTP requests

pub async fn http( &self, pod: &str, port: u16, ) -> Result<HttpForwarderService<BytesBody>>

impl PodApi

pub fn is_current(pod: &Pod, target: &VaultVersion) -> Result<bool>

Check if the vault pod has the specified version

pub async fn upgrade( &self, pod: Pod, target: &VaultVersion, token: Secret<String>, should_unseal: bool, force_upgrade: bool, keys: &[Secret<String>], ) -> Result<()>

Upgrade a vault pod

• a.1. if Pod version is outdated
  • a.1.1. Delete pod
  • a.1.2. Wait for pod to be deleted
  • a.1.3. Wait for pod to be running
• a.2. if Pod version is current
  • a.2.1. Pod is sealed
    • a.2.1.1 Unseal pod
  • a.2.2. Wait for pod to be unsealed
  • a.2.3. Wait for pod to be ready

Trait Implementations

impl Clone for PodApi

fn clone(&self) -> PodApi

Returns a duplicate of the value.

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

Performs copy-assignment from source.