class

Kubernetes::Client

Inherits Reference / Object

Constructors

new(server : URI, token_file : Path, certificate_file : String = "/var/run/secrets/kubernetes.io/serviceaccount/ca.crt", client_cert_file : String | Nil = nil, private_key_file : String | Nil = nil, log = Log.for("kubernetes.client"))
Source
new(server : URI, token : Proc(String) = -> do (File.read("/var/run/secrets/kubernetes.io/serviceaccount/token")).strip end, certificate_file : String = "/var/run/secrets/kubernetes.io/serviceaccount/ca.crt", client_cert_file : String | Nil = nil, private_key_file : String | Nil = nil, log = Log.for("kubernetes.client"))
Source
new(*, server : URI = URI.parse("https://#{ENV["KUBERNETES_SERVICE_HOST"]}:#{ENV["KUBERNETES_SERVICE_PORT"]}"), token : Proc(String) = -> do (File.read("/var/run/secrets/kubernetes.io/serviceaccount/token")).strip end, tls : OpenSSL::SSL::Context::Client | Nil, log : Log = Log.for("kubernetes.client"))
Source

Class methods

from_config(config : Config, *, context context_name : String = config.current_context)
Source
from_config(*, file : String = "#{ENV["HOME"]?}/.kube/config", context context_name : String | Nil = nil)
Source

Instance methods

api_resources(group : String)
Source
apis
Source
apply_cronjob(resource : Resource(CronJob), spec, name : String = resource.metadata.name, namespace : String | Nil = resource.metadata.namespace, force : Bool = false, field_manager : String | Nil = nil)
Source
apply_cronjob(metadata : NamedTuple | Metadata, api_version : String = "batch/v1", kind : String = "CronJob", force : Bool = false, field_manager : String | Nil = nil, **kwargs)
Source
apply_deployment(resource : Deployment, spec, name : String = resource.metadata.name, namespace : String | Nil = resource.metadata.namespace, force : Bool = false, field_manager : String | Nil = nil)
Source
apply_deployment(metadata : NamedTuple | Metadata, api_version : String = "apps/v1", kind : String = "Deployment", force : Bool = false, field_manager : String | Nil = nil, **kwargs)
Source
apply_ingress(resource : Resource(Networking::Ingress), spec, name : String = resource.metadata.name, namespace : String | Nil = resource.metadata.namespace, force : Bool = false, field_manager : String | Nil = nil)
Source
apply_ingress(metadata : NamedTuple | Metadata, api_version : String = "networking.k8s.io/v1", kind : String = "Ingress", force : Bool = false, field_manager : String | Nil = nil, **kwargs)
Source
apply_job(resource : Resource(Job), spec, name : String = resource.metadata.name, namespace : String | Nil = resource.metadata.namespace, force : Bool = false, field_manager : String | Nil = nil)
Source
apply_job(metadata : NamedTuple | Metadata, api_version : String = "batch/v1", kind : String = "Job", force : Bool = false, field_manager : String | Nil = nil, **kwargs)
Source
apply_persistentvolumeclaim(resource : Resource(JSON::Any), spec, name : String = resource.metadata.name, namespace : String | Nil = resource.metadata.namespace, force : Bool = false, field_manager : String | Nil = nil)
Source
apply_persistentvolumeclaim(metadata : NamedTuple | Metadata, api_version : String = "/v1", kind : String = "PersistentVolumeClaim", force : Bool = false, field_manager : String | Nil = nil, **kwargs)
Source
apply_pod(resource : Pod, spec, name : String = resource.metadata.name, namespace : String | Nil = resource.metadata.namespace, force : Bool = false, field_manager : String | Nil = nil)
Source
apply_pod(metadata : NamedTuple | Metadata, api_version : String = "/v1", kind : String = "Pod", force : Bool = false, field_manager : String | Nil = nil, **kwargs)
Source
apply_service(resource : Service, spec, name : String = resource.metadata.name, namespace : String | Nil = resource.metadata.namespace, force : Bool = false, field_manager : String | Nil = nil)
Source
apply_service(metadata : NamedTuple | Metadata, api_version : String = "/v1", kind : String = "Service", force : Bool = false, field_manager : String | Nil = nil, **kwargs)
Source
apply_statefulset(resource : Resource(StatefulSet), spec, name : String = resource.metadata.name, namespace : String | Nil = resource.metadata.namespace, force : Bool = false, field_manager : String | Nil = nil)
Source
apply_statefulset(metadata : NamedTuple | Metadata, api_version : String = "apps/v1", kind : String = "StatefulSet", force : Bool = false, field_manager : String | Nil = nil, **kwargs)
Source
close
Source
cronjob(name : String, namespace : String = "default", resource_version : String = "")
Source
cronjobs(namespace : String | Nil = "default", label_selector = nil)
Source
delete(path : String, headers = HTTP::Headers.new)
Source
delete_cronjob(resource : Resource(CronJob))
Source
delete_cronjob(name : String, namespace : String = "default", *, propagation_policy : PropagationPolicy = :background)
Source
delete_deployment(resource : Deployment)
Source
delete_deployment(name : String, namespace : String = "default", *, propagation_policy : PropagationPolicy = :background)
Source
delete_ingress(resource : Resource(Networking::Ingress))
Source
delete_ingress(name : String, namespace : String = "default", *, propagation_policy : PropagationPolicy = :background)
Source
delete_job(resource : Resource(Job))
Source
delete_job(name : String, namespace : String = "default", *, propagation_policy : PropagationPolicy = :background)
Source
delete_persistentvolumeclaim(resource : Resource(JSON::Any))
Source
delete_persistentvolumeclaim(name : String, namespace : String = "default", *, propagation_policy : PropagationPolicy = :background)
Source
delete_pod(resource : Pod)
Source
delete_pod(name : String, namespace : String = "default", *, propagation_policy : PropagationPolicy = :background)
Source
delete_service(resource : Service)
Source
delete_service(name : String, namespace : String = "default", *, propagation_policy : PropagationPolicy = :background)
Source
delete_statefulset(resource : Resource(StatefulSet))
Source
delete_statefulset(name : String, namespace : String = "default", *, propagation_policy : PropagationPolicy = :background)
Source
deployment(name : String, namespace : String = "default", resource_version : String = "")
Source
deployments(namespace : String | Nil = "default", label_selector = nil)
Source
get(path : String, headers = HTTP::Headers.new, *, as type : T.class) : T | Nil forall T
Source
get(path : String, headers = HTTP::Headers.new, &)
Source
ingress(name : String, namespace : String = "default", resource_version : String = "")
Source
ingresses(namespace : String | Nil = "default", label_selector = nil)
Source
job(name : String, namespace : String = "default", resource_version : String = "")
Source
jobs(namespace : String | Nil = "default", label_selector = nil)
Source
on_close

Register a callback to be invoked when the client is closed. Used for cleanup of resources like TokenFileWatcher.

Source
patch(path : String, body, headers = HTTP::Headers.new)
Source
patch_cronjob(name : String, namespace, **kwargs)
Source
patch_cronjob_subresource(name : String, subresource : String, namespace : String = "default", **args)
Source
patch_deployment(name : String, namespace, **kwargs)
Source
patch_deployment_subresource(name : String, subresource : String, namespace : String = "default", **args)
Source
patch_ingress(name : String, namespace, **kwargs)
Source
patch_ingress_subresource(name : String, subresource : String, namespace : String = "default", **args)
Source
patch_job(name : String, namespace, **kwargs)
Source
patch_job_subresource(name : String, subresource : String, namespace : String = "default", **args)
Source
patch_persistentvolumeclaim(name : String, namespace, **kwargs)
Source
patch_persistentvolumeclaim_subresource(name : String, subresource : String, namespace : String = "default", **args)
Source
patch_pod(name : String, namespace, **kwargs)
Source
patch_pod_subresource(name : String, subresource : String, namespace : String = "default", **args)
Source
patch_service(name : String, namespace, **kwargs)
Source
patch_service_subresource(name : String, subresource : String, namespace : String = "default", **args)
Source
patch_statefulset(name : String, namespace, **kwargs)
Source
patch_statefulset_subresource(name : String, subresource : String, namespace : String = "default", **args)
Source
persistentvolumeclaim(name : String, namespace : String = "default", resource_version : String = "")
Source
persistentvolumeclaims(namespace : String | Nil = "default", label_selector = nil)
Source
pod(name : String, namespace : String = "default", resource_version : String = "")
Source
pods(namespace : String | Nil = "default", label_selector = nil)
Source
put(path : String, body, headers = HTTP::Headers.new)
Source
raw_patch(path : String, body, headers = HTTP::Headers.new)
Source
service(name : String, namespace : String = "default", resource_version : String = "")
Source
services(namespace : String | Nil = "default", label_selector = nil)
Source
statefulset(name : String, namespace : String = "default", resource_version : String = "")
Source
statefulsets(namespace : String | Nil = "default", label_selector = nil)
Source
watch_cronjobs(resource_version = "0", timeout : Time::Span = 10.minutes, namespace : String | Nil = nil, labels label_selector : String = "", &)
Source
watch_deployments(resource_version = "0", timeout : Time::Span = 10.minutes, namespace : String | Nil = nil, labels label_selector : String = "", &)
Source
watch_ingresses(resource_version = "0", timeout : Time::Span = 10.minutes, namespace : String | Nil = nil, labels label_selector : String = "", &)
Source
watch_jobs(resource_version = "0", timeout : Time::Span = 10.minutes, namespace : String | Nil = nil, labels label_selector : String = "", &)
Source
watch_persistentvolumeclaims(resource_version = "0", timeout : Time::Span = 10.minutes, namespace : String | Nil = nil, labels label_selector : String = "", &)
Source
watch_pods(resource_version = "0", timeout : Time::Span = 10.minutes, namespace : String | Nil = nil, labels label_selector : String = "", &)
Source
watch_services(resource_version = "0", timeout : Time::Span = 10.minutes, namespace : String | Nil = nil, labels label_selector : String = "", &)
Source
watch_statefulsets(resource_version = "0", timeout : Time::Span = 10.minutes, namespace : String | Nil = nil, labels label_selector : String = "", &)
Source