client

Documentation

Index

• Constants
• func GetClientConfig(kc string) (*rest.Config, error)
• func IsRunningInKubernetes() bool
• func ListWithPages[T metav1.ListInterface](pageSize int, list listFunc[T], ctx context.Context, opts metav1.ListOptions, ...) error
• type ClusterDetails
  • func GetCurrentClusterDetails(kc string) ClusterDetails
• type KubernetesClientFromCacheWithAPIFallback
  • func NewKubernetesClientFromCacheWithAPIFallback(cache client.Client, apiServer client.Reader) *KubernetesClientFromCacheWithAPIFallback
  • func (k *KubernetesClientFromCacheWithAPIFallback) Create(ctx context.Context, obj client.Object, opts ...client.CreateOption) error
  • func (k *KubernetesClientFromCacheWithAPIFallback) Delete(ctx context.Context, obj client.Object, opts ...client.DeleteOption) error
  • func (k *KubernetesClientFromCacheWithAPIFallback) DeleteAllOf(ctx context.Context, obj client.Object, opts ...client.DeleteAllOfOption) error
  • func (k *KubernetesClientFromCacheWithAPIFallback) Get(ctx context.Context, key client.ObjectKey, obj client.Object, ...) error
  • func (k *KubernetesClientFromCacheWithAPIFallback) GroupVersionKindFor(obj runtime.Object) (schema.GroupVersionKind, error)
  • func (k *KubernetesClientFromCacheWithAPIFallback) IsObjectNamespaced(obj runtime.Object) (bool, error)
  • func (k *KubernetesClientFromCacheWithAPIFallback) List(ctx context.Context, list client.ObjectList, opts ...client.ListOption) error
  • func (k *KubernetesClientFromCacheWithAPIFallback) Patch(ctx context.Context, obj client.Object, patch client.Patch, ...) error
  • func (k *KubernetesClientFromCacheWithAPIFallback) RESTMapper() meta.RESTMapper
  • func (k *KubernetesClientFromCacheWithAPIFallback) Scheme() *runtime.Scheme
  • func (k *KubernetesClientFromCacheWithAPIFallback) Status() client.SubResourceWriter
  • func (k *KubernetesClientFromCacheWithAPIFallback) SubResource(subResource string) client.SubResourceClient
  • func (k *KubernetesClientFromCacheWithAPIFallback) Update(ctx context.Context, obj client.Object, opts ...client.UpdateOption) error

Constants

const DefaultPageSize = 500

Functions

func GetClientConfig

func GetClientConfig(kc string) (*rest.Config, error)

func IsRunningInKubernetes

func IsRunningInKubernetes() bool

func ListWithPages

func ListWithPages[T metav1.ListInterface](pageSize int, list listFunc[T], ctx context.Context, opts metav1.ListOptions, handler func(obj T) error) error

Types

type ClusterDetails

type ClusterDetails struct {
	CurrentContext string
	ClusterName    string
	ServerEndpoint string
}

func GetCurrentClusterDetails

func GetCurrentClusterDetails(kc string) ClusterDetails

type KubernetesClientFromCacheWithAPIFallback

type KubernetesClientFromCacheWithAPIFallback struct {
	Cache     client.Client
	APIServer client.Reader
}

func NewKubernetesClientFromCacheWithAPIFallback

func NewKubernetesClientFromCacheWithAPIFallback(cache client.Client, apiServer client.Reader) *KubernetesClientFromCacheWithAPIFallback

func (*KubernetesClientFromCacheWithAPIFallback) Create

func (k *KubernetesClientFromCacheWithAPIFallback) Create(ctx context.Context, obj client.Object, opts ...client.CreateOption) error

func (*KubernetesClientFromCacheWithAPIFallback) Delete

func (k *KubernetesClientFromCacheWithAPIFallback) Delete(ctx context.Context, obj client.Object, opts ...client.DeleteOption) error

func (*KubernetesClientFromCacheWithAPIFallback) DeleteAllOf

func (k *KubernetesClientFromCacheWithAPIFallback) DeleteAllOf(ctx context.Context, obj client.Object, opts ...client.DeleteAllOfOption) error

func (*KubernetesClientFromCacheWithAPIFallback) Get

func (k *KubernetesClientFromCacheWithAPIFallback) Get(ctx context.Context, key client.ObjectKey, obj client.Object, opts ...client.GetOption) error

func (*KubernetesClientFromCacheWithAPIFallback) GroupVersionKindFor

func (k *KubernetesClientFromCacheWithAPIFallback) GroupVersionKindFor(obj runtime.Object) (schema.GroupVersionKind, error)

func (*KubernetesClientFromCacheWithAPIFallback) IsObjectNamespaced

func (k *KubernetesClientFromCacheWithAPIFallback) IsObjectNamespaced(obj runtime.Object) (bool, error)

func (*KubernetesClientFromCacheWithAPIFallback) List

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

func (*KubernetesClientFromCacheWithAPIFallback) Patch

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

func (*KubernetesClientFromCacheWithAPIFallback) RESTMapper

func (k *KubernetesClientFromCacheWithAPIFallback) RESTMapper() meta.RESTMapper

func (*KubernetesClientFromCacheWithAPIFallback) Scheme

func (k *KubernetesClientFromCacheWithAPIFallback) Scheme() *runtime.Scheme

func (*KubernetesClientFromCacheWithAPIFallback) Status

func (k *KubernetesClientFromCacheWithAPIFallback) Status() client.SubResourceWriter

func (*KubernetesClientFromCacheWithAPIFallback) SubResource

func (k *KubernetesClientFromCacheWithAPIFallback) SubResource(subResource string) client.SubResourceClient

func (*KubernetesClientFromCacheWithAPIFallback) Update

func (k *KubernetesClientFromCacheWithAPIFallback) Update(ctx context.Context, obj client.Object, opts ...client.UpdateOption) error