k8s

package
v2.24.1 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Apr 10, 2024 License: Apache-2.0 Imports: 31 Imported by: 1

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func BuildGVKFilter added in v2.10.2 

func BuildGVKFilter(group *string, version *string, kind *string) func(ar *v1.APIResource) bool

func CreateDiscoveryAndMapper added in v2.21.0 

func CreateDiscoveryAndMapper(ctx context.Context, config *rest.Config) (discovery.CachedDiscoveryInterface, meta.RESTMapper, error)

func FixNamespace added in v2.21.0 

func FixNamespace(o *uo.UnstructuredObject, namespaced bool, def string)

func FixNamespaceInRef added in v2.21.0 

func FixNamespaceInRef(ref k8s.ObjectRef, namespaced bool, def string) k8s.ObjectRef

func GetClusterId added in v2.21.0 

func GetClusterId(ctx context.Context, c client.Client) (string, error)

func GetOrGenerateSingleSecret added in v2.21.0 

func GetOrGenerateSingleSecret(ctx context.Context, c client.Client, name string, namespace string, key string, manager string) (string, error)

func GetSingleSecret added in v2.21.0 

func GetSingleSecret(ctx context.Context, c client.Client, name string, namespace string, key string) (string, error)

func UnwrapListItems 

func UnwrapListItems(o *uo.UnstructuredObject, withListCallback bool, cb func(o *uo.UnstructuredObject) error) error

Types

type ApiWarning 

type ApiWarning struct {
	Code  int
	Agent string
	Text  string
}

type DeleteOptions 

type DeleteOptions struct {
	ForceDryRun         bool
	NoWait              bool
	IgnoreNotFoundError bool
}

type K8sCluster 

type K8sCluster struct {
	DryRun bool

	ServerVersion *version.Info
	// contains filtered or unexported fields
}

func NewK8sCluster 

func NewK8sCluster(ctx context.Context,
	config *rest.Config,
	discovery discovery.DiscoveryInterface,
	mapper meta.RESTMapper,
	dryRun bool) (*K8sCluster, error)

func (*K8sCluster) ApplyObject added in v2.20.0 

func (k *K8sCluster) ApplyObject(o *uo.UnstructuredObject, options PatchOptions) (*uo.UnstructuredObject, []ApiWarning, error)

func (*K8sCluster) DeleteSingleObject 

func (k *K8sCluster) DeleteSingleObject(ref k8s.ObjectRef, options DeleteOptions) ([]ApiWarning, error)

func (*K8sCluster) FixObjectForPatch 

func (k *K8sCluster) FixObjectForPatch(o *uo.UnstructuredObject) *uo.UnstructuredObject

func (*K8sCluster) GetAllAPIResources added in v2.24.0 

func (k *K8sCluster) GetAllAPIResources() ([]v1.APIResource, error)

func (*K8sCluster) GetAllPreferredAPIResources added in v2.24.0 

func (k *K8sCluster) GetAllPreferredAPIResources() ([]v1.APIResource, error)

func (*K8sCluster) GetClusterId added in v2.21.0 

func (k *K8sCluster) GetClusterId() (string, error)

func (*K8sCluster) GetFilteredPreferredAPIResources added in v2.24.0 

func (k *K8sCluster) GetFilteredPreferredAPIResources(filter func(ar *v1.APIResource) bool) ([]v1.APIResource, error)

func (*K8sCluster) GetSchemaForGVK 

func (k *K8sCluster) GetSchemaForGVK(gvk schema.GroupVersionKind) (*uo.UnstructuredObject, error)

func (*K8sCluster) GetSingleObject 

func (k *K8sCluster) GetSingleObject(ref k8s.ObjectRef) (*uo.UnstructuredObject, []ApiWarning, error)

func (*K8sCluster) GetSingleObjectMetadata added in v2.23.0 

func (k *K8sCluster) GetSingleObjectMetadata(ref k8s.ObjectRef) (*uo.UnstructuredObject, []ApiWarning, error)

func (*K8sCluster) IsNamespaced 

func (k *K8sCluster) IsNamespaced(gvk schema.GroupVersionKind) *bool

func (*K8sCluster) ListMetadata added in v2.20.0 

func (k *K8sCluster) ListMetadata(gvk schema.GroupVersionKind, namespace string, labels map[string]string) ([]*uo.UnstructuredObject, []ApiWarning, error)

func (*K8sCluster) ListObjects 

func (k *K8sCluster) ListObjects(gvk schema.GroupVersionKind, namespace string, labels map[string]string) ([]*uo.UnstructuredObject, []ApiWarning, error)

func (*K8sCluster) ProxyGet added in v2.10.0 

func (k *K8sCluster) ProxyGet(scheme, namespace, name, port, path string, params map[string]string) (io.ReadCloser, error)

func (*K8sCluster) ReadWrite 

func (k *K8sCluster) ReadWrite() *K8sCluster

func (*K8sCluster) ResetMapper added in v2.20.0 

func (k *K8sCluster) ResetMapper()

func (*K8sCluster) ToClient added in v2.20.0 

func (k *K8sCluster) ToClient() (client.Client, error)

func (*K8sCluster) ToDiscoveryClient added in v2.15.0 

func (k *K8sCluster) ToDiscoveryClient() (discovery.CachedDiscoveryInterface, error)

func (*K8sCluster) ToRESTConfig added in v2.15.0 

func (k *K8sCluster) ToRESTConfig() (*rest.Config, error)

func (*K8sCluster) ToRESTMapper added in v2.15.0 

func (k *K8sCluster) ToRESTMapper() (meta.RESTMapper, error)

func (*K8sCluster) UpdateObject 

func (k *K8sCluster) UpdateObject(o *uo.UnstructuredObject, options UpdateOptions) (*uo.UnstructuredObject, []ApiWarning, error)

type PatchOptions 

type PatchOptions struct {
	ForceDryRun bool
	ForceApply  bool
}

type UpdateOptions 

type UpdateOptions struct {
	ForceDryRun bool
}

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.