installer

Documentation

Index

• type InstallerController
  • func NewInstallerController(targetNamespace, staticPodName string, configMaps []revision.RevisionResource, ...) *InstallerController
  • func (c *InstallerController) Run(ctx context.Context, workers int)
  • func (c *InstallerController) WithCerts(certDir string, certConfigMaps, certSecrets []revision.RevisionResource) *InstallerController
  • func (c *InstallerController) WithInstallerPodMutationFn(installerPodMutationFn InstallerPodMutationFunc) *InstallerController
• type InstallerPodMutationFunc
• type Int32
  • func Int32KeySet(theMap interface{}) Int32
  • func NewInt32(items ...int32) Int32
  • func (s Int32) Delete(items ...int32)
  • func (s Int32) Difference(s2 Int32) Int32
  • func (s1 Int32) Equal(s2 Int32) bool
  • func (s Int32) Has(item int32) bool
  • func (s Int32) HasAll(items ...int32) bool
  • func (s Int32) HasAny(items ...int32) bool
  • func (s Int32) Insert(items ...int32)
  • func (s1 Int32) Intersection(s2 Int32) Int32
  • func (s1 Int32) IsSuperset(s2 Int32) bool
  • func (s Int32) Len() int
  • func (s Int32) List() []int32
  • func (s Int32) PopAny() (int32, bool)
  • func (s1 Int32) Union(s2 Int32) Int32
  • func (s Int32) UnsortedList() []int32

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(
	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) Run

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

Run starts the kube-apiserver and blocks until stopCh is closed.

func (*InstallerController) WithCerts

func (c *InstallerController) WithCerts(certDir string, certConfigMaps, certSecrets []revision.RevisionResource) *InstallerController

func (*InstallerController) WithInstallerPodMutationFn

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

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 map[int32]sets.Empty

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

func Int32KeySet

func Int32KeySet(theMap interface{}) Int32

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.

func NewInt32

func NewInt32(items ...int32) Int32

NewInt32 creates a Int32 from a list of values.

func (Int32) Delete

func (s Int32) Delete(items ...int32)

Delete removes all items from the set.

func (Int32) Difference

func (s Int32) Difference(s2 Int32) Int32

Difference returns a set of objects that are not in s2 For example: s1 = {a1, a2, a3} s2 = {a1, a2, a4, a5} s1.Difference(s2) = {a3} s2.Difference(s1) = {a4, a5}

func (Int32) Equal

func (s1 Int32) Equal(s2 Int32) bool

Equal returns true if and only if s1 is equal (as a set) to s2. Two sets are equal if their membership is identical. (In practice, this means same elements, order doesn't matter)

func (Int32) Has

func (s Int32) Has(item int32) bool

Has returns true if and only if item is contained in the set.

func (Int32) HasAll

func (s Int32) HasAll(items ...int32) bool

HasAll returns true if and only if all items are contained in the set.

func (Int32) HasAny

func (s Int32) HasAny(items ...int32) bool

HasAny returns true if any items are contained in the set.

func (Int32) Insert

func (s Int32) Insert(items ...int32)

Insert adds items to the set.

func (Int32) Intersection

func (s1 Int32) Intersection(s2 Int32) Int32

Intersection returns a new set which includes the item in BOTH s1 and s2 For example: s1 = {a1, a2} s2 = {a2, a3} s1.Intersection(s2) = {a2}

func (Int32) IsSuperset

func (s1 Int32) IsSuperset(s2 Int32) bool

IsSuperset returns true if and only if s1 is a superset of s2.

func (Int32) Len

func (s Int32) Len() int

Len returns the size of the set.

func (Int32) List

func (s Int32) List() []int32

List returns the contents as a sorted int32 slice.

func (Int32) PopAny

func (s Int32) PopAny() (int32, bool)

Returns a single element from the set.

func (Int32) Union

func (s1 Int32) Union(s2 Int32) Int32

Union returns a new set which includes items in either s1 or s2. For example: s1 = {a1, a2} s2 = {a3, a4} s1.Union(s2) = {a1, a2, a3, a4} s2.Union(s1) = {a1, a2, a3, a4}

func (Int32) UnsortedList

func (s Int32) UnsortedList() []int32

UnsortedList returns the slice with contents in random order.