kubernetes

package

Go to main page

Versions in this module

v0

v0.0.55

Dec 3, 2025

Changes in this version

type AccessControlClientset

+ func (a *AccessControlClientset) DynamicClient() dynamic.Interface

+ func (a *AccessControlClientset) MetricsV1beta1Client() *metricsv1beta1.MetricsV1beta1Client

+ func (a *AccessControlClientset) RESTMapper() meta.ResettableRESTMapper

+ func (a *AccessControlClientset) ToRawKubeConfigLoader() clientcmd.ClientConfig

+ type AccessControlRoundTripper struct

+ func (rt *AccessControlRoundTripper) RoundTrip(req *http.Request) (*http.Response, error)

type Kubernetes

+ func (k *Kubernetes) NewKiali() *kiali.Kiali

+ func (k *Kubernetes) ResourcesScale(ctx context.Context, gvk *schema.GroupVersionKind, namespace, name string, ...) (*unstructured.Unstructured, error)

+ func (k *Kubernetes) ToDiscoveryClient() (discovery.CachedDiscoveryInterface, error)

+ func (k *Kubernetes) ToRESTConfig() (*rest.Config, error)

+ func (k *Kubernetes) ToRESTMapper() (meta.RESTMapper, error)

+ func (k *Kubernetes) ToRawKubeConfigLoader() clientcmd.ClientConfig

type Manager

+ func (m *Manager) Invalidate()

+ type McpReload func() error

v0.0.54

Nov 12, 2025

Changes in this version

+ var ErrorInClusterNotInCluster = errors.New("in-cluster manager cannot be used outside of a cluster")

+ var ErrorKubeconfigInClusterNotAllowed = errors.New("kubeconfig manager cannot be used in in-cluster deployments")

+ func IsInCluster(cfg *config.StaticConfig) bool

type AccessControlClientset

+ func (a *AccessControlClientset) Nodes() (corev1.NodeInterface, error)

+ func (a *AccessControlClientset) NodesLogs(ctx context.Context, name string) (*rest.Request, error)

+ func (a *AccessControlClientset) NodesMetricses(ctx context.Context, name string, listOptions metav1.ListOptions) (*metrics.NodeMetricsList, error)

+ func (a *AccessControlClientset) NodesStatsSummary(ctx context.Context, name string) (*rest.Request, error)

type Kubernetes

+ func (k *Kubernetes) NodesLog(ctx context.Context, name string, query string, tailLines int64) (string, error)

+ func (k *Kubernetes) NodesStatsSummary(ctx context.Context, name string) (string, error)

+ func (k *Kubernetes) NodesTop(ctx context.Context, options NodesTopOptions) (*metrics.NodeMetricsList, error)

type Manager

+ func NewInClusterManager(config *config.StaticConfig) (*Manager, error)

+ func NewKubeconfigManager(config *config.StaticConfig, kubeconfigContext string) (*Manager, error)

+ type NodesTopOptions struct

+ Name string

+ type Provider interface

+ Close func()

+ GetDefaultTarget func() string

+ GetDerivedKubernetes func(ctx context.Context, target string) (*Kubernetes, error)

+ GetTargetParameterName func() string

+ GetTargets func(ctx context.Context) ([]string, error)

+ WatchTargets func(func() error)

+ func NewProvider(cfg *config.StaticConfig) (Provider, error)

+ type TokenVerifier interface

+ VerifyToken func(ctx context.Context, cluster, token, audience string) (*authenticationv1api.UserInfo, []string, error)

v0.0.53

Oct 10, 2025

Changes in this version

+ const KubeConfigTargetParameterName

+ func GetRegisteredStrategies() []string

+ func RegisterProvider(strategy string, factory ProviderFactory)

type Kubernetes

+ func (k *Kubernetes) AccessControlClientset() *AccessControlClientset

+ func (k *Kubernetes) ConfigurationContextsDefault() (string, error)

+ func (k *Kubernetes) ConfigurationContextsList() (map[string]string, error)

+ type ManagerProvider interface

+ Close func()

+ GetDefaultTarget func() string

+ GetManagerFor func(ctx context.Context, target string) (*Manager, error)

+ GetTargetParameterName func() string

+ GetTargets func(ctx context.Context) ([]string, error)

+ WatchTargets func(func() error)

+ func NewManagerProvider(cfg *config.StaticConfig) (ManagerProvider, error)

+ type ProviderFactory func(m *Manager, cfg *config.StaticConfig) (ManagerProvider, error)

v0.0.52

Sep 25, 2025

Changes in this version

+ const DefaultTailLines

v0.0.51

Sep 17, 2025

Changes in this version

type Kubernetes

+ func (k *Kubernetes) ConfigurationView(minify bool) (runtime.Object, error)

+ type Openshift interface

+ IsOpenShift func(context.Context) bool

v0.0.50

Sep 11, 2025

v0.0.49

Aug 8, 2025

v0.0.48

Aug 5, 2025

v0.0.47

Jul 31, 2025

Changes in this version

+ const AppKubernetesComponent

+ const AppKubernetesManagedBy

+ const AppKubernetesName

+ const AppKubernetesPartOf

+ const CustomAuthorizationHeader

+ const CustomUserAgent

+ const OAuthAuthorizationHeader

+ var InClusterConfig = func() (*rest.Config, error)

+ var ParameterCodec = runtime.NewParameterCodec(Scheme)

+ var Scheme = scheme.Scheme

+ type AccessControlClientset struct

+ func NewAccessControlClientset(cfg *rest.Config, staticConfig *config.StaticConfig) (*AccessControlClientset, error)

+ func (a *AccessControlClientset) DiscoveryClient() discovery.DiscoveryInterface

+ func (a *AccessControlClientset) Pods(namespace string) (corev1.PodInterface, error)

+ func (a *AccessControlClientset) PodsExec(namespace, name string, podExecOptions *v1.PodExecOptions) (remotecommand.Executor, error)

+ func (a *AccessControlClientset) PodsMetricses(ctx context.Context, namespace, name string, listOptions metav1.ListOptions) (*metrics.PodMetricsList, error)

+ func (a *AccessControlClientset) SelfSubjectAccessReviews() (authorizationv1.SelfSubjectAccessReviewInterface, error)

+ func (a *AccessControlClientset) Services(namespace string) (corev1.ServiceInterface, error)

+ func (a *AccessControlClientset) TokenReview() (authenticationv1.TokenReviewInterface, error)

+ type AccessControlRESTMapper struct

+ func NewAccessControlRESTMapper(delegate *restmapper.DeferredDiscoveryRESTMapper, ...) *AccessControlRESTMapper

+ func (a AccessControlRESTMapper) KindFor(resource schema.GroupVersionResource) (schema.GroupVersionKind, error)

+ func (a AccessControlRESTMapper) KindsFor(resource schema.GroupVersionResource) ([]schema.GroupVersionKind, error)

+ func (a AccessControlRESTMapper) RESTMapping(gk schema.GroupKind, versions ...string) (*meta.RESTMapping, error)

+ func (a AccessControlRESTMapper) RESTMappings(gk schema.GroupKind, versions ...string) ([]*meta.RESTMapping, error)

+ func (a AccessControlRESTMapper) Reset()

+ func (a AccessControlRESTMapper) ResourceFor(input schema.GroupVersionResource) (schema.GroupVersionResource, error)

+ func (a AccessControlRESTMapper) ResourceSingularizer(resource string) (singular string, err error)

+ func (a AccessControlRESTMapper) ResourcesFor(input schema.GroupVersionResource) ([]schema.GroupVersionResource, error)

+ type CloseWatchKubeConfig func() error

+ type HeaderKey string

+ type Kubernetes struct

+ func (k *Kubernetes) EventsList(ctx context.Context, namespace string) ([]map[string]any, error)

+ func (k *Kubernetes) NamespaceOrDefault(namespace string) string

+ func (k *Kubernetes) NamespacesList(ctx context.Context, options ResourceListOptions) (runtime.Unstructured, error)

+ func (k *Kubernetes) NewHelm() *helm.Helm

+ func (k *Kubernetes) PodsDelete(ctx context.Context, namespace, name string) (string, error)

+ func (k *Kubernetes) PodsExec(ctx context.Context, namespace, name, container string, command []string) (string, error)

+ func (k *Kubernetes) PodsGet(ctx context.Context, namespace, name string) (*unstructured.Unstructured, error)

+ func (k *Kubernetes) PodsListInAllNamespaces(ctx context.Context, options ResourceListOptions) (runtime.Unstructured, error)

+ func (k *Kubernetes) PodsListInNamespace(ctx context.Context, namespace string, options ResourceListOptions) (runtime.Unstructured, error)

+ func (k *Kubernetes) PodsLog(ctx context.Context, namespace, name, container string) (string, error)

+ func (k *Kubernetes) PodsRun(ctx context.Context, namespace, name, image string, port int32) ([]*unstructured.Unstructured, error)

+ func (k *Kubernetes) PodsTop(ctx context.Context, options PodsTopOptions) (*metrics.PodMetricsList, error)

+ func (k *Kubernetes) ProjectsList(ctx context.Context, options ResourceListOptions) (runtime.Unstructured, error)

+ func (k *Kubernetes) ResourcesCreateOrUpdate(ctx context.Context, resource string) ([]*unstructured.Unstructured, error)

+ func (k *Kubernetes) ResourcesDelete(ctx context.Context, gvk *schema.GroupVersionKind, namespace, name string) error

+ func (k *Kubernetes) ResourcesGet(ctx context.Context, gvk *schema.GroupVersionKind, namespace, name string) (*unstructured.Unstructured, error)

+ func (k *Kubernetes) ResourcesList(ctx context.Context, gvk *schema.GroupVersionKind, namespace string, ...) (runtime.Unstructured, error)

+ type Manager struct

+ CloseWatchKubeConfig CloseWatchKubeConfig

+ func NewManager(config *config.StaticConfig) (*Manager, error)

+ func (m *Manager) Close()

+ func (m *Manager) ConfigurationView(minify bool) (runtime.Object, error)

+ func (m *Manager) Derived(ctx context.Context) (*Kubernetes, error)

+ func (m *Manager) GetAPIServerHost() string

+ func (m *Manager) IsInCluster() bool

+ func (m *Manager) IsOpenShift(_ context.Context) bool

+ func (m *Manager) NamespaceOrDefault(namespace string) string

+ func (m *Manager) ToDiscoveryClient() (discovery.CachedDiscoveryInterface, error)

+ func (m *Manager) ToRESTConfig() (*rest.Config, error)

+ func (m *Manager) ToRESTMapper() (meta.RESTMapper, error)

+ func (m *Manager) ToRawKubeConfigLoader() clientcmd.ClientConfig

+ func (m *Manager) VerifyToken(ctx context.Context, token, audience string) (*authenticationv1api.UserInfo, []string, error)

+ func (m *Manager) WatchKubeConfig(onKubeConfigChange func() error)

+ type PodsTopOptions struct

+ AllNamespaces bool

+ Name string

+ Namespace string

+ type ResourceListOptions struct

+ AsTable bool

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL