reconciler

package
v0.36.0-rc1 Latest Latest
Warning

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

Go to latest
Published: Jul 18, 2024 License: Apache-2.0 Imports: 42 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"
)

Variables

This section is empty.

Functions

This section is empty.

Types

type ApplicationClientImpl

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

type Client

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

func NewClient

func NewClient(connection sdk.Connection) *Client

func (*Client) Applications

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

func (*Client) Containers

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

func (*Client) Environments

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

func (*Client) Groups

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

func (*Client) Resources

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

type ContainerClientImpl

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

func (*ContainerClientImpl) ContinueCreateOperation

func (*ContainerClientImpl) ContinueDeleteOperation

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 EnvironmentClientImpl

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

type Poller

type Poller[T any] interface {
	Done() bool
	Poll(ctx context.Context) (*http.Response, error)
	Result(ctx context.Context) (T, error)
	ResumeToken() (string, 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 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 ResourceClientImpl

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

func (*ResourceClientImpl) ContinueCreateOperation

func (*ResourceClientImpl) ContinueDeleteOperation

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

func (*ResourceClientImpl) Get

func (*ResourceClientImpl) ListSecrets

type ResourceGroupClientImpl

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

Jump to

Keyboard shortcuts

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