resource

package

Go to main page

Versions in this module

v0

v0.5.0

Feb 13, 2020

v0.4.0

Jan 15, 2020

Changes in this version

+ const AnnotationDelimiter

+ const AnnotationKeyPropagateToPrefix

+ type EnqueueRequestForPropagated struct

+ func (e *EnqueueRequestForPropagated) Create(evt event.CreateEvent, q workqueue.RateLimitingInterface)

+ func (e *EnqueueRequestForPropagated) Delete(evt event.DeleteEvent, q workqueue.RateLimitingInterface)

+ func (e *EnqueueRequestForPropagated) Generic(evt event.GenericEvent, q workqueue.RateLimitingInterface)

+ func (e *EnqueueRequestForPropagated) Update(evt event.UpdateEvent, q workqueue.RateLimitingInterface)

+ type Target interface

+ type TargetKind schema.GroupVersionKind

v0.3.0

Dec 20, 2019

Changes in this version

+ type CredentialsSecretReferencer interface

+ GetCredentialsSecretReference func() v1alpha1.SecretKeySelector

+ SetCredentialsSecretReference func(r v1alpha1.SecretKeySelector)

+ type Provider interface

v0.2.3

Nov 19, 2019

Changes in this version

+ func ConfigureNames(_ context.Context, cm Claim, _ Class, mg Managed) error

+ func ConfigureReclaimPolicy(_ context.Context, _ Claim, cs Class, mg Managed) error

v0.2.2

Nov 14, 2019

v0.2.1

Nov 5, 2019

v0.2.0

Nov 4, 2019

Changes in this version

+ type APIBinder struct

+ func NewAPIBinder(c client.Client, t runtime.ObjectTyper) *APIBinder

+ func (a *APIBinder) Bind(ctx context.Context, cm Claim, mg Managed) error

+ func (a *APIBinder) Unbind(ctx context.Context, _ Claim, mg Managed) error

+ type APIClaimFinalizer struct

+ func NewAPIClaimFinalizer(c client.Client, finalizer string) *APIClaimFinalizer

+ func (a *APIClaimFinalizer) AddFinalizer(ctx context.Context, cm Claim) error

+ func (a *APIClaimFinalizer) RemoveFinalizer(ctx context.Context, cm Claim) error

+ type APIManagedFinalizer struct

+ func NewAPIManagedFinalizer(c client.Client, finalizer string) *APIManagedFinalizer

+ func (a *APIManagedFinalizer) AddFinalizer(ctx context.Context, mg Managed) error

+ func (a *APIManagedFinalizer) RemoveFinalizer(ctx context.Context, mg Managed) error

+ type APIManagedReferenceResolverOption func(*APIManagedReferenceResolver)

+ func WithAttributeReferencerFinder(f AttributeReferencerFinder) APIManagedReferenceResolverOption

+ type APIStatusBinder struct

+ func NewAPIStatusBinder(c client.Client, t runtime.ObjectTyper) *APIStatusBinder

+ func (a *APIStatusBinder) Bind(ctx context.Context, cm Claim, mg Managed) error

+ func (a *APIStatusBinder) Unbind(ctx context.Context, _ Claim, mg Managed) error

+ type AttributeReferencerFinder interface

+ FindReferencers func(obj interface{}) []AttributeReferencer

+ type AttributeReferencerFinderFn func(obj interface{}) []AttributeReferencer

+ func (fn AttributeReferencerFinderFn) FindReferencers(obj interface{}) []AttributeReferencer

+ type Binder interface

+ Bind func(ctx context.Context, cm Claim, mg Managed) error

+ Unbind func(ctx context.Context, cm Claim, mg Managed) error

+ type BinderFns struct

+ BindFn func(ctx context.Context, cm Claim, mg Managed) error

+ UnbindFn func(ctx context.Context, cm Claim, mg Managed) error

+ func (b BinderFns) Bind(ctx context.Context, cm Claim, mg Managed) error

+ func (b BinderFns) Unbind(ctx context.Context, cm Claim, mg Managed) error

type ClaimFinalizer

+ AddFinalizer func(ctx context.Context, cm Claim) error

+ RemoveFinalizer func(ctx context.Context, cm Claim) error

+ type ClaimFinalizerFns struct

+ AddFinalizerFn func(ctx context.Context, cm Claim) error

+ RemoveFinalizerFn func(ctx context.Context, cm Claim) error

+ func (f ClaimFinalizerFns) AddFinalizer(ctx context.Context, mg Claim) error

+ func (f ClaimFinalizerFns) RemoveFinalizer(ctx context.Context, mg Claim) error

type ClaimReconcilerOption

+ func WithBinder(b Binder) ClaimReconcilerOption

type ManagedFinalizer

+ AddFinalizer func(ctx context.Context, cm Managed) error

+ RemoveFinalizer func(ctx context.Context, cm Managed) error

+ type ManagedFinalizerFns struct

+ AddFinalizerFn func(ctx context.Context, cm Managed) error

+ RemoveFinalizerFn func(ctx context.Context, cm Managed) error

+ func (f ManagedFinalizerFns) AddFinalizer(ctx context.Context, mg Managed) error

+ func (f ManagedFinalizerFns) RemoveFinalizer(ctx context.Context, mg Managed) error

type ManagedReconcilerOption

+ func WithManagedReferenceResolver(rr ManagedReferenceResolver) ManagedReconcilerOption

v0.1.0

Oct 26, 2019

Changes in this version

+ const AnnotationKeyPropagateFromName

+ const AnnotationKeyPropagateFromNamespace

+ const AnnotationKeyPropagateFromUID

+ const AnnotationKeyPropagateToName

+ const AnnotationKeyPropagateToNamespace

+ const AnnotationKeyPropagateToUID

+ const ReasonBinding

+ func Binding() v1alpha1.Condition

+ func ConnectionSecretFor(o ConnectionSecretOwner, kind schema.GroupVersionKind) *corev1.Secret

+ func GetKind(obj runtime.Object, ot runtime.ObjectTyper) (schema.GroupVersionKind, error)

+ func Ignore(is ErrorIs, err error) error

+ func IgnoreNotFound(err error) error

+ func IsBindable(b Bindable) bool

+ func IsBound(b Bindable) bool

+ func IsConditionTrue(c v1alpha1.Condition) bool

+ func IsReferencesAccessError(err error) bool

+ func LocalConnectionSecretFor(o LocalConnectionSecretOwner, kind schema.GroupVersionKind) *corev1.Secret

+ func MustCreateObject(kind schema.GroupVersionKind, oc runtime.ObjectCreater) runtime.Object

+ func MustGetKind(obj runtime.Object, ot runtime.ObjectTyper) schema.GroupVersionKind

+ func NewPredicates(fn PredicateFn) predicate.Funcs

+ func NewSecretPropagatingReconciler(m manager.Manager) reconcile.Reconciler

+ func ResolveClassClaimValues(classValue, claimValue string) (string, error)

+ func SetBindable(b Bindable)

+ type APIClaimFinalizerRemover struct

+ func NewAPIClaimFinalizerRemover(c client.Client) *APIClaimFinalizerRemover

+ func (a *APIClaimFinalizerRemover) Finalize(ctx context.Context, cm Claim) error

+ type APIManagedBinder struct

+ func NewAPIManagedBinder(c client.Client, t runtime.ObjectTyper) *APIManagedBinder

+ func (a *APIManagedBinder) Bind(ctx context.Context, cm Claim, mg Managed) error

+ type APIManagedConnectionPropagator struct

+ func NewAPIManagedConnectionPropagator(c client.Client, t runtime.ObjectTyper) *APIManagedConnectionPropagator

+ func (a *APIManagedConnectionPropagator) PropagateConnection(ctx context.Context, cm Claim, mg Managed) error

+ type APIManagedCreator struct

+ func NewAPIManagedCreator(c client.Client, t runtime.ObjectTyper) *APIManagedCreator

+ func (a *APIManagedCreator) Create(ctx context.Context, cm Claim, cs Class, mg Managed) error

+ type APIManagedFinalizerAdder struct

+ func NewAPIManagedFinalizerAdder(c client.Client) *APIManagedFinalizerAdder

+ func (a *APIManagedFinalizerAdder) Initialize(ctx context.Context, mg Managed) error

+ type APIManagedFinalizerRemover struct

+ func NewAPIManagedFinalizerRemover(c client.Client) *APIManagedFinalizerRemover

+ func (a *APIManagedFinalizerRemover) Finalize(ctx context.Context, mg Managed) error

+ type APIManagedReferenceResolver struct

+ func NewAPIManagedReferenceResolver(c client.Client) *APIManagedReferenceResolver

+ func (r *APIManagedReferenceResolver) ResolveReferences(ctx context.Context, res CanReference) (err error)

+ type APIManagedStatusBinder struct

+ func NewAPIManagedStatusBinder(c client.Client, t runtime.ObjectTyper) *APIManagedStatusBinder

+ func (a *APIManagedStatusBinder) Bind(ctx context.Context, cm Claim, mg Managed) error

+ type APIManagedStatusUnbinder struct

+ func NewAPIManagedStatusUnbinder(c client.Client) *APIManagedStatusUnbinder

+ func (a *APIManagedStatusUnbinder) Finalize(ctx context.Context, mg Managed) error

+ type APIManagedUnbinder struct

+ func NewAPIManagedUnbinder(c client.Client) *APIManagedUnbinder

+ func (a *APIManagedUnbinder) Finalize(ctx context.Context, mg Managed) error

+ type APISecretPublisher struct

+ func NewAPISecretPublisher(c client.Client, ot runtime.ObjectTyper) *APISecretPublisher

+ func (a *APISecretPublisher) PublishConnection(ctx context.Context, mg Managed, c ConnectionDetails) error

+ func (a *APISecretPublisher) UnpublishConnection(ctx context.Context, mg Managed, c ConnectionDetails) error

+ type AttributeReferencer interface

+ Assign func(CanReference, string) error

+ Build func(context.Context, CanReference, client.Reader) (string, error)

+ GetStatus func(context.Context, CanReference, client.Reader) ([]ReferenceStatus, error)

+ type Bindable interface

+ GetBindingPhase func() v1alpha1.BindingPhase

+ SetBindingPhase func(p v1alpha1.BindingPhase)

+ type CanReference interface

+ type Claim interface

+ type ClaimDefaultingReconciler struct

+ func NewClaimDefaultingReconciler(m manager.Manager, of ClaimKind, to ClassKind, ...) *ClaimDefaultingReconciler

+ func (r *ClaimDefaultingReconciler) Reconcile(req reconcile.Request) (reconcile.Result, error)

+ type ClaimDefaultingReconcilerOption func(*ClaimDefaultingReconciler)

+ func WithDefaultingJitterer(j Jitterer) ClaimDefaultingReconcilerOption

+ type ClaimFinalizer interface

+ Finalize func(ctx context.Context, cm Claim) error

+ type ClaimFinalizerFn func(ctx context.Context, cm Claim) error

+ func (fn ClaimFinalizerFn) Finalize(ctx context.Context, cm Claim) error

+ type ClaimKind schema.GroupVersionKind

+ type ClaimReconciler struct

+ func NewClaimReconciler(m manager.Manager, of ClaimKind, using ClassKind, with ManagedKind, ...) *ClaimReconciler

+ func (r *ClaimReconciler) Reconcile(req reconcile.Request) (reconcile.Result, error)

+ type ClaimReconcilerOption func(*ClaimReconciler)

+ func WithClaimFinalizer(f ClaimFinalizer) ClaimReconcilerOption

+ func WithManagedBinder(b ManagedBinder) ClaimReconcilerOption

+ func WithManagedConfigurators(c ...ManagedConfigurator) ClaimReconcilerOption

+ func WithManagedConnectionPropagator(p ManagedConnectionPropagator) ClaimReconcilerOption

+ func WithManagedCreator(c ManagedCreator) ClaimReconcilerOption

+ func WithManagedFinalizer(f ManagedFinalizer) ClaimReconcilerOption

+ type ClaimReferencer interface

+ GetClaimReference func() *corev1.ObjectReference

+ SetClaimReference func(r *corev1.ObjectReference)

+ type ClaimSchedulingReconciler struct

+ func NewClaimSchedulingReconciler(m manager.Manager, of ClaimKind, to ClassKind, ...) *ClaimSchedulingReconciler

+ func (r *ClaimSchedulingReconciler) Reconcile(req reconcile.Request) (reconcile.Result, error)

+ type ClaimSchedulingReconcilerOption func(*ClaimSchedulingReconciler)

+ func WithSchedulingJitterer(j Jitterer) ClaimSchedulingReconcilerOption

+ type Class interface

+ type ClassKind schema.GroupVersionKind

+ func (k ClassKind) List() schema.GroupVersionKind

+ type ClassReferencer interface

+ GetClassReference func() *corev1.ObjectReference

+ SetClassReference func(r *corev1.ObjectReference)

+ type ClassSelector interface

+ GetClassSelector func() *metav1.LabelSelector

+ SetClassSelector func(s *metav1.LabelSelector)

+ type Conditioned interface

+ GetCondition func(v1alpha1.ConditionType) v1alpha1.Condition

+ SetConditions func(c ...v1alpha1.Condition)

+ type ConfiguratorChain []ManagedConfigurator

+ func (cc ConfiguratorChain) Configure(ctx context.Context, cm Claim, cs Class, mg Managed) error

+ type ConnectionDetails map[string][]byte

+ type ConnectionSecretOwner interface

+ type ConnectionSecretWriterTo interface

+ GetWriteConnectionSecretToReference func() *v1alpha1.SecretReference

+ SetWriteConnectionSecretToReference func(r *v1alpha1.SecretReference)

+ type EnqueueRequestForClaim struct

+ func (e *EnqueueRequestForClaim) Create(evt event.CreateEvent, q workqueue.RateLimitingInterface)

+ func (e *EnqueueRequestForClaim) Delete(evt event.DeleteEvent, q workqueue.RateLimitingInterface)

+ func (e *EnqueueRequestForClaim) Generic(evt event.GenericEvent, q workqueue.RateLimitingInterface)

+ func (e *EnqueueRequestForClaim) Update(evt event.UpdateEvent, q workqueue.RateLimitingInterface)

+ type EnqueueRequestForPropagator struct

+ func (e *EnqueueRequestForPropagator) Create(evt event.CreateEvent, q workqueue.RateLimitingInterface)

+ func (e *EnqueueRequestForPropagator) Delete(evt event.DeleteEvent, q workqueue.RateLimitingInterface)

+ func (e *EnqueueRequestForPropagator) Generic(evt event.GenericEvent, q workqueue.RateLimitingInterface)

+ func (e *EnqueueRequestForPropagator) Update(evt event.UpdateEvent, q workqueue.RateLimitingInterface)

+ type ErrorIs func(err error) bool

+ type ExternalClient interface

+ Create func(ctx context.Context, mg Managed) (ExternalCreation, error)

+ Delete func(ctx context.Context, mg Managed) error

+ Observe func(ctx context.Context, mg Managed) (ExternalObservation, error)

+ Update func(ctx context.Context, mg Managed) (ExternalUpdate, error)

+ type ExternalClientFns struct

+ CreateFn func(ctx context.Context, mg Managed) (ExternalCreation, error)

+ DeleteFn func(ctx context.Context, mg Managed) error

+ ObserveFn func(ctx context.Context, mg Managed) (ExternalObservation, error)

+ UpdateFn func(ctx context.Context, mg Managed) (ExternalUpdate, error)

+ func (e ExternalClientFns) Create(ctx context.Context, mg Managed) (ExternalCreation, error)

+ func (e ExternalClientFns) Delete(ctx context.Context, mg Managed) error

+ func (e ExternalClientFns) Observe(ctx context.Context, mg Managed) (ExternalObservation, error)

+ func (e ExternalClientFns) Update(ctx context.Context, mg Managed) (ExternalUpdate, error)

+ type ExternalConnecter interface

+ Connect func(ctx context.Context, mg Managed) (ExternalClient, error)

+ type ExternalConnectorFn func(ctx context.Context, mg Managed) (ExternalClient, error)

+ func (ec ExternalConnectorFn) Connect(ctx context.Context, mg Managed) (ExternalClient, error)

+ type ExternalCreation struct

+ ConnectionDetails ConnectionDetails

+ type ExternalObservation struct

+ ConnectionDetails ConnectionDetails

+ ResourceExists bool

+ ResourceUpToDate bool

+ type ExternalUpdate struct

+ ConnectionDetails ConnectionDetails

+ type InitializerChain []ManagedInitializer

+ func (cc InitializerChain) Initialize(ctx context.Context, mg Managed) error

+ type Jitterer func()

+ type LocalConnectionSecretOwner interface

+ type LocalConnectionSecretWriterTo interface

+ GetWriteConnectionSecretToReference func() *v1alpha1.LocalSecretReference

+ SetWriteConnectionSecretToReference func(r *v1alpha1.LocalSecretReference)

+ type Managed interface

+ type ManagedBinder interface

+ Bind func(ctx context.Context, cm Claim, mg Managed) error

+ type ManagedBinderFn func(ctx context.Context, cm Claim, mg Managed) error

+ func (fn ManagedBinderFn) Bind(ctx context.Context, cm Claim, mg Managed) error

+ type ManagedConfigurator interface

+ Configure func(ctx context.Context, cm Claim, cs Class, mg Managed) error

+ type ManagedConfiguratorFn func(ctx context.Context, cm Claim, cs Class, mg Managed) error

+ func (fn ManagedConfiguratorFn) Configure(ctx context.Context, cm Claim, cs Class, mg Managed) error

+ type ManagedConnectionPropagator interface

+ PropagateConnection func(ctx context.Context, cm Claim, mg Managed) error

+ type ManagedConnectionPropagatorFn func(ctx context.Context, cm Claim, mg Managed) error

+ func (fn ManagedConnectionPropagatorFn) PropagateConnection(ctx context.Context, cm Claim, mg Managed) error

+ type ManagedConnectionPublisher interface

+ PublishConnection func(ctx context.Context, mg Managed, c ConnectionDetails) error

+ UnpublishConnection func(ctx context.Context, mg Managed, c ConnectionDetails) error

+ type ManagedConnectionPublisherFns struct

+ PublishConnectionFn func(ctx context.Context, mg Managed, c ConnectionDetails) error

+ UnpublishConnectionFn func(ctx context.Context, mg Managed, c ConnectionDetails) error

+ func (fn ManagedConnectionPublisherFns) PublishConnection(ctx context.Context, mg Managed, c ConnectionDetails) error

+ func (fn ManagedConnectionPublisherFns) UnpublishConnection(ctx context.Context, mg Managed, c ConnectionDetails) error

+ type ManagedCreator interface

+ Create func(ctx context.Context, cm Claim, cs Class, mg Managed) error

+ type ManagedCreatorFn func(ctx context.Context, cm Claim, cs Class, mg Managed) error

+ func (fn ManagedCreatorFn) Create(ctx context.Context, cm Claim, cs Class, mg Managed) error

+ type ManagedFinalizer interface

+ Finalize func(ctx context.Context, cm Managed) error

+ type ManagedFinalizerFn func(ctx context.Context, cm Managed) error

+ func (fn ManagedFinalizerFn) Finalize(ctx context.Context, cm Managed) error

+ type ManagedInitializer interface

+ Initialize func(ctx context.Context, mg Managed) error

+ type ManagedInitializerFn func(ctx context.Context, mg Managed) error

+ func (m ManagedInitializerFn) Initialize(ctx context.Context, mg Managed) error

+ type ManagedKind schema.GroupVersionKind

+ type ManagedNameAsExternalName struct

+ func NewManagedNameAsExternalName(c client.Client) *ManagedNameAsExternalName

+ func (a *ManagedNameAsExternalName) Initialize(ctx context.Context, mg Managed) error

+ type ManagedReconciler struct

+ func NewManagedReconciler(m manager.Manager, of ManagedKind, o ...ManagedReconcilerOption) *ManagedReconciler

+ func (r *ManagedReconciler) Reconcile(req reconcile.Request) (reconcile.Result, error)

+ type ManagedReconcilerOption func(*ManagedReconciler)

+ func WithExternalConnecter(c ExternalConnecter) ManagedReconcilerOption

+ func WithLongWait(after time.Duration) ManagedReconcilerOption

+ func WithManagedConnectionPublishers(p ...ManagedConnectionPublisher) ManagedReconcilerOption

+ func WithManagedInitializers(i ...ManagedInitializer) ManagedReconcilerOption

+ func WithShortWait(after time.Duration) ManagedReconcilerOption

+ type ManagedReferenceResolver interface

+ ResolveReferences func(context.Context, CanReference) error

+ type ManagedReferenceResolverFn func(context.Context, CanReference) error

+ func (m ManagedReferenceResolverFn) ResolveReferences(ctx context.Context, res CanReference) error

+ type ManagedResourceReferencer interface

+ GetResourceReference func() *corev1.ObjectReference

+ SetResourceReference func(r *corev1.ObjectReference)

+ type NopClient struct

+ func (c *NopClient) Create(ctx context.Context, mg Managed) (ExternalCreation, error)

+ func (c *NopClient) Delete(ctx context.Context, mg Managed) error

+ func (c *NopClient) Observe(ctx context.Context, mg Managed) (ExternalObservation, error)

+ func (c *NopClient) Update(ctx context.Context, mg Managed) (ExternalUpdate, error)

+ type NopConnecter struct

+ func (c *NopConnecter) Connect(_ context.Context, _ Managed) (ExternalClient, error)

+ type ObjectMetaConfigurator struct

+ func NewObjectMetaConfigurator(t runtime.ObjectTyper) *ObjectMetaConfigurator

+ func (c *ObjectMetaConfigurator) Configure(_ context.Context, cm Claim, _ Class, mg Managed) error

+ type PredicateFn func(obj runtime.Object) bool

+ func AllOf(fn ...PredicateFn) PredicateFn

+ func AnyOf(fn ...PredicateFn) PredicateFn

+ func HasClassReferenceKind(k ClassKind) PredicateFn

+ func HasClassSelector() PredicateFn

+ func HasManagedResourceReferenceKind(k ManagedKind) PredicateFn

+ func HasNoClassReference() PredicateFn

+ func HasNoClassSelector() PredicateFn

+ func HasNoManagedResourceReference() PredicateFn

+ func IsControlledByKind(k schema.GroupVersionKind) PredicateFn

+ func IsManagedKind(k ManagedKind, ot runtime.ObjectTyper) PredicateFn

+ func IsPropagated() PredicateFn

+ func IsPropagator() PredicateFn

+ type PublisherChain []ManagedConnectionPublisher

+ func (pc PublisherChain) PublishConnection(ctx context.Context, mg Managed, c ConnectionDetails) error

+ func (pc PublisherChain) UnpublishConnection(ctx context.Context, mg Managed, c ConnectionDetails) error

+ type Reclaimer interface

+ GetReclaimPolicy func() v1alpha1.ReclaimPolicy

+ SetReclaimPolicy func(p v1alpha1.ReclaimPolicy)

+ type ReferenceStatus struct

+ Name string

+ Status ReferenceStatusType

+ func (r ReferenceStatus) String() string

+ type ReferenceStatusType int

+ const ReferenceNotFound

+ const ReferenceNotReady

+ const ReferenceReady

+ const ReferenceStatusUnknown

+ func (t ReferenceStatusType) String() string

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