controller

Documentation

Index

• Constants
• func EnvSources(refs []v1alpha2.EnvReference) []v1.EnvFromSource
• func FileToVolume(f v1alpha2.File) (v1.Volume, v1.VolumeMount)
• func FilesToVolumes(files []v1alpha2.File) ([]v1.Volume, []v1.VolumeMount)
• func GetDefaultPipelineSteps(ctx context.Context, capSvc capabilities.Service, cfg *v1alpha1.OperatorConfig) ([]pipeline.Step, error)
• type CapsuleReconciler
  • func (r *CapsuleReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
  • func (r *CapsuleReconciler) SetupWithManager(mgr ctrl.Manager, logger logr.Logger) error
• type CronJobStep
  • func NewCronJobStep() *CronJobStep
  • func (s *CronJobStep) Apply(_ context.Context, req pipeline.CapsuleRequest) error
• type DeploymentStep
  • func NewDeploymentStep() *DeploymentStep
  • func (s *DeploymentStep) Apply(ctx context.Context, req pipeline.CapsuleRequest) error
• type NetworkStep
  • func NewNetworkStep(cfg *v1alpha1.OperatorConfig) *NetworkStep
  • func (s *NetworkStep) Apply(_ context.Context, req pipeline.CapsuleRequest) error
• type ServiceAccountStep
  • func NewServiceAccountStep() *ServiceAccountStep
  • func (s *ServiceAccountStep) Apply(_ context.Context, req pipeline.CapsuleRequest) error
• type ServiceMonitorStep
  • func NewServiceMonitorStep(cfg *v1alpha1.OperatorConfig) *ServiceMonitorStep
  • func (s *ServiceMonitorStep) Apply(_ context.Context, req pipeline.CapsuleRequest) error
• type VPAStep
  • func NewVPAStep(cfg *v1alpha1.OperatorConfig) *VPAStep
  • func (s *VPAStep) Apply(_ context.Context, req pipeline.CapsuleRequest) error

Constants

const (
	AnnotationChecksumFiles     = "rig.dev/config-checksum-files"
	AnnotationChecksumAutoEnv   = "rig.dev/config-checksum-auto-env"
	AnnotationChecksumEnv       = "rig.dev/config-checksum-env"
	AnnotationChecksumSharedEnv = "rig.dev/config-checksum-shared-env"

	AnnotationOverrideOwnership = "rig.dev/override-ownership"

	LabelSharedConfig = "rig.dev/shared-config"
	LabelCapsule      = "rig.dev/capsule"
	LabelCron         = "batch.kubernets.io/cronjob"
)

const (
	RigDevRolloutLabel = "rig.dev/rollout"
)

Functions

func EnvSources

func EnvSources(refs []v1alpha2.EnvReference) []v1.EnvFromSource

func FileToVolume

func FileToVolume(f v1alpha2.File) (v1.Volume, v1.VolumeMount)

func FilesToVolumes

func FilesToVolumes(files []v1alpha2.File) ([]v1.Volume, []v1.VolumeMount)

func GetDefaultPipelineSteps

func GetDefaultPipelineSteps(
	ctx context.Context,
	capSvc capabilities.Service,
	cfg *v1alpha1.OperatorConfig,
) ([]pipeline.Step, error)

Types

type CapsuleReconciler

type CapsuleReconciler struct {
	client.Client
	Scheme              *runtime.Scheme
	Config              *configv1alpha1.OperatorConfig
	ClientSet           clientset.Interface
	CapabilitiesService capabilities.Service
	Pipeline            *pipeline.Pipeline
	PluginManager       *plugin.Manager
}

CapsuleReconciler reconciles a Capsule object

func (*CapsuleReconciler) Reconcile

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

Reconcile compares the state specified by the Capsule object against the actual cluster state, and then performs operations to make the cluster state reflect the state specified by the Capsule.

func (*CapsuleReconciler) SetupWithManager

func (r *CapsuleReconciler) SetupWithManager(mgr ctrl.Manager, logger logr.Logger) error

SetupWithManager sets up the controller with the Manager.

type CronJobStep

type CronJobStep struct{}

func NewCronJobStep

func NewCronJobStep() *CronJobStep

func (*CronJobStep) Apply

func (s *CronJobStep) Apply(_ context.Context, req pipeline.CapsuleRequest) error

type DeploymentStep

type DeploymentStep struct{}

func NewDeploymentStep

func NewDeploymentStep() *DeploymentStep

func (*DeploymentStep) Apply

func (s *DeploymentStep) Apply(ctx context.Context, req pipeline.CapsuleRequest) error

type NetworkStep

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

func NewNetworkStep

func NewNetworkStep(cfg *v1alpha1.OperatorConfig) *NetworkStep

func (*NetworkStep) Apply

func (s *NetworkStep) Apply(_ context.Context, req pipeline.CapsuleRequest) error

type ServiceAccountStep

type ServiceAccountStep struct{}

func NewServiceAccountStep

func NewServiceAccountStep() *ServiceAccountStep

func (*ServiceAccountStep) Apply

func (s *ServiceAccountStep) Apply(_ context.Context, req pipeline.CapsuleRequest) error

type ServiceMonitorStep

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

func NewServiceMonitorStep

func NewServiceMonitorStep(cfg *v1alpha1.OperatorConfig) *ServiceMonitorStep

func (*ServiceMonitorStep) Apply

func (s *ServiceMonitorStep) Apply(_ context.Context, req pipeline.CapsuleRequest) error

type VPAStep

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

func NewVPAStep

func NewVPAStep(cfg *v1alpha1.OperatorConfig) *VPAStep

func (*VPAStep) Apply

func (s *VPAStep) Apply(_ context.Context, req pipeline.CapsuleRequest) error