kubernetes

Documentation

Index

• func NewKubernetesRuntime(resource *apiv1.Resource) (runtime.Runtime, error)
• type KubernetesRuntime
  • func (k *KubernetesRuntime) Apply(ctx context.Context, request *runtime.ApplyRequest) *runtime.ApplyResponse
  • func (k *KubernetesRuntime) Delete(ctx context.Context, request *runtime.DeleteRequest) *runtime.DeleteResponse
  • func (k *KubernetesRuntime) Import(ctx context.Context, request *runtime.ImportRequest) *runtime.ImportResponse
  • func (k *KubernetesRuntime) Read(ctx context.Context, request *runtime.ReadRequest) *runtime.ReadResponse
  • func (k *KubernetesRuntime) Watch(ctx context.Context, request *runtime.WatchRequest) *runtime.WatchResponse
  • func (k *KubernetesRuntime) WatchByRelation(ctx context.Context, cur *unstructured.Unstructured, ...) (<-chan k8swatch.Event, *unstructured.Unstructured, error)
  • func (k *KubernetesRuntime) WatchBySelector(ctx context.Context, o *unstructured.Unstructured, gvk schema.GroupVersionKind, ...) (<-chan k8swatch.Event, error)

Functions

func NewKubernetesRuntime

func NewKubernetesRuntime(resource *apiv1.Resource) (runtime.Runtime, error)

NewKubernetesRuntime create a new KubernetesRuntime

Types

type KubernetesRuntime

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

func (*KubernetesRuntime) Apply

func (k *KubernetesRuntime) Apply(ctx context.Context, request *runtime.ApplyRequest) *runtime.ApplyResponse

Apply kubernetes Resource by client-go

func (*KubernetesRuntime) Delete

func (k *KubernetesRuntime) Delete(ctx context.Context, request *runtime.DeleteRequest) *runtime.DeleteResponse

Delete kubernetes Resource by client-go

func (*KubernetesRuntime) Import

func (k *KubernetesRuntime) Import(ctx context.Context, request *runtime.ImportRequest) *runtime.ImportResponse

Import already exist kubernetes Resource

func (*KubernetesRuntime) Read

func (k *KubernetesRuntime) Read(ctx context.Context, request *runtime.ReadRequest) *runtime.ReadResponse

Read kubernetes Resource by client-go

func (*KubernetesRuntime) Watch

func (k *KubernetesRuntime) Watch(ctx context.Context, request *runtime.WatchRequest) *runtime.WatchResponse

Watch kubernetes resource by client-go

func (*KubernetesRuntime) WatchByRelation

func (k *KubernetesRuntime) WatchByRelation(
	ctx context.Context,
	cur *unstructured.Unstructured,
	gvk schema.GroupVersionKind,
	related func(watched, cur *unstructured.Unstructured) bool,
) (<-chan k8swatch.Event, *unstructured.Unstructured, error)

WatchByRelation watched resources by giving gvk if related() return true

func (*KubernetesRuntime) WatchBySelector

func (k *KubernetesRuntime) WatchBySelector(
	ctx context.Context,
	o *unstructured.Unstructured,
	gvk schema.GroupVersionKind,
	id, labelStr string,
) (<-chan k8swatch.Event, error)

WatchBySelector watch resources by gvk and filter by selector