kube

package
v1.0.0 Latest Latest
Warning

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

 Go to latest Published: Feb 7, 2025 License: Apache-2.0 Imports: 41 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var DefaultResyncTime = 10 * time.Hour

Functions

func Apply 

func Apply[T client.Object](ctx context.Context, config *rest.Config, resources []T, options ...Option) error

func AutoClientConfig 

func AutoClientConfig() (*rest.Config, error)

AutoClientConfig 自动获取当前环境 restConfig

func CreateByYamlOrJson 

func CreateByYamlOrJson(ctx context.Context, cfg *rest.Config, yamlOrJson []byte) error

func CreatePatchContent 

func CreatePatchContent(origin, modified interface{}) ([]byte, error)

func DefaultClientConfig 

func DefaultClientConfig() clientcmd.ClientConfig

DefaultClientConfig read config from kubeconfig or incluster config as fallback It read config from KUBECONFIG environment file or default kubeconfig file or in cluster config. https://github.com/kubernetes/client-go/blob/cab7ba1d4a523956b6395dcbe38620159ac43fef/tools/clientcmd/loader.go#L143-L152

func DeleteByYamlOrJson 

func DeleteByYamlOrJson(ctx context.Context, cfg *rest.Config, yamlOrJson []byte) error

func FieldIndexName 

func FieldIndexName(field string) string

FieldIndexName constructs the name of the index over the given field, for use with an indexer.

func FillGVK 

func FillGVK(object client.Object, scheme *runtime.Scheme) error

func GetKubeClient 

func GetKubeClient(kubeconfig []byte) (*rest.Config, *kubernetes.Clientset, error)

func GetKubeRestConfig 

func GetKubeRestConfig(kubeconfig []byte) (*rest.Config, error)

func GetKubeconfigInfos 

func GetKubeconfigInfos(kubeconfig []byte) (apiserver string, cert, key, ca []byte, err error)

func KeyToNamespacedKey 

func KeyToNamespacedKey(ns string, baseKey string) string

KeyToNamespacedKey prefixes the given index key with a namespace for use in field selector indexes.

func LocalNamespaceOrDefault 

func LocalNamespaceOrDefault(def string) string

LocalNamespace return namespace of default namespace of the kubeconfig or current pod namespace Out of cluster: It read from kubeconfig default context namespace. On cluster: It read from POD_NAMESPACE environment or the serviceaccount namespace file. https://github.com/kubernetes/client-go/blob/cab7ba1d4a523956b6395dcbe38620159ac43fef/tools/clientcmd/client_config.go#L581-L596

func NewCacheReaderFor 

func NewCacheReaderFor(ctx context.Context, cli client.Client,
	gvk schema.GroupVersionKind, eventhandler cache.ResourceEventHandler,
	listoptions ...client.ListOption,
) (client.Reader, error)

func NewClient 

func NewClient(config *rest.Config) (client.Client, error)

func NewListOf 

func NewListOf(gvk schema.GroupVersionKind, scheme *runtime.Scheme) client.ObjectList

func NewLocalClient 

func NewLocalClient() (client.WithWatch, error)

func ParseResource 

func ParseResource(raw []byte) ([]*unstructured.Unstructured, error)

func PortForward 

func PortForward(ctx context.Context, config *rest.Config, namespace string, podLabelSelector string, targetPort int) (int, error)

func Remove 

func Remove[T client.Object](ctx context.Context, config *rest.Config, resources []T, options ...Option) error

func RequiresExactMatch 

func RequiresExactMatch(sel fields.Selector) (field, val string, required bool)

RequiresExactMatch checks if the given field selector is of the form `k=v` or `k==v`.

Types

type CacheClient 

type CacheClient struct {
	client.Client
	// contains filtered or unexported fields
}

func NewCachedClient 

func NewCachedClient(ctx context.Context, cli client.Client, eventhandler cache.ResourceEventHandler) *CacheClient

func (*CacheClient) Get 

func (m *CacheClient) Get(ctx context.Context, key client.ObjectKey, obj client.Object) error

func (*CacheClient) List 

func (m *CacheClient) List(ctx context.Context, list client.ObjectList, opts ...client.ListOption) error

type CacheReader 

type CacheReader struct {
	// contains filtered or unexported fields
}

CacheReader is a Reader that reads from a informer cache. See: https://github.com/kubernetes-sigs/controller-runtime/blob/9489eb5b6c7733d1755ed18330876c3a8e364058/pkg/cache/internal/cache_reader.go#L39 CacheReader wraps a cache.Index to implement the client.CacheReader interface for a single type.

func NewCacheReader 

func NewCacheReader(indexer cache.Indexer, gvk schema.GroupVersionKind, scopeName apimeta.RESTScopeName, disableDeepCopy bool) *CacheReader

func (*CacheReader) Get 

func (c *CacheReader) Get(_ context.Context, key client.ObjectKey, out client.Object) error

Get checks the indexer for the object and writes a copy of it if found.

func (*CacheReader) List 

func (c *CacheReader) List(_ context.Context, out client.ObjectList, opts ...client.ListOption) error

List lists items out of the indexer and writes them to out.

type JsonPatchType 

type JsonPatchType struct {
	From client.Object
}

func (*JsonPatchType) Data 

func (j *JsonPatchType) Data(obj client.Object) ([]byte, error)

Data is the raw data representing the patch.

func (*JsonPatchType) Type 

func (j *JsonPatchType) Type() types.PatchType

Type is the PatchType of the patch.

type NoopClient 

type NoopClient struct{}

func (NoopClient) Create 

func (NoopClient) Create(ctx context.Context, obj client.Object, opts ...client.CreateOption) error

Create saves the object obj in the Kubernetes cluster.

func (NoopClient) Delete 

func (NoopClient) Delete(ctx context.Context, obj client.Object, opts ...client.DeleteOption) error

Delete deletes the given obj from Kubernetes cluster.

func (NoopClient) DeleteAllOf 

func (NoopClient) DeleteAllOf(ctx context.Context, obj client.Object, opts ...client.DeleteAllOfOption) error

DeleteAllOf deletes all objects of the given type matching the given options.

func (NoopClient) Get 

func (NoopClient) Get(ctx context.Context, key client.ObjectKey, obj client.Object) error

Get retrieves an obj for the given object key from the Kubernetes Cluster. obj must be a struct pointer so that obj can be updated with the response returned by the Server.

func (NoopClient) List 

func (NoopClient) List(ctx context.Context, list client.ObjectList, opts ...client.ListOption) error

List retrieves list of objects for a given namespace and list options. On a successful call, Items field in the list will be populated with the result returned from the server.

func (NoopClient) Patch 

func (NoopClient) Patch(ctx context.Context, obj client.Object, patch client.Patch, opts ...client.PatchOption) error

Patch patches the given obj in the Kubernetes cluster. obj must be a struct pointer so that obj can be updated with the content returned by the Server.

func (NoopClient) RESTMapper 

func (NoopClient) RESTMapper() meta.RESTMapper

RESTMapper returns the rest this client is using.

func (NoopClient) Scheme 

func (NoopClient) Scheme() *runtime.Scheme

Scheme returns the scheme this client is using.

func (NoopClient) Status 

func (c NoopClient) Status() client.StatusWriter

func (NoopClient) Update 

func (NoopClient) Update(ctx context.Context, obj client.Object, opts ...client.UpdateOption) error

Update updates the given obj in the Kubernetes cluster. obj must be a struct pointer so that obj can be updated with the content returned by the Server.

type Option 

type Option func(*Options)

func WithCreateNamespace 

func WithCreateNamespace() Option

type Options 

type Options struct {
	CreateNamespace bool `json:"createNamespace,omitempty"`
}

Source Files

View all Source files

Directories

Path Synopsis

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.