reconciler

package
v0.50.0 Latest Latest
Warning

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

 Go to latest Published: Aug 19, 2025 License: Apache-2.0 Imports: 57 Imported by: 0

Documentation

Overview

Package reconciler is a generated GoMock package.

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"

	// GitRepositoryHttpRetryCount is the number of times to retry GitRepository HTTP requests.
	GitRepositoryHttpRetryCount = 9
)

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 ArchiveFetcher added in v0.45.0 

type ArchiveFetcher interface {
	Fetch(archiveURL string, digest string, dir string) error
}

func NewArchiveFetcher added in v0.45.0 

func NewArchiveFetcher() ArchiveFetcher

NewArchiveFetcher creates a new ArchiveFetcher with the default options.

type ArchiveFetcherImpl added in v0.45.0 

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

func (*ArchiveFetcherImpl) Fetch added in v0.45.0 

func (a *ArchiveFetcherImpl) Fetch(archiveURL string, digest string, dir string) error

type ConfigEntry added in v0.45.0 

type ConfigEntry struct {
	// Name is the name of the Bicep (.bicep) file.
	Name string `yaml:"name"`
	// Params is the name of the Bicep parameters (.bicepparam) file.
	Params string `yaml:"params,omitempty"`
	// Namespace is the Kubernetes namespace that the generated DeploymentTemplate should be created in.
	Namespace string `yaml:"namespace,omitempty"`
	// ResourceGroup is the Radius resource group that the Bicep file should be deployed to.
	ResourceGroup string `yaml:"resourceGroup,omitempty"`
}

ConfigEntry is the build configuration for a Bicep file in a Git repository.

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 FluxController added in v0.45.0 

type FluxController struct {
	client.Client
	Bicep          bicep.Interface
	FileSystem     filesystem.FileSystem
	ArchiveFetcher ArchiveFetcher
	// contains filtered or unexported fields
}

FluxController watches GitRepository objects for revision changes and processes the artifacts fetched from the Source Controller. It reads the git repository configuration, builds the bicep files. specified in the configuration, and creates DeploymentTemplate objects on the cluster.

func (*FluxController) Reconcile added in v0.45.0 

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

func (*FluxController) SetupWithManager added in v0.45.0 

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

type GitRepositoryRevisionChangePredicate added in v0.45.0 

type GitRepositoryRevisionChangePredicate struct {
	predicate.Funcs
}

GitRepositoryRevisionChangePredicate triggers an update event when a GitRepository revision changes.

func (*GitRepositoryRevisionChangePredicate) Create added in v0.45.0 

func (*GitRepositoryRevisionChangePredicate) Create(e event.CreateEvent) bool

func (*GitRepositoryRevisionChangePredicate) Update added in v0.45.0 

func (*GitRepositoryRevisionChangePredicate) Update(e event.UpdateEvent) bool

type MockArchiveFetcher added in v0.45.0 

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

MockArchiveFetcher is a mock of ArchiveFetcher interface.

func NewMockArchiveFetcher added in v0.45.0 

func NewMockArchiveFetcher(ctrl *gomock.Controller) *MockArchiveFetcher

NewMockArchiveFetcher creates a new mock instance.

func (*MockArchiveFetcher) EXPECT added in v0.45.0 

func (m *MockArchiveFetcher) EXPECT() *MockArchiveFetcherMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockArchiveFetcher) Fetch added in v0.45.0 

func (m *MockArchiveFetcher) Fetch(arg0, arg1, arg2 string) error

Fetch mocks base method.

type MockArchiveFetcherFetchCall added in v0.45.0 

type MockArchiveFetcherFetchCall struct {
	*gomock.Call
}

MockArchiveFetcherFetchCall wrap *gomock.Call

func (*MockArchiveFetcherFetchCall) Do added in v0.45.0 

func (c *MockArchiveFetcherFetchCall) Do(f func(string, string, string) error) *MockArchiveFetcherFetchCall

Do rewrite *gomock.Call.Do

func (*MockArchiveFetcherFetchCall) DoAndReturn added in v0.45.0 

func (c *MockArchiveFetcherFetchCall) DoAndReturn(f func(string, string, string) error) *MockArchiveFetcherFetchCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*MockArchiveFetcherFetchCall) Return added in v0.45.0 

func (c *MockArchiveFetcherFetchCall) Return(arg0 error) *MockArchiveFetcherFetchCall

Return rewrite *gomock.Call.Return

type MockArchiveFetcherMockRecorder added in v0.45.0 

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

MockArchiveFetcherMockRecorder is the mock recorder for MockArchiveFetcher.

func (*MockArchiveFetcherMockRecorder) Fetch added in v0.45.0 

func (mr *MockArchiveFetcherMockRecorder) Fetch(arg0, arg1, arg2 any) *MockArchiveFetcherFetchCall

Fetch indicates an expected call of Fetch.

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 RadiusGitOpsConfig added in v0.45.0 

type RadiusGitOpsConfig struct {
	Config []ConfigEntry `yaml:"config"`
}

RadiusGitOpsConfig is the configuration for Radius in a Git repository.

func ParseRadiusGitOpsConfig added in v0.45.0 

func ParseRadiusGitOpsConfig(configFilePath string) (*RadiusGitOpsConfig, error)

ParseRadiusGitOpsConfig parses the Radius GitOps configuration file at the given path on the local filesystem.

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.