resource

package
v0.15.2-fix-2 Latest Latest
Warning

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

 Go to latest Published: Sep 12, 2023 License: Apache-2.0 Imports: 27 Imported by: 0

Documentation

Overview

Package resource provides a general CRUD interface for Kubernetes resources.

Index

Constants

This section is empty.

Variables

View Source 
var NewDynamicClient = func(config *rest.Config) (dynamic.Interface, error) {
	c, err := dynamic.NewForConfig(config)
	return c, err
}

Functions

func BuildRestConfigFromData 

func BuildRestConfigFromData(apiServer, apiServerToken, caData string, tls *rest.TLSClientConfig) (*rest.Config, error)

func BuildRestConfigFromFiles 

func BuildRestConfigFromFiles(apiServer, apiServerTokenFile, caFile string, tls *rest.TLSClientConfig) *rest.Config

func DefaultUpdateStatus 

func DefaultUpdateStatus(_ context.Context, _ runtime.Object, _ metav1.UpdateOptions) (runtime.Object, error)

DefaultUpdateStatus returns NotFound error indicating the status subresource isn't supported.

func EnsureValidName 

func EnsureValidName(name string) string

func GetAuthorizedRestConfigFromData 

func GetAuthorizedRestConfigFromData(apiServer, apiServerToken, caData string, tls *rest.TLSClientConfig,
	gvr schema.GroupVersionResource, namespace string,
) (restConfig *rest.Config, authorized bool, err error)

func GetAuthorizedRestConfigFromFiles 

func GetAuthorizedRestConfigFromFiles(apiServer, apiServerTokenFile, caFile string, tls *rest.TLSClientConfig,
	gvr schema.GroupVersionResource, namespace string,
) (restConfig *rest.Config, authorized bool, err error)

func IsAuthorizedFor 

func IsAuthorizedFor(restConfig *rest.Config, gvr schema.GroupVersionResource, namespace string) (bool, error)

func IsNotFoundErr 

func IsNotFoundErr(err error) bool

func IsUnknownAuthorityError 

func IsUnknownAuthorityError(err error) bool

func MustExtractList 

func MustExtractList(from runtime.Object) []runtime.Object

func MustToMeta 

func MustToMeta(obj interface{}) metav1.Object

func MustToUnstructured 

func MustToUnstructured(from runtime.Object) *unstructured.Unstructured

func MustToUnstructuredUsingDefaultConverter 

func MustToUnstructuredUsingDefaultConverter(from runtime.Object) *unstructured.Unstructured

MustToUnstructuredUsingDefaultConverter uses runtime.DefaultUnstructuredConverter which doesn't use a runtime.Scheme and thus the returned Unstructured will not have the type metadata field populated.

func MustToUnstructuredUsingScheme 

func MustToUnstructuredUsingScheme(from runtime.Object, usingScheme *runtime.Scheme) *unstructured.Unstructured

func ToJSON 

func ToJSON(o any) string

func ToUnstructured 

func ToUnstructured(from runtime.Object) (*unstructured.Unstructured, error)

func ToUnstructuredUsingScheme 

func ToUnstructuredUsingScheme(from runtime.Object, usingScheme *runtime.Scheme) (*unstructured.Unstructured, error)

Types

type Interface 

type Interface interface {
	Get(ctx context.Context, name string, options metav1.GetOptions) (runtime.Object, error)
	Create(ctx context.Context, obj runtime.Object, options metav1.CreateOptions) (runtime.Object, error)
	Update(ctx context.Context, obj runtime.Object, options metav1.UpdateOptions) (runtime.Object, error)
	UpdateStatus(ctx context.Context, obj runtime.Object, options metav1.UpdateOptions) (runtime.Object, error)
	Delete(ctx context.Context, name string, options metav1.DeleteOptions) error
	List(ctx context.Context, options metav1.ListOptions) ([]runtime.Object, error)
}

func ForClusterRole 

func ForClusterRole(client kubernetes.Interface) Interface

func ForClusterRoleBinding 

func ForClusterRoleBinding(client kubernetes.Interface) Interface

func ForConfigMap 

func ForConfigMap(client kubernetes.Interface, namespace string) Interface

func ForDaemonSet 

func ForDaemonSet(client kubernetes.Interface, namespace string) Interface

func ForDeployment 

func ForDeployment(client kubernetes.Interface, namespace string) Interface

func ForNamespace 

func ForNamespace(client kubernetes.Interface) Interface

func ForPod 

func ForPod(client kubernetes.Interface, namespace string) Interface

func ForRole 

func ForRole(client kubernetes.Interface, namespace string) Interface

func ForRoleBinding 

func ForRoleBinding(client kubernetes.Interface, namespace string) Interface

func ForService 

func ForService(client kubernetes.Interface, namespace string) Interface

func ForServiceAccount 

func ForServiceAccount(client kubernetes.Interface, namespace string) Interface

type InterfaceFuncs 

type InterfaceFuncs struct {
	GetFunc          func(ctx context.Context, name string, options metav1.GetOptions) (runtime.Object, error)
	CreateFunc       func(ctx context.Context, obj runtime.Object, options metav1.CreateOptions) (runtime.Object, error)
	UpdateFunc       func(ctx context.Context, obj runtime.Object, options metav1.UpdateOptions) (runtime.Object, error)
	UpdateStatusFunc func(ctx context.Context, obj runtime.Object, options metav1.UpdateOptions) (runtime.Object, error)
	DeleteFunc       func(ctx context.Context, name string, options metav1.DeleteOptions) error
	ListFunc         func(ctx context.Context, options metav1.ListOptions) ([]runtime.Object, error)
}

func ForControllerClient 

func ForControllerClient(client controllerClient.Client, namespace string, objType controllerClient.Object) *InterfaceFuncs

func ForDynamic 

func ForDynamic(client dynamic.ResourceInterface) *InterfaceFuncs

func ForListableControllerClient 

func ForListableControllerClient(client controllerClient.Client, namespace string, objType controllerClient.Object,
	listType controllerClient.ObjectList,
) *InterfaceFuncs

func (*InterfaceFuncs) Create 

func (i *InterfaceFuncs) Create(ctx context.Context, obj runtime.Object, options metav1.CreateOptions) (runtime.Object, error)

func (*InterfaceFuncs) Delete 

func (i *InterfaceFuncs) Delete(ctx context.Context, name string,
	options metav1.DeleteOptions,
) error

func (*InterfaceFuncs) Get 

func (i *InterfaceFuncs) Get(ctx context.Context, name string, options metav1.GetOptions) (runtime.Object, error)

func (*InterfaceFuncs) List 

func (i *InterfaceFuncs) List(ctx context.Context, options metav1.ListOptions) ([]runtime.Object, error)

func (*InterfaceFuncs) Update 

func (i *InterfaceFuncs) Update(ctx context.Context, obj runtime.Object, options metav1.UpdateOptions) (runtime.Object, error)

func (*InterfaceFuncs) UpdateStatus 

func (i *InterfaceFuncs) UpdateStatus(ctx context.Context, obj runtime.Object, options metav1.UpdateOptions) (runtime.Object, error)

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.