Versions in this module Expand all Collapse all v0 v0.0.10 Apr 10, 2026 v0.0.9 Mar 17, 2026 Changes in this version + const DEFAULT_NAMESPACE_NAME + func NewIntStr(v int) *intstr.IntOrString + type Client struct + func NewClient(kubeConfigYaml string) (*Client, error) + func NewClientFromFile(kubeConfPath string) (*Client, error) + func NewClientFromRestConfig(restConf *rest.Config) (*Client, error) + func (c *Client) Admin() *admin.Client + func (c *Client) Config() *config.Client + func (c *Client) CurrentCluster() *clientcmdapi.Cluster + func (c *Client) CurrentContext() *clientcmdapi.Context + func (c *Client) DeploymentWatcher(namespaces ...string) *K8sWatcher[*appsv1.Deployment] + func (c *Client) Event() *event.Client + func (c *Client) Gateway() *gateway.Client + func (c *Client) GetContexts() map[string]*clientcmdapi.Context + func (c *Client) K8sClientSet() *kubernetes.Clientset + func (c *Client) Network() *network.Client + func (c *Client) PodWatcher(namespaces ...string) *K8sWatcher[*corev1.Pod] + func (c *Client) ServerResources() *meta.ApiResourceList + func (c *Client) ServerVersion() (string, error) + func (c *Client) ServiceWatcher(namespaces ...string) *K8sWatcher[*corev1.Service] + func (c *Client) Storage() *storage.Client + func (c *Client) WorkLoad() *workload.Client + type K8sWatcher struct + func NewK8sWatcher[T runtime.Object](clientset kubernetes.Interface, namespaces []string, ...) *K8sWatcher[T] + func (w *K8sWatcher[T]) GetName() string + func (w *K8sWatcher[T]) GetNamespaces() []string + func (w *K8sWatcher[T]) IsConfigUpdate(configHash string) bool + func (w *K8sWatcher[T]) OnError(fn func(error)) + func (w *K8sWatcher[T]) RegisterHandler(handler ResourceHandler[T]) + func (w *K8sWatcher[T]) Run() error + func (w *K8sWatcher[T]) SetConfigHash(configHash string) *K8sWatcher[T] + func (w *K8sWatcher[T]) SetName(name string) *K8sWatcher[T] + func (w *K8sWatcher[T]) Stop() + func (w *K8sWatcher[T]) WithAnnotations(key, value string) *K8sWatcher[T] + type RESOURCE string + const RESOURCE_DEPLOYMENT + const RESOURCE_POD + const RESOURCE_SERVICE + type ResourceHandler interface + OnAdd func(obj T) + OnDelete func(obj T) + OnUpdate func(oldObj, newObj T) + type ResourceHandlerFunc struct + OnAddFunc func(obj T) + OnDeleteFunc func(obj T) + OnUpdateFunc func(oldObj, newObj T) + func NewResourceHandlerFunc[T runtime.Object](onAddFunc func(obj T), onUpdateFunc func(oldObj, newObj T), ...) *ResourceHandlerFunc[T] + func (f *ResourceHandlerFunc[T]) OnAdd(obj T) + func (f *ResourceHandlerFunc[T]) OnDelete(obj T) + func (f *ResourceHandlerFunc[T]) OnUpdate(oldObj, newObj T)