cluster

Documentation

Overview

Package cluster intercepts write activity to Cluster objects.

Index

• func IsInvalidConfig(err error) bool
• func IsNotAllowed(err error) bool
• func IsNotFound(err error) bool
• func IsParsingFailed(err error) bool
• func UpgradeScheduleTimeIsValid(updateTime string) bool
• type Config
• type Mutator
  • func NewMutator(config config.Config) (*Mutator, error)
  • func (m *Mutator) DefaultCiliumCidrOnV18Upgrade(cluster capi.Cluster, currentRelease *semver.Version, ...) ([]mutator.PatchOperation, error)
  • func (m *Mutator) Log(keyVals ...interface{})
  • func (m *Mutator) Mutate(request *admissionv1.AdmissionRequest) ([]mutator.PatchOperation, error)
  • func (m *Mutator) MutateCreate(request *admissionv1.AdmissionRequest) ([]mutator.PatchOperation, error)
  • func (m *Mutator) MutateInfraRef(cluster capi.Cluster, releaseVersion *semver.Version) ([]mutator.PatchOperation, error)
  • func (m *Mutator) MutateOperatorVersion(cluster capi.Cluster, releaseVersion *semver.Version) ([]mutator.PatchOperation, error)
  • func (m *Mutator) MutateReleaseUpdate(cluster capi.Cluster, oldCluster capi.Cluster) ([]mutator.PatchOperation, error)
  • func (m *Mutator) MutateReleaseVersion(cluster capi.Cluster) ([]mutator.PatchOperation, error)
  • func (m *Mutator) MutateUpdate(request *admissionv1.AdmissionRequest) ([]mutator.PatchOperation, error)
  • func (m *Mutator) Resource() string
• type Validator
  • func NewValidator(config config.Config) (*Validator, error)
  • func (v *Validator) Cilium(cluster *capi.Cluster, oldCluster *capi.Cluster) error
  • func (v *Validator) ClusterAnnotationUpgradeReleaseIsValid(cluster *capi.Cluster) error
  • func (v *Validator) ClusterAnnotationUpgradeTimeIsValid(cluster *capi.Cluster, oldCluster *capi.Cluster) error
  • func (v *Validator) ClusterExists(obj metav1.Object) error
  • func (v *Validator) ClusterLabelKeysValid(oldCluster *capi.Cluster, newCluster *capi.Cluster) error
  • func (v *Validator) ClusterLabelValuesValid(oldCluster *capi.Cluster, newCluster *capi.Cluster) error
  • func (v *Validator) ClusterStatusValid(oldCluster *capi.Cluster, newCluster *capi.Cluster) error
  • func (v *Validator) EnsureGitopsPaused(cluster *capi.Cluster, oldCluster *capi.Cluster) error
  • func (v *Validator) Log(keyVals ...interface{})
  • func (v *Validator) ReleaseVersionValid(oldCluster *capi.Cluster, newCluster *capi.Cluster) error
  • func (v *Validator) Resource() string
  • func (v *Validator) UpgradeScheduleReleaseIsValid(targetRelease string, currentRelease string) error
  • func (v *Validator) Validate(request *admissionv1.AdmissionRequest) (bool, error)
  • func (v *Validator) ValidateCiliumIpamMode(cluster *capi.Cluster) error
  • func (v *Validator) ValidateCiliumIpamModeUnchanged(oldCluster *capi.Cluster, newCluster *capi.Cluster) error
  • func (v *Validator) ValidateCreate(request *admissionv1.AdmissionRequest) (bool, error)
  • func (v *Validator) ValidateUpdate(request *admissionv1.AdmissionRequest) (bool, error)

Functions

func IsInvalidConfig

func IsInvalidConfig(err error) bool

IsInvalidConfig asserts invalidConfigError.

func IsNotAllowed

func IsNotAllowed(err error) bool

IsNotAllowed asserts notAllowedError.

func IsNotFound

func IsNotFound(err error) bool

IsNotFound asserts notFoundError.

func IsParsingFailed

func IsParsingFailed(err error) bool

IsParsingFailed asserts parsingFailedError.

func UpgradeScheduleTimeIsValid

func UpgradeScheduleTimeIsValid(updateTime string) bool

Types

type Config

type Config struct {
	K8sClient k8sclient.Interface
	Logger    micrologger.Logger
}

type Mutator

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

Mutator for Cluster object.

func NewMutator

func NewMutator(config config.Config) (*Mutator, error)

func (*Mutator) DefaultCiliumCidrOnV18Upgrade

func (m *Mutator) DefaultCiliumCidrOnV18Upgrade(cluster capi.Cluster, currentRelease *semver.Version, targetRelease *semver.Version) ([]mutator.PatchOperation, error)

func (*Mutator) Log

func (m *Mutator) Log(keyVals ...interface{})

func (*Mutator) Mutate

func (m *Mutator) Mutate(request *admissionv1.AdmissionRequest) ([]mutator.PatchOperation, error)

Mutate is the function executed for every matching webhook request.

func (*Mutator) MutateCreate

func (m *Mutator) MutateCreate(request *admissionv1.AdmissionRequest) ([]mutator.PatchOperation, error)

MutateCreate is the function executed for every create webhook request.

func (*Mutator) MutateInfraRef

func (m *Mutator) MutateInfraRef(cluster capi.Cluster, releaseVersion *semver.Version) ([]mutator.PatchOperation, error)

func (*Mutator) MutateOperatorVersion

func (m *Mutator) MutateOperatorVersion(cluster capi.Cluster, releaseVersion *semver.Version) ([]mutator.PatchOperation, error)

func (*Mutator) MutateReleaseUpdate

func (m *Mutator) MutateReleaseUpdate(cluster capi.Cluster, oldCluster capi.Cluster) ([]mutator.PatchOperation, error)

func (*Mutator) MutateReleaseVersion

func (m *Mutator) MutateReleaseVersion(cluster capi.Cluster) ([]mutator.PatchOperation, error)

func (*Mutator) MutateUpdate

func (m *Mutator) MutateUpdate(request *admissionv1.AdmissionRequest) ([]mutator.PatchOperation, error)

MutateUpdate is the function executed for every update webhook request.

func (*Mutator) Resource

func (m *Mutator) Resource() string

type Validator

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

func NewValidator

func NewValidator(config config.Config) (*Validator, error)

func (*Validator) Cilium

func (v *Validator) Cilium(cluster *capi.Cluster, oldCluster *capi.Cluster) error

func (*Validator) ClusterAnnotationUpgradeReleaseIsValid

func (v *Validator) ClusterAnnotationUpgradeReleaseIsValid(cluster *capi.Cluster) error

func (*Validator) ClusterAnnotationUpgradeTimeIsValid

func (v *Validator) ClusterAnnotationUpgradeTimeIsValid(cluster *capi.Cluster, oldCluster *capi.Cluster) error

func (*Validator) ClusterExists

func (v *Validator) ClusterExists(obj metav1.Object) error

func (*Validator) ClusterLabelKeysValid

func (v *Validator) ClusterLabelKeysValid(oldCluster *capi.Cluster, newCluster *capi.Cluster) error

func (*Validator) ClusterLabelValuesValid

func (v *Validator) ClusterLabelValuesValid(oldCluster *capi.Cluster, newCluster *capi.Cluster) error

func (*Validator) ClusterStatusValid

func (v *Validator) ClusterStatusValid(oldCluster *capi.Cluster, newCluster *capi.Cluster) error

func (*Validator) EnsureGitopsPaused

func (v *Validator) EnsureGitopsPaused(cluster *capi.Cluster, oldCluster *capi.Cluster) error

func (*Validator) Log

func (v *Validator) Log(keyVals ...interface{})

func (*Validator) ReleaseVersionValid

func (v *Validator) ReleaseVersionValid(oldCluster *capi.Cluster, newCluster *capi.Cluster) error

func (*Validator) Resource

func (v *Validator) Resource() string

func (*Validator) UpgradeScheduleReleaseIsValid

func (v *Validator) UpgradeScheduleReleaseIsValid(targetRelease string, currentRelease string) error

func (*Validator) Validate

func (v *Validator) Validate(request *admissionv1.AdmissionRequest) (bool, error)

func (*Validator) ValidateCiliumIpamMode

func (v *Validator) ValidateCiliumIpamMode(cluster *capi.Cluster) error

func (*Validator) ValidateCiliumIpamModeUnchanged

func (v *Validator) ValidateCiliumIpamModeUnchanged(oldCluster *capi.Cluster, newCluster *capi.Cluster) error

func (*Validator) ValidateCreate

func (v *Validator) ValidateCreate(request *admissionv1.AdmissionRequest) (bool, error)

func (*Validator) ValidateUpdate

func (v *Validator) ValidateUpdate(request *admissionv1.AdmissionRequest) (bool, error)