Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

kube

package

Go to main page

Versions in this module

v1

v1.0.0

Nov 22, 2023

v0

v0.0.3

Dec 2, 2023

Changes in this version

+ const AlphasenseQueueKind

+ const AlphasenseSubscriptionKind

+ const AlphasenseTopicKind

+ const CrossplaneProviderKind

v0.0.2

Dec 1, 2023

v0.0.1

Dec 1, 2023

Changes in this version

+ const APIServiceKind

+ const CustomResourceDefinitionKind

+ const DaemonSetKind

+ const DeploymentKind

+ const EndpointsKind

+ const HorizontalPodAutoscalerKind

+ const IngressKind

+ const JobKind

+ const NamespaceKind

+ const PersistentVolumeClaimKind

+ const PodKind

+ const ReplicaSetKind

+ const SecretKind

+ const ServiceAccountKind

+ const ServiceKind

+ const StatefulSetKind

+ func GetAppInstanceLabel(un *unstructured.Unstructured, key string) string

+ func GetDeploymentReplicas(u *unstructured.Unstructured) *int64

+ func GetObjectRef(obj *unstructured.Unstructured) v1.ObjectReference

+ func IsCRD(obj *unstructured.Unstructured) bool

+ func IsCRDGroupVersionKind(gvk schema.GroupVersionKind) bool

+ func IsNamespacedOrUnknown(provider ResourceInfoProvider, gk schema.GroupKind) bool

+ func MustToUnstructured(obj interface{}) *unstructured.Unstructured

+ func NewKubeConfig(restConfig *rest.Config, namespace string) *clientcmdapi.Config

+ func RetryUntilSucceed(ctx context.Context, interval time.Duration, desc string, log logr.Logger, ...)

+ func RunAllAsync(count int, action func(i int) error) error

+ func ServerResourceForGroupVersionKind(disco discovery.DiscoveryInterface, gvk schema.GroupVersionKind, verb string) (*metav1.APIResource, error)

+ func SplitYAML(yamlData []byte) ([]*unstructured.Unstructured, error)

+ func SplitYAMLToString(yamlData []byte) ([]string, error)

+ func TestConfig(config *rest.Config) error

+ func ToGroupVersionResource(groupVersion string, apiResource *metav1.APIResource) schema.GroupVersionResource

+ func ToResourceInterface(dynamicIf dynamic.Interface, apiResource *metav1.APIResource, ...) dynamic.ResourceInterface

+ func ToUnstructured(obj interface{}) (*unstructured.Unstructured, error)

+ func UnsetLabel(target *unstructured.Unstructured, key string)

+ func WatchWithRetry(ctx context.Context, getWatch func() (watch.Interface, error)) ...

+ func WriteKubeConfig(restConfig *rest.Config, namespace, filename string) error

+ type APIResourceInfo struct

+ GroupKind schema.GroupKind

+ GroupVersionResource schema.GroupVersionResource

+ Meta metav1.APIResource

+ type CleanupFunc func()

+ type CreateGVKParserError struct

+ func NewCreateGVKParserError(err error) *CreateGVKParserError

+ func (e *CreateGVKParserError) Error() string

+ type Kubectl interface

+ ConvertToVersion func(obj *unstructured.Unstructured, group, version string) (*unstructured.Unstructured, error)

+ CreateResource func(ctx context.Context, config *rest.Config, gvk schema.GroupVersionKind, ...) (*unstructured.Unstructured, error)

+ DeleteResource func(ctx context.Context, config *rest.Config, gvk schema.GroupVersionKind, ...) error

+ GetAPIResources func(config *rest.Config, preferred bool, resourceFilter ResourceFilter) ([]APIResourceInfo, error)

+ GetResource func(ctx context.Context, config *rest.Config, gvk schema.GroupVersionKind, ...) (*unstructured.Unstructured, error)

+ GetServerVersion func(config *rest.Config) (string, error)

+ LoadOpenAPISchema func(config *rest.Config) (openapi.Resources, *managedfields.GvkParser, error)

+ ManageResources func(config *rest.Config, openAPISchema openapi.Resources) (ResourceOperations, func(), error)

+ NewDynamicClient func(config *rest.Config) (dynamic.Interface, error)

+ PatchResource func(ctx context.Context, config *rest.Config, gvk schema.GroupVersionKind, ...) (*unstructured.Unstructured, error)

+ SetOnKubectlRun func(onKubectlRun OnKubectlRunFunc)

+ type KubectlCmd struct

+ Log logr.Logger

+ OnKubectlRun OnKubectlRunFunc

+ Tracer tracing.Tracer

+ func (k *KubectlCmd) ConvertToVersion(obj *unstructured.Unstructured, group string, version string) (*unstructured.Unstructured, error)

+ func (k *KubectlCmd) CreateResource(ctx context.Context, config *rest.Config, gvk schema.GroupVersionKind, ...) (*unstructured.Unstructured, error)

+ func (k *KubectlCmd) DeleteResource(ctx context.Context, config *rest.Config, gvk schema.GroupVersionKind, ...) error

+ func (k *KubectlCmd) GetAPIResources(config *rest.Config, preferred bool, resourceFilter ResourceFilter) ([]APIResourceInfo, error)

+ func (k *KubectlCmd) GetResource(ctx context.Context, config *rest.Config, gvk schema.GroupVersionKind, ...) (*unstructured.Unstructured, error)

+ func (k *KubectlCmd) GetServerVersion(config *rest.Config) (string, error)

+ func (k *KubectlCmd) LoadOpenAPISchema(config *rest.Config) (openapi.Resources, *managedfields.GvkParser, error)

+ func (k *KubectlCmd) ManageResources(config *rest.Config, openAPISchema openapi.Resources) (ResourceOperations, func(), error)

+ func (k *KubectlCmd) NewDynamicClient(config *rest.Config) (dynamic.Interface, error)

+ func (k *KubectlCmd) PatchResource(ctx context.Context, config *rest.Config, gvk schema.GroupVersionKind, ...) (*unstructured.Unstructured, error)

+ func (k *KubectlCmd) SetOnKubectlRun(onKubectlRun OnKubectlRunFunc)

+ type OnKubectlRunFunc func(command string) (CleanupFunc, error)

+ type ResourceFilter interface

+ IsExcludedResource func(group, kind, cluster string) bool

+ type ResourceInfoProvider interface

+ IsNamespaced func(gk schema.GroupKind) (bool, error)

+ type ResourceKey struct

+ Group string

+ Kind string

+ Name string

+ Namespace string

+ func GetResourceKey(obj *unstructured.Unstructured) ResourceKey

+ func NewResourceKey(group string, kind string, namespace string, name string) ResourceKey

+ func (k *ResourceKey) String() string

+ func (k ResourceKey) GroupKind() schema.GroupKind

+ type ResourceOperations interface

+ ApplyResource func(ctx context.Context, obj *unstructured.Unstructured, ...) (string, error)

+ CreateResource func(ctx context.Context, obj *unstructured.Unstructured, ...) (string, error)

+ ReplaceResource func(ctx context.Context, obj *unstructured.Unstructured, ...) (string, error)

+ UpdateResource func(ctx context.Context, obj *unstructured.Unstructured, ...) (*unstructured.Unstructured, error)