reconciler

package
v0.44.0 Latest Latest
Warning

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

 Go to latest Published: Mar 6, 2025 License: Apache-2.0 Imports: 43 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	// PollingDelay is the amount of time to wait between polling for the status of a resource.
	PollingDelay time.Duration = 5 * time.Second

	// AnnotationRadiusEnabled is the name of the annotation that indicates if a Deployment has Radius enabled.
	AnnotationRadiusEnabled = "radapp.io/enabled"

	// AnnotationRadiusConnectionPrefix is the name of the annotation that indicates the name of the connection to use.
	AnnotationRadiusConnectionPrefix = "radapp.io/connection-"

	// AnnotationRadiusStatus is the name of the annotation that indicates the status of a Deployment.
	AnnotationRadiusStatus = "radapp.io/status"

	// AnnotationRadiusConfigurationHash is the name of the annotation that indicates the hash of the configuration.
	AnnotationRadiusConfigurationHash = "radapp.io/configuration-hash"

	// AnnotationRadiusEnvironment is the name of the annotation that indicates the name of the environment. If unset,
	// the value 'default' will be used as the environment name.
	AnnotationRadiusEnvironment = "radapp.io/environment"

	// AnnotationRadiusApplication is the name of the annotation that indicates the name of the application. If unset,
	// the namespace of the Deployment will be used as the application name.
	AnnotationRadiusApplication = "radapp.io/application"

	// DeploymentFinalizer is the name of the finalizer added to Deployments.
	DeploymentFinalizer = "radapp.io/deployment-finalizer"

	// RecipeFinalizer is the name of the finalizer added to Recipes.
	RecipeFinalizer = "radapp.io/recipe-finalizer"

	// DeploymentTemplateFinalizer is the name of the finalizer added to DeploymentTemplates.
	DeploymentTemplateFinalizer = "radapp.io/deployment-template-finalizer"

	// DeploymentResourceFinalizer is the name of the finalizer added to DeploymentResources.
	DeploymentResourceFinalizer = "radapp.io/deployment-resource-finalizer"
)

Variables

This section is empty.

Functions

func ParseDeploymentScopeFromProviderConfig added in v0.43.0 

func ParseDeploymentScopeFromProviderConfig(providerConfig any) (string, error)

Types

type ApplicationClient 

type ApplicationClient interface {
	CreateOrUpdate(ctx context.Context, applicationName string, resource corerpv20231001preview.ApplicationResource, options *corerpv20231001preview.ApplicationsClientCreateOrUpdateOptions) (corerpv20231001preview.ApplicationsClientCreateOrUpdateResponse, error)
	Delete(ctx context.Context, applicationName string, options *corerpv20231001preview.ApplicationsClientDeleteOptions) (corerpv20231001preview.ApplicationsClientDeleteResponse, error)
	Get(ctx context.Context, applicationName string, options *corerpv20231001preview.ApplicationsClientGetOptions) (corerpv20231001preview.ApplicationsClientGetResponse, error)
}

type ApplicationClientImpl 

type ApplicationClientImpl struct {
	// contains filtered or unexported fields
}

func (*ApplicationClientImpl) CreateOrUpdate 

func (ac *ApplicationClientImpl) CreateOrUpdate(ctx context.Context, applicationName string, resource corerpv20231001preview.ApplicationResource, options *corerpv20231001preview.ApplicationsClientCreateOrUpdateOptions) (corerpv20231001preview.ApplicationsClientCreateOrUpdateResponse, error)

func (*ApplicationClientImpl) Delete 

func (ac *ApplicationClientImpl) Delete(ctx context.Context, applicationName string, options *corerpv20231001preview.ApplicationsClientDeleteOptions) (corerpv20231001preview.ApplicationsClientDeleteResponse, error)

func (*ApplicationClientImpl) Get 

func (ac *ApplicationClientImpl) Get(ctx context.Context, applicationName string, options *corerpv20231001preview.ApplicationsClientGetOptions) (corerpv20231001preview.ApplicationsClientGetResponse, error)

type ContainerClient 

type ContainerClient interface {
	BeginCreateOrUpdate(ctx context.Context, containerName string, resource corerpv20231001preview.ContainerResource, options *corerpv20231001preview.ContainersClientBeginCreateOrUpdateOptions) (sdkclients.Poller[corerpv20231001preview.ContainersClientCreateOrUpdateResponse], error)
	BeginDelete(ctx context.Context, containerName string, options *corerpv20231001preview.ContainersClientBeginDeleteOptions) (sdkclients.Poller[corerpv20231001preview.ContainersClientDeleteResponse], error)
	ContinueCreateOperation(ctx context.Context, resumeToken string) (sdkclients.Poller[corerpv20231001preview.ContainersClientCreateOrUpdateResponse], error)
	ContinueDeleteOperation(ctx context.Context, resumeToken string) (sdkclients.Poller[corerpv20231001preview.ContainersClientDeleteResponse], error)
	Get(ctx context.Context, containerName string, options *corerpv20231001preview.ContainersClientGetOptions) (corerpv20231001preview.ContainersClientGetResponse, error)
}

type ContainerClientImpl 

type ContainerClientImpl struct {
	// contains filtered or unexported fields
}

func (*ContainerClientImpl) BeginCreateOrUpdate 

func (cc *ContainerClientImpl) BeginCreateOrUpdate(ctx context.Context, containerName string, resource corerpv20231001preview.ContainerResource, options *corerpv20231001preview.ContainersClientBeginCreateOrUpdateOptions) (sdkclients.Poller[corerpv20231001preview.ContainersClientCreateOrUpdateResponse], error)

func (*ContainerClientImpl) BeginDelete 

func (cc *ContainerClientImpl) BeginDelete(ctx context.Context, containerName string, options *corerpv20231001preview.ContainersClientBeginDeleteOptions) (sdkclients.Poller[corerpv20231001preview.ContainersClientDeleteResponse], error)

func (*ContainerClientImpl) ContinueCreateOperation 

func (cc *ContainerClientImpl) ContinueCreateOperation(ctx context.Context, resumeToken string) (sdkclients.Poller[corerpv20231001preview.ContainersClientCreateOrUpdateResponse], error)

func (*ContainerClientImpl) ContinueDeleteOperation 

func (cc *ContainerClientImpl) ContinueDeleteOperation(ctx context.Context, resumeToken string) (sdkclients.Poller[corerpv20231001preview.ContainersClientDeleteResponse], error)

func (*ContainerClientImpl) Get 

func (cc *ContainerClientImpl) Get(ctx context.Context, containerName string, options *corerpv20231001preview.ContainersClientGetOptions) (corerpv20231001preview.ContainersClientGetResponse, error)

type DeploymentReconciler added in v0.26.4 

type DeploymentReconciler struct {
	// Client is the Kubernetes client.
	Client client.Client

	// Scheme is the Kubernetes scheme.
	Scheme *runtime.Scheme

	// EventRecorder is the Kubernetes event recorder.
	EventRecorder record.EventRecorder

	// Radius is the Radius client.
	Radius RadiusClient

	// DelayInterval is the amount of time to wait between operations.
	DelayInterval time.Duration
}

DeploymentReconciler reconciles a Deployment object.

func (*DeploymentReconciler) Reconcile added in v0.26.4 

func (r *DeploymentReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)

Reconcile is the main reconciliation loop for the Deployment resource.

func (*DeploymentReconciler) SetupWithManager added in v0.26.4 

func (r *DeploymentReconciler) SetupWithManager(mgr ctrl.Manager) error

type DeploymentResourceReconciler added in v0.43.0 

type DeploymentResourceReconciler struct {
	// Client is the Kubernetes client.
	Client client.Client

	// Scheme is the Kubernetes scheme.
	Scheme *runtime.Scheme

	// EventRecorder is the Kubernetes event recorder.
	EventRecorder record.EventRecorder

	// Radius is the Radius client.
	Radius RadiusClient

	// ResourceDeploymentsClient is the client for managing deployments.
	ResourceDeploymentsClient sdkclients.ResourceDeploymentsClient

	// DelayInterval is the amount of time to wait between operations.
	DelayInterval time.Duration
}

DeploymentResourceReconciler reconciles a DeploymentResource object.

func (*DeploymentResourceReconciler) Reconcile added in v0.43.0 

func (r *DeploymentResourceReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)

Reconcile is the main reconciliation loop for the DeploymentResource resource.

func (*DeploymentResourceReconciler) SetupWithManager added in v0.43.0 

func (r *DeploymentResourceReconciler) SetupWithManager(mgr ctrl.Manager) error

SetupWithManager sets up the controller with the Manager.

type DeploymentTemplateReconciler added in v0.43.0 

type DeploymentTemplateReconciler struct {
	// Client is the Kubernetes client.
	Client client.Client

	// Scheme is the Kubernetes scheme.
	Scheme *k8sruntime.Scheme

	// EventRecorder is the Kubernetes event recorder.
	EventRecorder record.EventRecorder

	// Radius is the Radius client.
	Radius RadiusClient

	// ResourceDeploymentsClient is the client for managing deployments.
	ResourceDeploymentsClient sdkclients.ResourceDeploymentsClient

	// DelayInterval is the amount of time to wait between operations.
	DelayInterval time.Duration
}

DeploymentTemplateReconciler reconciles a DeploymentTemplate object.

func (*DeploymentTemplateReconciler) Reconcile added in v0.43.0 

func (r *DeploymentTemplateReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)

Reconcile is the main reconciliation loop for the DeploymentTemplate resource.

func (*DeploymentTemplateReconciler) SetupWithManager added in v0.43.0 

func (r *DeploymentTemplateReconciler) SetupWithManager(mgr ctrl.Manager) error

SetupWithManager sets up the controller with the Manager.

type EnvironmentClient 

type EnvironmentClient interface {
	List(ctx context.Context, options *corerpv20231001preview.EnvironmentsClientListByScopeOptions) (corerpv20231001preview.EnvironmentsClientListByScopeResponse, error)
}

type EnvironmentClientImpl 

type EnvironmentClientImpl struct {
	// contains filtered or unexported fields
}

func (*EnvironmentClientImpl) List 

func (ec *EnvironmentClientImpl) List(ctx context.Context, options *corerpv20231001preview.EnvironmentsClientListByScopeOptions) (corerpv20231001preview.EnvironmentsClientListByScopeResponse, error)

type RadiusClient 

type RadiusClient interface {
	Applications(scope string) ApplicationClient
	Containers(scope string) ContainerClient
	Environments(scope string) EnvironmentClient
	Groups(scope string) ResourceGroupClient
	Resources(scope string, resourceType string) ResourceClient
}

type RadiusClientImpl added in v0.43.0 

type RadiusClientImpl struct {
	// contains filtered or unexported fields
}

func NewRadiusClient added in v0.43.0 

func NewRadiusClient(connection sdk.Connection) *RadiusClientImpl

func (*RadiusClientImpl) Applications added in v0.43.0 

func (c *RadiusClientImpl) Applications(scope string) ApplicationClient

func (*RadiusClientImpl) Containers added in v0.43.0 

func (c *RadiusClientImpl) Containers(scope string) ContainerClient

func (*RadiusClientImpl) Environments added in v0.43.0 

func (c *RadiusClientImpl) Environments(scope string) EnvironmentClient

func (*RadiusClientImpl) Groups added in v0.43.0 

func (c *RadiusClientImpl) Groups(scope string) ResourceGroupClient

func (*RadiusClientImpl) Resources added in v0.43.0 

func (c *RadiusClientImpl) Resources(scope string, resourceType string) ResourceClient

type RecipeReconciler 

type RecipeReconciler struct {
	// Client is the Kubernetes client.
	Client client.Client

	// Scheme is the Kubernetes scheme.
	Scheme *runtime.Scheme

	// EventRecorder is the Kubernetes event recorder.
	EventRecorder record.EventRecorder

	// Radius is the Radius client.
	Radius RadiusClient

	// DelayInterval is the amount of time to wait between operations.
	DelayInterval time.Duration
}

RecipeReconciler reconciles a Recipe object.

func (*RecipeReconciler) Reconcile 

func (r *RecipeReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)

Reconcile is the main reconciliation loop for the Recipe resource.

func (*RecipeReconciler) SetupWithManager 

func (r *RecipeReconciler) SetupWithManager(mgr ctrl.Manager) error

SetupWithManager sets up the controller with the Manager.

type RecipeWebhook added in v0.28.0 

type RecipeWebhook struct{}

RecipeWebhook implements the validating webhook functions for the Recipe type.

func (*RecipeWebhook) SetupWebhookWithManager added in v0.28.0 

func (r *RecipeWebhook) SetupWebhookWithManager(mgr ctrl.Manager) error

SetupWebhookWithManager sets up the webhook for the Recipe type with the provided manager. It configures the webhook to watch for changes on the Recipe resource and uses the provided validator. Returns an error if there was a problem setting up the webhook.

func (*RecipeWebhook) ValidateCreate added in v0.28.0 

func (r *RecipeWebhook) ValidateCreate(ctx context.Context, obj runtime.Object) (admission.Warnings, error)

ValidateCreate validates the creation of a Recipe object.

func (*RecipeWebhook) ValidateDelete added in v0.28.0 

func (r *RecipeWebhook) ValidateDelete(ctx context.Context, obj runtime.Object) (admission.Warnings, error)

ValidateDelete validates the deletion of a Recipe object.

func (*RecipeWebhook) ValidateUpdate added in v0.28.0 

func (r *RecipeWebhook) ValidateUpdate(ctx context.Context, oldObj, newObj runtime.Object) (admission.Warnings, error)

ValidateUpdate validates the update of a Recipe object.

type ResourceClient 

type ResourceClient interface {
	BeginCreateOrUpdate(ctx context.Context, resourceName string, resource generated.GenericResource, options *generated.GenericResourcesClientBeginCreateOrUpdateOptions) (sdkclients.Poller[generated.GenericResourcesClientCreateOrUpdateResponse], error)
	BeginDelete(ctx context.Context, resourceName string, options *generated.GenericResourcesClientBeginDeleteOptions) (sdkclients.Poller[generated.GenericResourcesClientDeleteResponse], error)
	ContinueCreateOperation(ctx context.Context, resumeToken string) (sdkclients.Poller[generated.GenericResourcesClientCreateOrUpdateResponse], error)
	ContinueDeleteOperation(ctx context.Context, resumeToken string) (sdkclients.Poller[generated.GenericResourcesClientDeleteResponse], error)
	Get(ctx context.Context, resourceName string) (generated.GenericResourcesClientGetResponse, error)
	ListSecrets(ctx context.Context, resourceName string) (generated.GenericResourcesClientListSecretsResponse, error)
}

type ResourceClientImpl 

type ResourceClientImpl struct {
	// contains filtered or unexported fields
}

func (*ResourceClientImpl) BeginCreateOrUpdate 

func (rc *ResourceClientImpl) BeginCreateOrUpdate(ctx context.Context, resourceName string, resource generated.GenericResource, options *generated.GenericResourcesClientBeginCreateOrUpdateOptions) (sdkclients.Poller[generated.GenericResourcesClientCreateOrUpdateResponse], error)

func (*ResourceClientImpl) BeginDelete 

func (rc *ResourceClientImpl) BeginDelete(ctx context.Context, resourceName string, options *generated.GenericResourcesClientBeginDeleteOptions) (sdkclients.Poller[generated.GenericResourcesClientDeleteResponse], error)

func (*ResourceClientImpl) ContinueCreateOperation 

func (rc *ResourceClientImpl) ContinueCreateOperation(ctx context.Context, resumeToken string) (sdkclients.Poller[generated.GenericResourcesClientCreateOrUpdateResponse], error)

func (*ResourceClientImpl) ContinueDeleteOperation 

func (rc *ResourceClientImpl) ContinueDeleteOperation(ctx context.Context, resumeToken string) (sdkclients.Poller[generated.GenericResourcesClientDeleteResponse], error)

func (*ResourceClientImpl) Get 

func (rc *ResourceClientImpl) Get(ctx context.Context, resourceName string) (generated.GenericResourcesClientGetResponse, error)

func (*ResourceClientImpl) ListSecrets 

func (rc *ResourceClientImpl) ListSecrets(ctx context.Context, resourceName string) (generated.GenericResourcesClientListSecretsResponse, error)

type ResourceGroupClient 

type ResourceGroupClient interface {
	CreateOrUpdate(ctx context.Context, resourceGroupName string, resource ucpv20231001preview.ResourceGroupResource, options *ucpv20231001preview.ResourceGroupsClientCreateOrUpdateOptions) (ucpv20231001preview.ResourceGroupsClientCreateOrUpdateResponse, error)
	Get(ctx context.Context, resourceGroupName string, options *ucpv20231001preview.ResourceGroupsClientGetOptions) (ucpv20231001preview.ResourceGroupsClientGetResponse, error)
}

type ResourceGroupClientImpl 

type ResourceGroupClientImpl struct {
	// contains filtered or unexported fields
}

func (*ResourceGroupClientImpl) CreateOrUpdate 

func (rgc *ResourceGroupClientImpl) CreateOrUpdate(ctx context.Context, resourceGroupName string, resource ucpv20231001preview.ResourceGroupResource, options *ucpv20231001preview.ResourceGroupsClientCreateOrUpdateOptions) (ucpv20231001preview.ResourceGroupsClientCreateOrUpdateResponse, error)

func (*ResourceGroupClientImpl) Get 

func (rgc *ResourceGroupClientImpl) Get(ctx context.Context, resourceGroupName string, options *ucpv20231001preview.ResourceGroupsClientGetOptions) (ucpv20231001preview.ResourceGroupsClientGetResponse, error)

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.