installer

Documentation

Index

• Variables
• type InstallerController
  • func NewInstallerController(instanceName, targetNamespace, staticPodName string, ...) *InstallerController
  • func (c InstallerController) ControllerInstanceName() string
  • func (c InstallerController) Name() string
  • func (c *InstallerController) Run(ctx context.Context, workers int)
  • func (c InstallerController) Sync(ctx context.Context, syncCtx factory.SyncContext) error
  • func (c *InstallerController) WithCerts(certDir string, certConfigMaps, certSecrets []UnrevisionedResource) *InstallerController
  • func (c *InstallerController) WithInstallerPodMutationFn(installerPodMutationFn InstallerPodMutationFunc) *InstallerController
  • func (c *InstallerController) WithMinReadyDuration(minReadyDuration time.Duration) *InstallerController
  • func (c *InstallerController) WithStartupMonitorSupport(startupMonitorEnabled func() (bool, error)) *InstallerController
• type InstallerPodMutationFunc
• type Int32
• type UnrevisionedResource

Variables

var Int32KeySet = sets.Int32KeySet[any]

Int32KeySet creates a Int32 from a keys of a map[int32](? extends interface{}). If the value passed in is not actually a map, this will panic. Deprecated: Use k8s sets instead.

var NewInt32 = sets.NewInt32

NewInt32 creates a Int32 from a list of values. Deprecated: Use k8s sets instead.

Types

type InstallerController

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

InstallerController is a controller that watches the currentRevision and targetRevision fields for each node and spawn installer pods to update the static pods on the master nodes.

func NewInstallerController

func NewInstallerController(
	instanceName, targetNamespace, staticPodName string,
	configMaps []revision.RevisionResource,
	secrets []revision.RevisionResource,
	command []string,
	kubeInformersForTargetNamespace informers.SharedInformerFactory,
	operatorClient v1helpers.StaticPodOperatorClient,
	configMapsGetter corev1client.ConfigMapsGetter,
	secretsGetter corev1client.SecretsGetter,
	podsGetter corev1client.PodsGetter,
	eventRecorder events.Recorder,
) *InstallerController

NewInstallerController creates a new installer controller.

func (InstallerController) ControllerInstanceName

func (c InstallerController) ControllerInstanceName() string

ControllerInstanceName specifies the controller instance. Useful when the same controller is used multiple times.

func (InstallerController) Name

func (c InstallerController) Name() string

func (*InstallerController) Run

func (c *InstallerController) Run(ctx context.Context, workers int)

func (InstallerController) Sync

func (c InstallerController) Sync(ctx context.Context, syncCtx factory.SyncContext) error

func (*InstallerController) WithCerts

func (c *InstallerController) WithCerts(certDir string, certConfigMaps, certSecrets []UnrevisionedResource) *InstallerController

func (*InstallerController) WithInstallerPodMutationFn

func (c *InstallerController) WithInstallerPodMutationFn(installerPodMutationFn InstallerPodMutationFunc) *InstallerController

func (*InstallerController) WithMinReadyDuration

func (c *InstallerController) WithMinReadyDuration(minReadyDuration time.Duration) *InstallerController

func (*InstallerController) WithStartupMonitorSupport

func (c *InstallerController) WithStartupMonitorSupport(startupMonitorEnabled func() (bool, error)) *InstallerController

WithStartupMonitorSupport sets the predicate startupMonitorEnabled called on every sync to know whether startup monitor is deployed together with the operand static pod manifest, and the state machine can expect that the startup-monitor acknowledges a ready operand.

type InstallerPodMutationFunc

type InstallerPodMutationFunc func(pod *corev1.Pod, nodeName string, operatorSpec *operatorv1.StaticPodOperatorSpec, revision int32) error

InstallerPodMutationFunc is a function that has a chance at changing the installer pod before it is created

type Int32

type Int32 = sets.Int32

sets.Int32 is a set of int32s, implemented via map[int32]struct{} for minimal memory consumption. Deprecated: Use k8s sets instead.

type UnrevisionedResource

type UnrevisionedResource struct {
	Name     string
	Optional bool
}