controllers

Documentation

Index

• Constants
• type DeploymentsManager
  • func NewDeploymentsManager() DeploymentsManager
  • func (d *DeploymentsManager) ForgetDeployment(namespacedName types.NamespacedName)
  • func (d *DeploymentsManager) IsDeploymentMarkedAsPatched(deployment apps.Deployment) bool
  • func (d *DeploymentsManager) MarkDeploymentAsNotPatched(deployment apps.Deployment)
  • func (d *DeploymentsManager) MarkDeploymentAsPatched(deployment apps.Deployment)
• type OperatorConfiguration
• type RookoutReconciler
  • func (r *RookoutReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
  • func (r *RookoutReconciler) SetupWithManager(mgr ctrl.Manager) error
• type RunningDeployment

Constants

const (
	OperatorConfigurationResource = "Rookout"
	DeploymentResource            = "Deployment"
	ConfigurationResourceName     = "rookout-operator-configuration"
)

const (
	DefaultRequeueAfter                 = 10 * time.Second
	DefaultInitContainerName            = "agent-init-container"
	DefaultInitContainerImagePullPolicy = core.PullAlways
	DefaultSharedVolumeName             = "rookout-agent-shared-volume"
	DefaultSharedVolumeMountPath        = "/rookout"
	RookoutEnvVarPreffix                = "ROOKOUT_"
	RookoutTokenEnvVar                  = "ROOKOUT_TOKEN"
	RookoutControllerHostEnvVar         = "ROOKOUT_CONTROLLER_HOST"
)

const (
	DefaultInitContainerImage = "docker.io/rookout/k8s-operator-init-container:latest"
)

Types

type DeploymentsManager

type DeploymentsManager struct {
	Deployments map[string]*RunningDeployment
}

We are saving a state of all running deployments in the cluster

func NewDeploymentsManager

func NewDeploymentsManager() DeploymentsManager

func (*DeploymentsManager) ForgetDeployment

func (d *DeploymentsManager) ForgetDeployment(namespacedName types.NamespacedName)

func (*DeploymentsManager) IsDeploymentMarkedAsPatched

func (d *DeploymentsManager) IsDeploymentMarkedAsPatched(deployment apps.Deployment) bool

func (*DeploymentsManager) MarkDeploymentAsNotPatched

func (d *DeploymentsManager) MarkDeploymentAsNotPatched(deployment apps.Deployment)

func (*DeploymentsManager) MarkDeploymentAsPatched

func (d *DeploymentsManager) MarkDeploymentAsPatched(deployment apps.Deployment)

type OperatorConfiguration

type OperatorConfiguration struct {
	rookoutv1alpha1.Rookout
	// contains filtered or unexported fields
}

type RookoutReconciler

type RookoutReconciler struct {
	client.Client
	Log    logr.Logger
	Scheme *runtime.Scheme

	DeploymentsManager DeploymentsManager
}

func (*RookoutReconciler) Reconcile

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

func (*RookoutReconciler) SetupWithManager

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

type RunningDeployment

type RunningDeployment struct {
	*apps.Deployment
	// contains filtered or unexported fields
}