healthwatcher

Documentation

Index

• func AddControllerToManager(logger logging.Logger, mgr manager.Manager, ...) error
• func NewController(logger logging.Logger, c client.Client, scheme *runtime.Scheme, ...) (reconcile.Reconciler, error)
• func TransferLsHealthCheckStatusToAvailabilityInstance(availabilityInstance *lssv1alpha1.AvailabilityInstance, ...)
• type Controller
  • func NewTestActuator(op operation.Operation, ...) *Controller
  • func (c *Controller) Reconcile(ctx context.Context, req reconcile.Request) (reconcile.Result, error)
• type ServiceTargetConfigKubeClientExtractor
  • func (e *ServiceTargetConfigKubeClientExtractor) GetKubeClientFromServiceTargetConfig(ctx context.Context, name string, namespace string, client client.Client) (client.Client, error)
• type ServiceTargetConfigKubeClientExtractorInterface

Functions

func AddControllerToManager

func AddControllerToManager(logger logging.Logger, mgr manager.Manager, config *config.LandscaperServiceConfiguration) error

AddControllerToManager adds the HealthWatcher controller to the manager

func NewController

func NewController(logger logging.Logger, c client.Client, scheme *runtime.Scheme, config *config.LandscaperServiceConfiguration) (reconcile.Reconciler, error)

func TransferLsHealthCheckStatusToAvailabilityInstance

func TransferLsHealthCheckStatusToAvailabilityInstance(availabilityInstance *lssv1alpha1.AvailabilityInstance, lsHealthChecks *lsv1alpha1.LsHealthCheckList, timeout time.Duration)

Types

type Controller

type Controller struct {
	operation.Operation
	// contains filtered or unexported fields
}

func NewTestActuator

func NewTestActuator(op operation.Operation, kubeClientExtractor ServiceTargetConfigKubeClientExtractorInterface, logger logging.Logger) *Controller

NewTestActuator creates a new controller for testing purposes.

func (*Controller) Reconcile

func (c *Controller) Reconcile(ctx context.Context, req reconcile.Request) (reconcile.Result, error)

type ServiceTargetConfigKubeClientExtractor

type ServiceTargetConfigKubeClientExtractor struct{}

func (*ServiceTargetConfigKubeClientExtractor) GetKubeClientFromServiceTargetConfig

func (e *ServiceTargetConfigKubeClientExtractor) GetKubeClientFromServiceTargetConfig(ctx context.Context, name string, namespace string, client client.Client) (client.Client, error)

type ServiceTargetConfigKubeClientExtractorInterface

type ServiceTargetConfigKubeClientExtractorInterface interface {
	GetKubeClientFromServiceTargetConfig(ctx context.Context, name string, namespace string, client client.Client) (client.Client, error)
}

ServiceTargetConfigKubeClientExtractorInterface implements functionality to create a kubeclient from a servive target config ref