kubernetes

package

v1.4.13 Latest Latest Go to latest Published: Jul 19, 2023 License: Apache-2.0 Imports: 17 Imported by: 8

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/RHsyseng/operator-utils

Links

Open Source Insights

Documentation ¶

Index ¶

func CustomResourceDefinitionExists(gvk schema.GroupVersionKind) error
type ExtendedReconciler
- func NewExtendedReconciler(service PlatformService, reconciler reconcile.Reconciler, ...) ExtendedReconciler
type Finalizer
type KubernetesPlatformService
- func GetInstance(mgr manager.Manager) KubernetesPlatformService
type PlatformService

Constants ¶

This section is empty.

Variables ¶

This section is empty.

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 ¶ added in v1.4.5

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 ...

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL