reconciler

package
v0.26.5 Latest Latest
Warning

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

 Go to latest Published: Oct 18, 2023 License: Apache-2.0 Imports: 39 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"

	// AnnotationRadiusEnvionment 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 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 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 ContainerClient 

type ContainerClient interface {
	BeginCreateOrUpdate(ctx context.Context, containerName string, resource corerpv20231001preview.ContainerResource, options *corerpv20231001preview.ContainersClientBeginCreateOrUpdateOptions) (Poller[corerpv20231001preview.ContainersClientCreateOrUpdateResponse], error)
	BeginDelete(ctx context.Context, containerName string, options *corerpv20231001preview.ContainersClientBeginDeleteOptions) (Poller[corerpv20231001preview.ContainersClientDeleteResponse], error)
	ContinueCreateOperation(ctx context.Context, resumeToken string) (Poller[corerpv20231001preview.ContainersClientCreateOrUpdateResponse], error)
	ContinueDeleteOperation(ctx context.Context, resumeToken string) (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) (Poller[corerpv20231001preview.ContainersClientCreateOrUpdateResponse], error)

func (*ContainerClientImpl) BeginDelete 

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

func (*ContainerClientImpl) ContinueCreateOperation 

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

func (*ContainerClientImpl) ContinueDeleteOperation 

func (cc *ContainerClientImpl) ContinueDeleteOperation(ctx context.Context, resumeToken string) (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 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 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 ResourceClient 

type ResourceClient interface {
	BeginCreateOrUpdate(ctx context.Context, resourceName string, resource generated.GenericResource, options *generated.GenericResourcesClientBeginCreateOrUpdateOptions) (Poller[generated.GenericResourcesClientCreateOrUpdateResponse], error)
	BeginDelete(ctx context.Context, resourceName string, options *generated.GenericResourcesClientBeginDeleteOptions) (Poller[generated.GenericResourcesClientDeleteResponse], error)
	ContinueCreateOperation(ctx context.Context, resumeToken string) (Poller[generated.GenericResourcesClientCreateOrUpdateResponse], error)
	ContinueDeleteOperation(ctx context.Context, resumeToken string) (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) (Poller[generated.GenericResourcesClientCreateOrUpdateResponse], error)

func (*ResourceClientImpl) BeginDelete 

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

func (*ResourceClientImpl) ContinueCreateOperation 

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

func (*ResourceClientImpl) ContinueDeleteOperation 

func (rc *ResourceClientImpl) ContinueDeleteOperation(ctx context.Context, resumeToken string) (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.