Struct K8s 

pub struct K8s {
    pub namespace: Arc<str>,
    /* private fields */
}

Fields

namespace: Arc<str>

Implementations

impl K8s

pub fn new(namespace: impl Into<Arc<str>>, client: Client) -> K8s

pub async fn with_default_client( namespace: impl Into<Arc<str>>, ) -> Result<K8s, Error>

pub fn get_all_api<T>(&self) -> Api<T>

where T: Resource, <T as Resource>::DynamicType: Default,

pub fn get_namespace_api<T>(&self) -> Api<T>

where T: Resource<Scope = NamespaceResourceScope>, <T as Resource>::DynamicType: Default,

pub fn get_specify_namespace_api<T>(&self, ns: &str) -> Api<T>

where T: Resource<Scope = NamespaceResourceScope>, <T as Resource>::DynamicType: Default,

Trait Implementations

impl Create for K8s

async fn create_config_item_gateway( &self, _gateway_name: &str, gateway: SgGateway, ) -> Result<(), Box<dyn Error + Send + Sync>>

async fn create_config_item_route( &self, gateway_name: &str, route_name: &str, route: SgHttpRoute, ) -> Result<(), Box<dyn Error + Send + Sync>>

async fn create_plugin( &self, id: &PluginInstanceId, value: Value, ) -> Result<(), Box<dyn Error + Send + Sync>>

fn create_config_item( &self, name: &str, item: ConfigItem, ) -> impl Future<Output = Result<(), Box<dyn Error + Send + Sync>>> + Send

fn create_config( &self, config: Config, ) -> impl Future<Output = Result<(), Box<dyn Error + Send + Sync>>> + Send

impl CreateListener for K8s

const CONFIG_LISTENER_NAME: &'static str = "k8s"

type Listener = K8sListener

async fn create_listener( &self, ) -> Result<(Config, <K8s as CreateListener>::Listener), Box<dyn Error + Send + Sync>>

impl Delete for K8s

async fn delete_config_item_gateway( &self, gateway_name: &str, ) -> Result<(), Box<dyn Error + Send + Sync>>

async fn delete_config_item_route( &self, gateway_name: &str, route_name: &str, ) -> Result<(), Box<dyn Error + Send + Sync>>

async fn delete_plugin( &self, id: &PluginInstanceId, ) -> Result<(), Box<dyn Error + Send + Sync>>

fn delete_config_item_all_routes( &self, gateway_name: &str, ) -> impl Future<Output = Result<(), Box<dyn Error + Send + Sync>>> + Send

where Self: Retrieve,

fn delete_config_item( &self, name: &str, ) -> impl Future<Output = Result<(), Box<dyn Error + Send + Sync>>> + Send

where Self: Retrieve,

impl Discovery for K8s

async fn instances( &self, ) -> Result<Vec<impl Instance>, Box<dyn Error + Send + Sync>>

async fn backends( &self, ) -> Result<Vec<BackendHost>, Box<dyn Error + Send + Sync>>

impl Retrieve for K8s

async fn retrieve_config_item_gateway( &self, gateway_name: &str, ) -> Result<Option<SgGateway>, Box<dyn Error + Send + Sync>>

async fn retrieve_config_item_route( &self, gateway_name: &str, route_name: &str, ) -> Result<Option<SgHttpRoute>, Box<dyn Error + Send + Sync>>

async fn retrieve_config_item_route_names( &self, name: &str, ) -> Result<Vec<String>, Box<dyn Error + Send + Sync>>

async fn retrieve_config_names( &self, ) -> Result<Vec<String>, Box<dyn Error + Send + Sync>>

async fn retrieve_all_plugins( &self, ) -> Result<Vec<PluginConfig>, Box<dyn Error + Send + Sync>>

async fn retrieve_plugin( &self, id: &PluginInstanceId, ) -> Result<Option<PluginConfig>, Box<dyn Error + Send + Sync>>

async fn retrieve_plugins_by_code( &self, code: &str, ) -> Result<Vec<PluginConfig>, Box<dyn Error + Send + Sync>>

fn retrieve_config_item_all_routes( &self, name: &str, ) -> impl Future<Output = Result<BTreeMap<String, SgHttpRoute>, Box<dyn Error + Send + Sync>>> + Send

fn retrieve_config_item( &self, name: &str, ) -> impl Future<Output = Result<Option<ConfigItem>, Box<dyn Error + Send + Sync>>> + Send

fn retrieve_config( &self, ) -> impl Future<Output = Result<Config, Box<dyn Error + Send + Sync>>> + Send

where Self: Sync, Box<dyn Error + Send + Sync>: Send,

impl Update for K8s

async fn update_config_item_gateway( &self, gateway_name: &str, gateway: SgGateway, ) -> Result<(), Box<dyn Error + Send + Sync>>

async fn update_config_item_route( &self, gateway_name: &str, route_name: &str, route: SgHttpRoute, ) -> Result<(), Box<dyn Error + Send + Sync>>

async fn update_plugin( &self, id: &PluginInstanceId, value: Value, ) -> Result<(), Box<dyn Error + Send + Sync>>

fn update_config_item( &self, name: &str, item: ConfigItem, ) -> impl Future<Output = Result<(), Box<dyn Error + Send + Sync>>> + Send

fn update_config( &self, config: Config, ) -> impl Future<Output = Result<(), Box<dyn Error + Send + Sync>>> + Send