resource

Documentation

Overview

Package resource provides a general CRUD interface for Kubernetes resources.

Index

• func BuildRestConfigFromData(apiServer, apiServerToken, caData string, tls *rest.TLSClientConfig) (*rest.Config, error)
• func BuildRestConfigFromFiles(apiServer, apiServerTokenFile, caFile string, tls *rest.TLSClientConfig) *rest.Config
• func EnsureValidName(name string) string
• func GetAuthorizedRestConfigFromData(apiServer, apiServerToken, caData string, tls *rest.TLSClientConfig, ...) (restConfig *rest.Config, authorized bool, err error)
• func GetAuthorizedRestConfigFromFiles(apiServer, apiServerTokenFile, caFile string, tls *rest.TLSClientConfig, ...) (restConfig *rest.Config, authorized bool, err error)
• func IsAuthorizedFor(restConfig *rest.Config, gvr schema.GroupVersionResource, namespace string) (bool, error)
• func IsUnknownAuthorityError(err error) bool
• func ToMeta(obj runtime.Object) metav1.Object
• func ToUnstructured(from runtime.Object) (*unstructured.Unstructured, error)
• type Interface
  • func ForClusterRole(client kubernetes.Interface) Interface
  • func ForClusterRoleBinding(client kubernetes.Interface) Interface
  • func ForConfigMap(client kubernetes.Interface, namespace string) Interface
  • func ForControllerClient(client controllerClient.Client, namespace string, ...) Interface
  • func ForDaemonSet(client kubernetes.Interface, namespace string) Interface
  • func ForDeployment(client kubernetes.Interface, namespace string) Interface
  • func ForDynamic(client dynamic.ResourceInterface) Interface
  • func ForNamespace(client kubernetes.Interface) Interface
  • func ForPod(client kubernetes.Interface, namespace string) Interface
  • func ForRole(client kubernetes.Interface, namespace string) Interface
  • func ForRoleBinding(client kubernetes.Interface, namespace string) Interface
  • func ForService(client kubernetes.Interface, namespace string) Interface
  • func ForServiceAccount(client kubernetes.Interface, namespace string) Interface
• type InterfaceFuncs
  • func (i *InterfaceFuncs) Create(ctx context.Context, obj runtime.Object, options metav1.CreateOptions) (runtime.Object, error)
  • func (i *InterfaceFuncs) Delete(ctx context.Context, name string, options metav1.DeleteOptions) error
  • func (i *InterfaceFuncs) Get(ctx context.Context, name string, options metav1.GetOptions) (runtime.Object, error)
  • func (i *InterfaceFuncs) Update(ctx context.Context, obj runtime.Object, options metav1.UpdateOptions) (runtime.Object, error)

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 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 IsUnknownAuthorityError

func IsUnknownAuthorityError(err error) bool

func ToMeta

func ToMeta(obj runtime.Object) metav1.Object

func ToUnstructured

func ToUnstructured(from runtime.Object) (*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)
	Delete(ctx context.Context, name string, options metav1.DeleteOptions) 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 ForControllerClient

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

func ForDaemonSet

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

func ForDeployment

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

func ForDynamic

func ForDynamic(client dynamic.ResourceInterface) 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)
	DeleteFunc func(ctx context.Context, name string, options metav1.DeleteOptions) error
}

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) Update

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