Documentation ¶
Index ¶
- func NewKubernetesRuntime(spec apiv1.Spec) (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, ...) ([]KubernetesWatchEvent, error)
- type KubernetesWatchEvent
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
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, amount int, related func(watched, cur *unstructured.Unstructured) bool, ) ([]KubernetesWatchEvent, error)
WatchByRelation watched resources by giving gvk if related() return true
type KubernetesWatchEvent ¶ added in v0.13.0
type KubernetesWatchEvent struct { Event <-chan k8swatch.Event Resource *unstructured.Unstructured }
KubernetesWatchEvent is a wrapper of k8swatch.Event
Click to show internal directories.
Click to hide internal directories.