controller

Documentation

Index

• Constants
• type DebugPredicate
  • func (p *DebugPredicate) Create(e event.CreateEvent) bool
  • func (p *DebugPredicate) Delete(e event.DeleteEvent) bool
  • func (p *DebugPredicate) Generic(e event.GenericEvent) bool
  • func (p *DebugPredicate) Update(e event.UpdateEvent) bool
• type UpdateReconciler
  • func (r *UpdateReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
  • func (r *UpdateReconciler) SetupWithManager(mgr ctrl.Manager) error
• type WorkspaceReconciler
  • func (r *WorkspaceReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
  • func (r *WorkspaceReconciler) SetupWithManager(mgr ctrl.Manager) error

Constants

const (
	SecretOutputsAnnotation = "pulumi.com/secrets"
	UpdateIndexerWorkspace  = "index.spec.workspaceRef"

	UpdateConditionTypeComplete    = "Complete"
	UpdateConditionTypeFailed      = "Failed"
	UpdateConditionTypeProgressing = "Progressing"

	UpdateConditionReasonComplete    = "Complete"
	UpdateConditionReasonUpdated     = "Updated"
	UpdateConditionReasonProgressing = "Progressing"
)

const (
	WorkspaceIndexerFluxSource  = "index.spec.flux.sourceRef"
	WorkspaceConditionTypeReady = autov1alpha1.WorkspaceReady
	PodAnnotationInitialized    = "auto.pulumi.com/initialized"
	PodAnnotationRevisionHash   = "auto.pulumi.com/revision-hash"

	// Termination grace period for the workspace pod and any update running in it.
	// Upon an update to the workspec spec or content, the statefulset will be updated,
	// leading to graceful pod replacement. The pod receives a SIGTERM signal and has
	// this much time to shut down before it is killed.
	WorkspacePodTerminationGracePeriodSeconds = 10 * 60
)

const (
	FieldManager                 = "pulumi-kubernetes-operator"
	WorkspacePulumiContainerName = "pulumi"
	WorkspaceShareVolumeName     = "share"
	WorkspaceShareMountPath      = "/share"
	WorkspaceGrpcPort            = 50051
)

Types

type DebugPredicate

type DebugPredicate struct {
	Controller string
}

func (*DebugPredicate) Create

func (p *DebugPredicate) Create(e event.CreateEvent) bool

func (*DebugPredicate) Delete

func (p *DebugPredicate) Delete(e event.DeleteEvent) bool

func (*DebugPredicate) Generic

func (p *DebugPredicate) Generic(e event.GenericEvent) bool

func (*DebugPredicate) Update

func (p *DebugPredicate) Update(e event.UpdateEvent) bool

type UpdateReconciler

type UpdateReconciler struct {
	client.Client
	Scheme   *runtime.Scheme
	Recorder record.EventRecorder
}

UpdateReconciler reconciles a Update object

func (*UpdateReconciler) Reconcile

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

Reconcile manages the Update CRD and initiates Pulumi operations.

func (*UpdateReconciler) SetupWithManager

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

SetupWithManager sets up the controller with the Manager.

type WorkspaceReconciler

type WorkspaceReconciler struct {
	client.Client
	Scheme   *runtime.Scheme
	Recorder record.EventRecorder
}

WorkspaceReconciler reconciles a Workspace object

func (*WorkspaceReconciler) Reconcile

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

func (*WorkspaceReconciler) SetupWithManager

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

SetupWithManager sets up the controller with the Manager.