Documentation ¶
Overview ¶
Package managed provides a reconciler that manages the lifecycle of a resource in an external system.
Index ¶
- func ControllerName(kind string) string
- type APISecretPublisher
- type APISimpleReferenceResolver
- type ConnectionDetails
- type ConnectionPublisher
- type ConnectionPublisherFns
- type CriticalAnnotationUpdateFn
- type CriticalAnnotationUpdater
- type DefaultProviderConfig
- type ExternalClient
- type ExternalClientFns
- func (e ExternalClientFns) Create(ctx context.Context, mg resource.Managed) (ExternalCreation, error)
- func (e ExternalClientFns) Delete(ctx context.Context, mg resource.Managed) error
- func (e ExternalClientFns) Observe(ctx context.Context, mg resource.Managed) (ExternalObservation, error)
- func (e ExternalClientFns) Update(ctx context.Context, mg resource.Managed) (ExternalUpdate, error)
- type ExternalConnecter
- type ExternalConnectorFn
- type ExternalCreation
- type ExternalObservation
- type ExternalUpdate
- type Initializer
- type InitializerChain
- type InitializerFn
- type NameAsExternalName
- type NopClient
- func (c *NopClient) Create(ctx context.Context, mg resource.Managed) (ExternalCreation, error)
- func (c *NopClient) Delete(ctx context.Context, mg resource.Managed) error
- func (c *NopClient) Observe(ctx context.Context, mg resource.Managed) (ExternalObservation, error)
- func (c *NopClient) Update(ctx context.Context, mg resource.Managed) (ExternalUpdate, error)
- type NopConnecter
- type PublisherChain
- type Reconciler
- type ReconcilerOption
- func WithConnectionPublishers(p ...ConnectionPublisher) ReconcilerOption
- func WithCreationGracePeriod(d time.Duration) ReconcilerOption
- func WithCriticalAnnotationUpdater(u CriticalAnnotationUpdater) ReconcilerOption
- func WithExternalConnecter(c ExternalConnecter) ReconcilerOption
- func WithFinalizer(f resource.Finalizer) ReconcilerOption
- func WithInitializers(i ...Initializer) ReconcilerOption
- func WithLogger(l logging.Logger) ReconcilerOption
- func WithPollInterval(after time.Duration) ReconcilerOption
- func WithRecorder(er event.Recorder) ReconcilerOption
- func WithReferenceResolver(rr ReferenceResolver) ReconcilerOption
- func WithTimeout(duration time.Duration) ReconcilerOption
- type ReferenceResolver
- type ReferenceResolverFn
- type RetryingCriticalAnnotationUpdater
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func ControllerName ¶
ControllerName returns the recommended name for controllers that use this package to reconcile a particular kind of managed resource.
Types ¶
type APISecretPublisher ¶
type APISecretPublisher struct {
// contains filtered or unexported fields
}
An APISecretPublisher publishes ConnectionDetails by submitting a Secret to a Kubernetes API server.
func NewAPISecretPublisher ¶
func NewAPISecretPublisher(c client.Client, ot runtime.ObjectTyper) *APISecretPublisher
NewAPISecretPublisher returns a new APISecretPublisher.
func (*APISecretPublisher) PublishConnection ¶
func (a *APISecretPublisher) PublishConnection(ctx context.Context, mg resource.Managed, c ConnectionDetails) error
PublishConnection publishes the supplied ConnectionDetails to a Secret in the same namespace as the supplied Managed resource. It is a no-op if the secret already exists with the supplied ConnectionDetails.
func (*APISecretPublisher) UnpublishConnection ¶
func (a *APISecretPublisher) UnpublishConnection(ctx context.Context, mg resource.Managed, c ConnectionDetails) error
UnpublishConnection is no-op since PublishConnection only creates resources that will be garbage collected by Kubernetes when the managed resource is deleted.
type APISimpleReferenceResolver ¶ added in v0.8.0
type APISimpleReferenceResolver struct {
// contains filtered or unexported fields
}
An APISimpleReferenceResolver resolves references from one managed resource to others by calling the referencing resource's ResolveReferences method, if any.
func NewAPISimpleReferenceResolver ¶ added in v0.8.0
func NewAPISimpleReferenceResolver(c client.Client) *APISimpleReferenceResolver
NewAPISimpleReferenceResolver returns a ReferenceResolver that resolves references from one managed resource to others by calling the referencing resource's ResolveReferences method, if any.
func (*APISimpleReferenceResolver) ResolveReferences ¶ added in v0.8.0
func (a *APISimpleReferenceResolver) ResolveReferences(ctx context.Context, mg resource.Managed) error
ResolveReferences of the supplied managed resource by calling its ResolveReferences method, if any.
type ConnectionDetails ¶
ConnectionDetails created or updated during an operation on an external resource, for example usernames, passwords, endpoints, ports, etc.
type ConnectionPublisher ¶
type ConnectionPublisher interface { // PublishConnection details for the supplied Managed resource. Publishing // must be additive; i.e. if details (a, b, c) are published, subsequently // publicing details (b, c, d) should update (b, c) but not remove a. PublishConnection(ctx context.Context, mg resource.Managed, c ConnectionDetails) error // UnpublishConnection details for the supplied Managed resource. UnpublishConnection(ctx context.Context, mg resource.Managed, c ConnectionDetails) error }
A ConnectionPublisher manages the supplied ConnectionDetails for the supplied Managed resource. ManagedPublishers must handle the case in which the supplied ConnectionDetails are empty.
type ConnectionPublisherFns ¶
type ConnectionPublisherFns struct { PublishConnectionFn func(ctx context.Context, mg resource.Managed, c ConnectionDetails) error UnpublishConnectionFn func(ctx context.Context, mg resource.Managed, c ConnectionDetails) error }
ConnectionPublisherFns is the pluggable struct to produce objects with ConnectionPublisher interface.
func (ConnectionPublisherFns) PublishConnection ¶
func (fn ConnectionPublisherFns) PublishConnection(ctx context.Context, mg resource.Managed, c ConnectionDetails) error
PublishConnection details for the supplied Managed resource.
func (ConnectionPublisherFns) UnpublishConnection ¶
func (fn ConnectionPublisherFns) UnpublishConnection(ctx context.Context, mg resource.Managed, c ConnectionDetails) error
UnpublishConnection details for the supplied Managed resource.
type CriticalAnnotationUpdateFn ¶ added in v0.13.1
A CriticalAnnotationUpdateFn may be used when it is critical that annotations must be updated before returning from the Reconcile loop.
func (CriticalAnnotationUpdateFn) UpdateCriticalAnnotations ¶ added in v0.13.1
func (fn CriticalAnnotationUpdateFn) UpdateCriticalAnnotations(ctx context.Context, o client.Object) error
UpdateCriticalAnnotations of the supplied object.
type CriticalAnnotationUpdater ¶ added in v0.13.1
type CriticalAnnotationUpdater interface {
UpdateCriticalAnnotations(ctx context.Context, o client.Object) error
}
A CriticalAnnotationUpdater is used when it is critical that annotations must be updated before returning from the Reconcile loop.
type DefaultProviderConfig ¶ added in v0.10.0
type DefaultProviderConfig struct {
// contains filtered or unexported fields
}
DefaultProviderConfig fills the ProviderConfigRef with `default` if it's left empty. Deprecated: Use OpenAPI schema defaulting instead.
func NewDefaultProviderConfig ¶ added in v0.10.0
func NewDefaultProviderConfig(c client.Client) *DefaultProviderConfig
NewDefaultProviderConfig returns a new DefaultProviderConfig. Deprecated: Use OpenAPI schema defaulting instead.
func (*DefaultProviderConfig) Initialize ¶ added in v0.10.0
Initialize the given managed resource.
type ExternalClient ¶
type ExternalClient interface { // Observe the external resource the supplied Managed resource // represents, if any. Observe implementations must not modify the // external resource, but may update the supplied Managed resource to // reflect the state of the external resource. Status modifications are // automatically persisted unless ResourceLateInitialized is true - see // ResourceLateInitialized for more detail. Observe(ctx context.Context, mg resource.Managed) (ExternalObservation, error) // Create an external resource per the specifications of the supplied // Managed resource. Called when Observe reports that the associated // external resource does not exist. Create implementations may update // managed resource annotations, and those updates will be persisted. // All other updates will be discarded. Create(ctx context.Context, mg resource.Managed) (ExternalCreation, error) // Update the external resource represented by the supplied Managed // resource, if necessary. Called unless Observe reports that the // associated external resource is up to date. Update(ctx context.Context, mg resource.Managed) (ExternalUpdate, error) // Delete the external resource upon deletion of its associated Managed // resource. Called when the managed resource has been deleted. Delete(ctx context.Context, mg resource.Managed) error }
An ExternalClient manages the lifecycle of an external resource. None of the calls here should be blocking. All of the calls should be idempotent. For example, Create call should not return AlreadyExists error if it's called again with the same parameters or Delete call should not return error if there is an ongoing deletion or resource does not exist.
type ExternalClientFns ¶
type ExternalClientFns struct { ObserveFn func(ctx context.Context, mg resource.Managed) (ExternalObservation, error) CreateFn func(ctx context.Context, mg resource.Managed) (ExternalCreation, error) UpdateFn func(ctx context.Context, mg resource.Managed) (ExternalUpdate, error) DeleteFn func(ctx context.Context, mg resource.Managed) error }
ExternalClientFns are a series of functions that satisfy the ExternalClient interface.
func (ExternalClientFns) Create ¶
func (e ExternalClientFns) Create(ctx context.Context, mg resource.Managed) (ExternalCreation, error)
Create an external resource per the specifications of the supplied Managed resource.
func (ExternalClientFns) Delete ¶
Delete the external resource upon deletion of its associated Managed resource.
func (ExternalClientFns) Observe ¶
func (e ExternalClientFns) Observe(ctx context.Context, mg resource.Managed) (ExternalObservation, error)
Observe the external resource the supplied Managed resource represents, if any.
func (ExternalClientFns) Update ¶
func (e ExternalClientFns) Update(ctx context.Context, mg resource.Managed) (ExternalUpdate, error)
Update the external resource represented by the supplied Managed resource, if necessary.
type ExternalConnecter ¶
type ExternalConnecter interface { // Connect to the provider specified by the supplied managed resource and // produce an ExternalClient. Connect(ctx context.Context, mg resource.Managed) (ExternalClient, error) }
An ExternalConnecter produces a new ExternalClient given the supplied Managed resource.
type ExternalConnectorFn ¶
An ExternalConnectorFn is a function that satisfies the ExternalConnecter interface.
func (ExternalConnectorFn) Connect ¶
func (ec ExternalConnectorFn) Connect(ctx context.Context, mg resource.Managed) (ExternalClient, error)
Connect to the provider specified by the supplied managed resource and produce an ExternalClient.
type ExternalCreation ¶
type ExternalCreation struct { // ExternalNameAssigned should be true if the Create operation resulted // in a change in the resource's external name. This is typically only // needed for external resource's with unpredictable external names that // are returned from the API at create time. // // Deprecated: The managed.Reconciler no longer needs to be informed // when an external name is assigned by the Create operation. It will // automatically detect and handle external name assignment. ExternalNameAssigned bool // ConnectionDetails required to connect to this resource. These details // are a set that is collated throughout the managed resource's lifecycle - // i.e. returning new connection details will have no affect on old details // unless an existing key is overwritten. Crossplane may publish these // credentials to a store (e.g. a Secret). ConnectionDetails ConnectionDetails }
An ExternalCreation is the result of the creation of an external resource.
type ExternalObservation ¶
type ExternalObservation struct { // ResourceExists must be true if a corresponding external resource exists // for the managed resource. Typically this is proven by the presence of an // external resource of the expected kind whose unique identifier matches // the managed resource's external name. Crossplane uses this information to // determine whether it needs to create or delete the external resource. ResourceExists bool // ResourceUpToDate should be true if the corresponding external resource // appears to be up-to-date - i.e. updating the external resource to match // the desired state of the managed resource would be a no-op. Keep in mind // that often only a subset of external resource fields can be updated. // Crossplane uses this information to determine whether it needs to update // the external resource. ResourceUpToDate bool // ResourceLateInitialized should be true if the managed resource's spec was // updated during its observation. A Crossplane provider may update a // managed resource's spec fields after it is created or updated, as long as // the updates are limited to setting previously unset fields, and adding // keys to maps. Crossplane uses this information to determine whether // changes to the spec were made during observation that must be persisted. // Note that changes to the spec will be persisted before changes to the // status, and that pending changes to the status may be lost when the spec // is persisted. Status changes will be persisted by the first subsequent // observation that _does not_ late initialize the managed resource, so it // is important that Observe implementations do not late initialize the // resource every time they are called. ResourceLateInitialized bool // ConnectionDetails required to connect to this resource. These details // are a set that is collated throughout the managed resource's lifecycle - // i.e. returning new connection details will have no affect on old details // unless an existing key is overwritten. Crossplane may publish these // credentials to a store (e.g. a Secret). ConnectionDetails ConnectionDetails // Diff is a Debug level message that is sent to the reconciler when // there is a change in the observed Managed Resource. It is useful for // finding where the observed diverges from the desired state. // The string should be a cmp.Diff that details the difference. Diff string }
An ExternalObservation is the result of an observation of an external resource.
type ExternalUpdate ¶
type ExternalUpdate struct { // ConnectionDetails required to connect to this resource. These details // are a set that is collated throughout the managed resource's lifecycle - // i.e. returning new connection details will have no affect on old details // unless an existing key is overwritten. Crossplane may publish these // credentials to a store (e.g. a Secret). ConnectionDetails ConnectionDetails }
An ExternalUpdate is the result of an update to an external resource.
type Initializer ¶
A Initializer establishes ownership of the supplied Managed resource. This typically involves the operations that are run before calling any ExternalClient methods.
type InitializerChain ¶
type InitializerChain []Initializer
A InitializerChain chains multiple managed initializers.
func (InitializerChain) Initialize ¶
Initialize calls each Initializer serially. It returns the first error it encounters, if any.
type InitializerFn ¶
A InitializerFn is a function that satisfies the Initializer interface.
func (InitializerFn) Initialize ¶
Initialize calls InitializerFn function.
type NameAsExternalName ¶
type NameAsExternalName struct {
// contains filtered or unexported fields
}
NameAsExternalName writes the name of the managed resource to the external name annotation field in order to be used as name of the external resource in provider.
func NewNameAsExternalName ¶
func NewNameAsExternalName(c client.Client) *NameAsExternalName
NewNameAsExternalName returns a new NameAsExternalName.
func (*NameAsExternalName) Initialize ¶
Initialize the given managed resource.
type NopClient ¶
type NopClient struct{}
A NopClient does nothing.
type NopConnecter ¶
type NopConnecter struct{}
A NopConnecter does nothing.
func (*NopConnecter) Connect ¶
func (c *NopConnecter) Connect(_ context.Context, _ resource.Managed) (ExternalClient, error)
Connect returns a NopClient. It never returns an error.
type PublisherChain ¶
type PublisherChain []ConnectionPublisher
A PublisherChain chains multiple ManagedPublishers.
func (PublisherChain) PublishConnection ¶
func (pc PublisherChain) PublishConnection(ctx context.Context, mg resource.Managed, c ConnectionDetails) error
PublishConnection calls each ConnectionPublisher.PublishConnection serially. It returns the first error it encounters, if any.
func (PublisherChain) UnpublishConnection ¶
func (pc PublisherChain) UnpublishConnection(ctx context.Context, mg resource.Managed, c ConnectionDetails) error
UnpublishConnection calls each ConnectionPublisher.UnpublishConnection serially. It returns the first error it encounters, if any.
type Reconciler ¶
type Reconciler struct {
// contains filtered or unexported fields
}
A Reconciler reconciles managed resources by creating and managing the lifecycle of an external resource, i.e. a resource in an external system such as a cloud provider API. Each controller must watch the managed resource kind for which it is responsible.
func NewReconciler ¶
func NewReconciler(m manager.Manager, of resource.ManagedKind, o ...ReconcilerOption) *Reconciler
NewReconciler returns a Reconciler that reconciles managed resources of the supplied ManagedKind with resources in an external system such as a cloud provider API. It panics if asked to reconcile a managed resource kind that is not registered with the supplied manager's runtime.Scheme. The returned Reconciler reconciles with a dummy, no-op 'external system' by default; callers should supply an ExternalConnector that returns an ExternalClient capable of managing resources in a real system.
type ReconcilerOption ¶
type ReconcilerOption func(*Reconciler)
A ReconcilerOption configures a Reconciler.
func WithConnectionPublishers ¶
func WithConnectionPublishers(p ...ConnectionPublisher) ReconcilerOption
WithConnectionPublishers specifies how the Reconciler should publish its connection details such as credentials and endpoints.
func WithCreationGracePeriod ¶ added in v0.13.1
func WithCreationGracePeriod(d time.Duration) ReconcilerOption
WithCreationGracePeriod configures an optional period during which we will wait for the external API to report that a newly created external resource exists. This allows us to tolerate eventually consistent APIs that do not immediately report that newly created resources exist when queried. All resources have a 30 second grace period by default.
func WithCriticalAnnotationUpdater ¶ added in v0.13.1
func WithCriticalAnnotationUpdater(u CriticalAnnotationUpdater) ReconcilerOption
WithCriticalAnnotationUpdater specifies how the Reconciler should update a managed resource's critical annotations. Implementations typically contain some kind of retry logic to increase the likelihood that critical annotations (like non-deterministic external names) will be persisted.
func WithExternalConnecter ¶
func WithExternalConnecter(c ExternalConnecter) ReconcilerOption
WithExternalConnecter specifies how the Reconciler should connect to the API used to sync and delete external resources.
func WithFinalizer ¶
func WithFinalizer(f resource.Finalizer) ReconcilerOption
WithFinalizer specifies how the Reconciler should add and remove finalizers to and from the managed resource.
func WithInitializers ¶
func WithInitializers(i ...Initializer) ReconcilerOption
WithInitializers specifies how the Reconciler should initialize a managed resource before calling any of the ExternalClient functions.
func WithLogger ¶
func WithLogger(l logging.Logger) ReconcilerOption
WithLogger specifies how the Reconciler should log messages.
func WithPollInterval ¶ added in v0.13.0
func WithPollInterval(after time.Duration) ReconcilerOption
WithPollInterval specifies how long the Reconciler should wait before queueing a new reconciliation after a successful reconcile. The Reconciler requeues after a specified duration when it is not actively waiting for an external operation, but wishes to check whether an existing external resource needs to be synced to its Crossplane Managed resource.
func WithRecorder ¶
func WithRecorder(er event.Recorder) ReconcilerOption
WithRecorder specifies how the Reconciler should record events.
func WithReferenceResolver ¶
func WithReferenceResolver(rr ReferenceResolver) ReconcilerOption
WithReferenceResolver specifies how the Reconciler should resolve any inter-resource references it encounters while reconciling managed resources.
func WithTimeout ¶
func WithTimeout(duration time.Duration) ReconcilerOption
WithTimeout specifies the timeout duration cumulatively for all the calls happen in the reconciliation function. In case the deadline exceeds, reconciler will still have some time to make the necessary calls to report the error such as status update.
type ReferenceResolver ¶
type ReferenceResolver interface { // ResolveReferences resolves all fields in the supplied managed resource // that are references to other managed resources by updating corresponding // fields, for example setting spec.network to the Network resource // specified by spec.networkRef.name. ResolveReferences(ctx context.Context, mg resource.Managed) error }
A ReferenceResolver resolves references to other managed resources.
type ReferenceResolverFn ¶
A ReferenceResolverFn is a function that satisfies the ReferenceResolver interface.
func (ReferenceResolverFn) ResolveReferences ¶
ResolveReferences calls ReferenceResolverFn function
type RetryingCriticalAnnotationUpdater ¶ added in v0.13.1
type RetryingCriticalAnnotationUpdater struct {
// contains filtered or unexported fields
}
A RetryingCriticalAnnotationUpdater is a CriticalAnnotationUpdater that retries annotation updates in the face of API server errors.
func NewRetryingCriticalAnnotationUpdater ¶ added in v0.13.1
func NewRetryingCriticalAnnotationUpdater(c client.Client) *RetryingCriticalAnnotationUpdater
NewRetryingCriticalAnnotationUpdater returns a CriticalAnnotationUpdater that retries annotation updates in the face of API server errors.
func (*RetryingCriticalAnnotationUpdater) UpdateCriticalAnnotations ¶ added in v0.13.1
func (u *RetryingCriticalAnnotationUpdater) UpdateCriticalAnnotations(ctx context.Context, o client.Object) error
UpdateCriticalAnnotations updates (i.e. persists) the annotations of the supplied Object. It retries in the face of any API server error several times in order to ensure annotations that contain critical state are persisted. Any pending changes to the supplied Object's spec, status, or other metadata are reset to their current state according to the API server.