kubernetes

Documentation

Index

• Constants
• func Apply(ctx context.Context, obj Object, changedBy, changeReason string, ...) (runtime.Object, error)
• func AttachSharedInformer[TObj Object](ctx context.Context, indexers cache.Indexers) (informers.GenericInformer, error)
• func Client(ctx context.Context, gvk schema.GroupVersionKind, namespace string) (dynamic.ResourceInterface, bool, error)
• func ClientForObject(ctx context.Context, obj runtime.Object, namespace string) (dynamic.ResourceInterface, schema.GroupVersionKind, bool, error)
• func Delete(ctx context.Context, gvk schema.GroupVersionKind, namespace string, ...) error
• func DeleteObject(ctx context.Context, obj Object) error
• func DspLabel(name string) string
• func EnableSharedInformer(ctx context.Context, resyncDuration time.Duration, namespace string) context.Context
• func Get(ctx context.Context, gvk schema.GroupVersionKind, namespace string, ...) (runtime.Object, error)
• func GetObject(ctx context.Context, obj Object) error
• func GroupVersionKindForObject(obj runtime.Object) (schema.GroupVersionKind, error)
• func IsDspLabel(label string) bool
• func IsPvcResizingError(err error) bool
• func Watch(ctx context.Context, gvk schema.GroupVersionKind, namespace string, ...) (watch.Interface, error)
• type Object
• type PodReference
  • func GetCurrentPodReference() (*PodReference, error)

Constants

const DspKubernetesLabelDomain = "tiki-dsp.io"

const DspKubernetesLabelPrefix = DspKubernetesLabelDomain + "/"

const DspNamespaceEnv = "DSP_NAMESPACE"

const DspPodEnv = "DSP_POD"

Functions

func Apply

func Apply(ctx context.Context, obj Object, changedBy, changeReason string, forceOverwrite bool) (runtime.Object, error)

func AttachSharedInformer

func AttachSharedInformer[TObj Object](ctx context.Context, indexers cache.Indexers) (informers.GenericInformer, error)

AttachSharedInformer creates a new informer instance located in the given context Shared informers do support custom indexing whilst attaching the first time. Calling AttachSharedInformer multiple times for the same resource using different cache.Indexers will use the indexers provided with the first call; all others will be ignored

func Client

func Client(ctx context.Context, gvk schema.GroupVersionKind, namespace string) (dynamic.ResourceInterface, bool, error)

func ClientForObject

func ClientForObject(ctx context.Context, obj runtime.Object, namespace string) (dynamic.ResourceInterface, schema.GroupVersionKind, bool, error)

func Delete

func Delete(ctx context.Context, gvk schema.GroupVersionKind, namespace string, name string) error

func DeleteObject

func DeleteObject(ctx context.Context, obj Object) error

func DspLabel

func DspLabel(name string) string

func EnableSharedInformer

func EnableSharedInformer(ctx context.Context, resyncDuration time.Duration, namespace string) context.Context

EnableSharedInformer connects a shared informer factory to the given context

func Get

func Get(ctx context.Context, gvk schema.GroupVersionKind, namespace string, name string) (runtime.Object, error)

func GetObject

func GetObject(ctx context.Context, obj Object) error

func GroupVersionKindForObject

func GroupVersionKindForObject(obj runtime.Object) (schema.GroupVersionKind, error)

func IsDspLabel

func IsDspLabel(label string) bool

func IsPvcResizingError

func IsPvcResizingError(err error) bool

func Watch

func Watch(ctx context.Context, gvk schema.GroupVersionKind, namespace string, options metaV1.ListOptions) (watch.Interface, error)

Types

type Object

type Object interface {
	metaV1.Object
	runtime.Object
}

type PodReference

type PodReference struct {
	Namespace string `json:"namespace"`
	Pod       string `json:"pod"`
}

func GetCurrentPodReference

func GetCurrentPodReference() (*PodReference, error)