v1alpha2

Documentation

Index

• func FromProfileHandlerToHandler(sync ProfileHandler) generic.Handler
• func FromSecretHandlerToHandler(sync SecretHandler) generic.Handler
• func RegisterSecretGeneratingHandler(ctx context.Context, controller SecretController, apply apply.Apply, ...)
• func RegisterSecretStatusHandler(ctx context.Context, controller SecretController, condition condition.Cond, ...)
• func UpdateProfileDeepCopyOnChange(client ProfileClient, obj *v1alpha2.Profile, ...) (*v1alpha2.Profile, error)
• func UpdateSecretDeepCopyOnChange(client SecretClient, obj *v1alpha2.Secret, ...) (*v1alpha2.Secret, error)
• type Interface
  • func New(controllerFactory controller.SharedControllerFactory) Interface
• type ProfileCache
• type ProfileClient
• type ProfileController
  • func NewProfileController(gvk schema.GroupVersionKind, resource string, namespaced bool, ...) ProfileController
• type ProfileHandler
• type ProfileIndexer
• type SecretCache
• type SecretClient
• type SecretController
  • func NewSecretController(gvk schema.GroupVersionKind, resource string, namespaced bool, ...) SecretController
• type SecretGeneratingHandler
• type SecretHandler
• type SecretIndexer
• type SecretStatusHandler

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