v1alpha2

package
v1.1.6 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Apr 4, 2024 License: Apache-2.0 Imports: 21 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func FromProfileHandlerToHandler 

func FromProfileHandlerToHandler(sync ProfileHandler) generic.Handler

func FromSecretHandlerToHandler 

func FromSecretHandlerToHandler(sync SecretHandler) generic.Handler

func RegisterSecretGeneratingHandler 

func RegisterSecretGeneratingHandler(ctx context.Context, controller SecretController, apply apply.Apply,
	condition condition.Cond, name string, handler SecretGeneratingHandler, opts *generic.GeneratingHandlerOptions)

RegisterSecretGeneratingHandler configures a SecretController to execute a SecretGeneratingHandler for every events observed, passing the returned objects to the provided apply.Apply. If a non-empty condition is provided, it will be updated in the status conditions for every handler execution

func RegisterSecretStatusHandler 

func RegisterSecretStatusHandler(ctx context.Context, controller SecretController, condition condition.Cond, name string, handler SecretStatusHandler)

RegisterSecretStatusHandler configures a SecretController to execute a SecretStatusHandler for every events observed. If a non-empty condition is provided, it will be updated in the status conditions for every handler execution

func UpdateProfileDeepCopyOnChange 

func UpdateProfileDeepCopyOnChange(client ProfileClient, obj *v1alpha2.Profile, handler func(obj *v1alpha2.Profile) (*v1alpha2.Profile, error)) (*v1alpha2.Profile, error)

func UpdateSecretDeepCopyOnChange 

func UpdateSecretDeepCopyOnChange(client SecretClient, obj *v1alpha2.Secret, handler func(obj *v1alpha2.Secret) (*v1alpha2.Secret, error)) (*v1alpha2.Secret, error)

Types

type Interface 

type Interface interface {
	Profile() ProfileController
	Secret() SecretController
}

func New 

func New(controllerFactory controller.SharedControllerFactory) Interface

type ProfileCache 

type ProfileCache interface {
	Get(namespace, name string) (*v1alpha2.Profile, error)
	List(namespace string, selector labels.Selector) ([]*v1alpha2.Profile, error)

	AddIndexer(indexName string, indexer ProfileIndexer)
	GetByIndex(indexName, key string) ([]*v1alpha2.Profile, error)
}

type ProfileClient 

type ProfileClient interface {
	Create(*v1alpha2.Profile) (*v1alpha2.Profile, error)
	Update(*v1alpha2.Profile) (*v1alpha2.Profile, error)

	Delete(namespace, name string, options *metav1.DeleteOptions) error
	Get(namespace, name string, options metav1.GetOptions) (*v1alpha2.Profile, error)
	List(namespace string, opts metav1.ListOptions) (*v1alpha2.ProfileList, error)
	Watch(namespace string, opts metav1.ListOptions) (watch.Interface, error)
	Patch(namespace, name string, pt types.PatchType, data []byte, subresources ...string) (result *v1alpha2.Profile, err error)
}

type ProfileController 

type ProfileController interface {
	generic.ControllerMeta
	ProfileClient

	OnChange(ctx context.Context, name string, sync ProfileHandler)
	OnRemove(ctx context.Context, name string, sync ProfileHandler)
	Enqueue(namespace, name string)
	EnqueueAfter(namespace, name string, duration time.Duration)

	Cache() ProfileCache
}

func NewProfileController 

func NewProfileController(gvk schema.GroupVersionKind, resource string, namespaced bool, controller controller.SharedControllerFactory) ProfileController

type ProfileHandler 

type ProfileHandler func(string, *v1alpha2.Profile) (*v1alpha2.Profile, error)

type ProfileIndexer 

type ProfileIndexer func(obj *v1alpha2.Profile) ([]string, error)

type SecretCache 

type SecretCache interface {
	Get(namespace, name string) (*v1alpha2.Secret, error)
	List(namespace string, selector labels.Selector) ([]*v1alpha2.Secret, error)

	AddIndexer(indexName string, indexer SecretIndexer)
	GetByIndex(indexName, key string) ([]*v1alpha2.Secret, error)
}

type SecretClient 

type SecretClient interface {
	Create(*v1alpha2.Secret) (*v1alpha2.Secret, error)
	Update(*v1alpha2.Secret) (*v1alpha2.Secret, error)
	UpdateStatus(*v1alpha2.Secret) (*v1alpha2.Secret, error)
	Delete(namespace, name string, options *metav1.DeleteOptions) error
	Get(namespace, name string, options metav1.GetOptions) (*v1alpha2.Secret, error)
	List(namespace string, opts metav1.ListOptions) (*v1alpha2.SecretList, error)
	Watch(namespace string, opts metav1.ListOptions) (watch.Interface, error)
	Patch(namespace, name string, pt types.PatchType, data []byte, subresources ...string) (result *v1alpha2.Secret, err error)
}

type SecretController 

type SecretController interface {
	generic.ControllerMeta
	SecretClient

	OnChange(ctx context.Context, name string, sync SecretHandler)
	OnRemove(ctx context.Context, name string, sync SecretHandler)
	Enqueue(namespace, name string)
	EnqueueAfter(namespace, name string, duration time.Duration)

	Cache() SecretCache
}

func NewSecretController 

func NewSecretController(gvk schema.GroupVersionKind, resource string, namespaced bool, controller controller.SharedControllerFactory) SecretController

type SecretGeneratingHandler 

type SecretGeneratingHandler func(obj *v1alpha2.Secret, status v1alpha2.SecretStatus) ([]runtime.Object, v1alpha2.SecretStatus, error)

SecretGeneratingHandler is the top-level handler that is executed for every Secret event. It extends SecretStatusHandler by a returning a slice of child objects to be passed to apply.Apply

type SecretHandler 

type SecretHandler func(string, *v1alpha2.Secret) (*v1alpha2.Secret, error)

type SecretIndexer 

type SecretIndexer func(obj *v1alpha2.Secret) ([]string, error)

type SecretStatusHandler 

type SecretStatusHandler func(obj *v1alpha2.Secret, status v1alpha2.SecretStatus) (v1alpha2.SecretStatus, error)

SecretStatusHandler is executed for every added or modified Secret. Should return the new status to be updated

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.