kubernetes

Documentation

Index

• func CustomResourceDefinitionExists(gvk schema.GroupVersionKind) error
• type ExtendedReconciler
  • func NewExtendedReconciler(service PlatformService, reconciler reconcile.Reconciler, ...) ExtendedReconciler
  • func (e *ExtendedReconciler) Reconcile(request reconcile.Request) (reconcile.Result, error)
  • func (e *ExtendedReconciler) RegisterFinalizer(f Finalizer) error
  • func (e *ExtendedReconciler) UnregisterFinalizer(finalizer string) error
• type Finalizer
• type KubernetesPlatformService
  • func GetInstance(mgr manager.Manager) KubernetesPlatformService
  • func (service *KubernetesPlatformService) Create(ctx context.Context, obj clientv1.Object, opts ...clientv1.CreateOption) error
  • func (service *KubernetesPlatformService) Delete(ctx context.Context, obj clientv1.Object, opts ...clientv1.DeleteOption) error
  • func (service *KubernetesPlatformService) DeleteAllOf(ctx context.Context, obj clientv1.Object, opts ...clientv1.DeleteAllOfOption) error
  • func (service *KubernetesPlatformService) Get(ctx context.Context, key clientv1.ObjectKey, obj clientv1.Object) error
  • func (service *KubernetesPlatformService) GetCached(ctx context.Context, key clientv1.ObjectKey, obj clientv1.Object) error
  • func (service *KubernetesPlatformService) GetScheme() *runtime.Scheme
  • func (service *KubernetesPlatformService) ImageStreamTags(namespace string) imagev1.ImageStreamTagInterface
  • func (service *KubernetesPlatformService) IsMockService() bool
  • func (service *KubernetesPlatformService) List(ctx context.Context, list clientv1.ObjectList, opts ...clientv1.ListOption) error
  • func (service *KubernetesPlatformService) Patch(ctx context.Context, obj clientv1.Object, patch clientv1.Patch, ...) error
  • func (service *KubernetesPlatformService) Status() clientv1.StatusWriter
  • func (service *KubernetesPlatformService) Update(ctx context.Context, obj clientv1.Object, opts ...clientv1.UpdateOption) error
• type PlatformService

Functions

func CustomResourceDefinitionExists

func CustomResourceDefinitionExists(gvk schema.GroupVersionKind) error

Types

type ExtendedReconciler

type ExtendedReconciler struct {
	Service    PlatformService
	Reconciler reconcile.Reconciler
	Resource   client.Object
	Finalizers map[string]Finalizer
}

func NewExtendedReconciler

func NewExtendedReconciler(service PlatformService, reconciler reconcile.Reconciler, resource client.Object) ExtendedReconciler

func (*ExtendedReconciler) Reconcile

func (e *ExtendedReconciler) Reconcile(request reconcile.Request) (reconcile.Result, error)

func (*ExtendedReconciler) RegisterFinalizer

func (e *ExtendedReconciler) RegisterFinalizer(f Finalizer) error

func (*ExtendedReconciler) UnregisterFinalizer

func (e *ExtendedReconciler) UnregisterFinalizer(finalizer string) error

type Finalizer

type Finalizer interface {
	GetName() string
	OnFinalize(owner client.Object, service PlatformService) error
}

type KubernetesPlatformService

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

func GetInstance

func GetInstance(mgr manager.Manager) KubernetesPlatformService

func (*KubernetesPlatformService) Create

func (service *KubernetesPlatformService) Create(ctx context.Context, obj clientv1.Object, opts ...clientv1.CreateOption) error

func (*KubernetesPlatformService) Delete

func (service *KubernetesPlatformService) Delete(ctx context.Context, obj clientv1.Object, opts ...clientv1.DeleteOption) error

func (*KubernetesPlatformService) DeleteAllOf

func (service *KubernetesPlatformService) DeleteAllOf(ctx context.Context, obj clientv1.Object, opts ...clientv1.DeleteAllOfOption) error

func (*KubernetesPlatformService) Get

func (service *KubernetesPlatformService) Get(ctx context.Context, key clientv1.ObjectKey, obj clientv1.Object) error

func (*KubernetesPlatformService) GetCached

func (service *KubernetesPlatformService) GetCached(ctx context.Context, key clientv1.ObjectKey, obj clientv1.Object) error

func (*KubernetesPlatformService) GetScheme

func (service *KubernetesPlatformService) GetScheme() *runtime.Scheme

func (*KubernetesPlatformService) ImageStreamTags

func (service *KubernetesPlatformService) ImageStreamTags(namespace string) imagev1.ImageStreamTagInterface

func (*KubernetesPlatformService) IsMockService

func (service *KubernetesPlatformService) IsMockService() bool

func (*KubernetesPlatformService) List

func (service *KubernetesPlatformService) List(ctx context.Context, list clientv1.ObjectList, opts ...clientv1.ListOption) error

func (*KubernetesPlatformService) Patch

func (service *KubernetesPlatformService) Patch(ctx context.Context, obj clientv1.Object, patch clientv1.Patch, opts ...clientv1.PatchOption) error

func (*KubernetesPlatformService) Status

func (service *KubernetesPlatformService) Status() clientv1.StatusWriter

func (*KubernetesPlatformService) Update

func (service *KubernetesPlatformService) Update(ctx context.Context, obj clientv1.Object, opts ...clientv1.UpdateOption) error

type PlatformService

type PlatformService interface {
	Create(ctx context.Context, obj client.Object, opts ...client.CreateOption) error
	Delete(ctx context.Context, obj client.Object, opts ...client.DeleteOption) error
	Get(ctx context.Context, key client.ObjectKey, obj client.Object) error
	List(ctx context.Context, list client.ObjectList, opts ...client.ListOption) error
	Update(ctx context.Context, obj client.Object, opts ...client.UpdateOption) error
	Patch(ctx context.Context, obj client.Object, patch client.Patch, opts ...client.PatchOption) error
	DeleteAllOf(ctx context.Context, obj client.Object, opts ...client.DeleteAllOfOption) error
	GetCached(ctx context.Context, key client.ObjectKey, obj client.Object) error
	ImageStreamTags(namespace string) imagev1.ImageStreamTagInterface
	GetScheme() *runtime.Scheme
	Status() client.StatusWriter
	IsMockService() bool
}

PlatformService ...