Documentation
¶
Overview ¶
Package controllers implements common controllers for the infra providers.
Index ¶
- type ProviderHealthStatusController
- func (ctrl *ProviderHealthStatusController) Inputs() []controller.Input
- func (ctrl *ProviderHealthStatusController) Name() string
- func (ctrl *ProviderHealthStatusController) Outputs() []controller.Output
- func (ctrl *ProviderHealthStatusController) Run(ctx context.Context, r controller.Runtime, _ *zap.Logger) error
- type ProviderHealthStatusOptions
- type ProvisionController
- func (ctrl *ProvisionController[T]) MapInput(ctx context.Context, _ *zap.Logger, r controller.QRuntime, ...) ([]resource.Pointer, error)
- func (ctrl *ProvisionController[T]) Reconcile(ctx context.Context, logger *zap.Logger, r controller.QRuntime, ...) error
- func (ctrl *ProvisionController[T]) Settings() controller.QSettings
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type ProviderHealthStatusController ¶ added in v0.46.0
type ProviderHealthStatusController struct {
// contains filtered or unexported fields
}
ProviderHealthStatusController reports infra provider health status.
func NewProviderHealthStatusController ¶ added in v0.46.0
func NewProviderHealthStatusController(providerID string, options ProviderHealthStatusOptions) (*ProviderHealthStatusController, error)
NewProviderHealthStatusController creates a new provider health status controller.
func (*ProviderHealthStatusController) Inputs ¶ added in v0.46.0
func (ctrl *ProviderHealthStatusController) Inputs() []controller.Input
Inputs implements controller.Controller interface.
func (*ProviderHealthStatusController) Name ¶ added in v0.46.0
func (ctrl *ProviderHealthStatusController) Name() string
Name implements controller.Controller interface.
func (*ProviderHealthStatusController) Outputs ¶ added in v0.46.0
func (ctrl *ProviderHealthStatusController) Outputs() []controller.Output
Outputs implements controller.Controller interface.
func (*ProviderHealthStatusController) Run ¶ added in v0.46.0
func (ctrl *ProviderHealthStatusController) Run(ctx context.Context, r controller.Runtime, _ *zap.Logger) error
Run implements controller.Controller interface.
type ProviderHealthStatusOptions ¶ added in v0.46.0
type ProviderHealthStatusOptions struct {
HealthCheckFunc func(ctx context.Context) error
Interval time.Duration
}
ProviderHealthStatusOptions defines options for the provider health status controller.
type ProvisionController ¶
type ProvisionController[T generic.ResourceWithRD] struct { generic.NamedController // contains filtered or unexported fields }
ProvisionController is the generic controller that operates the Provisioner.
func NewProvisionController ¶
func NewProvisionController[T generic.ResourceWithRD](providerID string, provisioner provision.Provisioner[T], concurrency uint, imageFactory provision.FactoryClient, ) *ProvisionController[T]
NewProvisionController creates new ProvisionController.
func (*ProvisionController[T]) MapInput ¶
func (ctrl *ProvisionController[T]) MapInput(ctx context.Context, _ *zap.Logger, r controller.QRuntime, ptr resource.Pointer, ) ([]resource.Pointer, error)
MapInput implements controller.QController interface.
func (*ProvisionController[T]) Reconcile ¶
func (ctrl *ProvisionController[T]) Reconcile(ctx context.Context, logger *zap.Logger, r controller.QRuntime, ptr resource.Pointer, ) error
Reconcile implements controller.QController interface.
func (*ProvisionController[T]) Settings ¶
func (ctrl *ProvisionController[T]) Settings() controller.QSettings
Settings implements controller.QController interface.
Source Files