operation

Documentation

Index

• type Builder
  • func NewBuilder() *Builder
  • func (b *Builder) Build(ctx context.Context, clientMap clientmap.ClientMap) (*Operation, error)
  • func (b *Builder) WithConfig(cfg *config.GardenletConfiguration) *Builder
  • func (b *Builder) WithExposureClassHandlerFromConfig(cfg *config.GardenletConfiguration) *Builder
  • func (b *Builder) WithGarden(g *garden.Garden) *Builder
  • func (b *Builder) WithGardenClusterIdentity(gardenClusterIdentity string) *Builder
  • func (b *Builder) WithGardenFrom(reader client.Reader, namespace string) *Builder
  • func (b *Builder) WithGardenerInfo(gardenerInfo *gardencorev1beta1.Gardener) *Builder
  • func (b *Builder) WithImageVector(imageVector imagevector.ImageVector) *Builder
  • func (b *Builder) WithLogger(logger logrus.FieldLogger) *Builder
  • func (b *Builder) WithSecrets(secrets map[string]*corev1.Secret) *Builder
  • func (b *Builder) WithSeed(s *seed.Seed) *Builder
  • func (b *Builder) WithSeedFrom(gardenClient client.Reader, seedName string) *Builder
  • func (b *Builder) WithShoot(s *shootpkg.Shoot) *Builder
  • func (b *Builder) WithShootFromCluster(gardenClient, seedClient kubernetes.Interface, s *gardencorev1beta1.Shoot) *Builder
• type Operation
  • func (o *Operation) AllSecretKeys() []string
  • func (o *Operation) CleanShootTaskErrorAndUpdateStatusLabel(ctx context.Context, taskID string)
  • func (o *Operation) ComputeAlertManagerHost() string
  • func (o *Operation) ComputeAlertManagerHosts() []string
  • func (o *Operation) ComputeGrafanaHosts() []string
  • func (o *Operation) ComputeGrafanaOperatorsHost() string
  • func (o *Operation) ComputeGrafanaUsersHost() string
  • func (o *Operation) ComputeIngressHost(prefix string) string
  • func (o *Operation) ComputeLokiHost() string
  • func (o *Operation) ComputeLokiHosts() []string
  • func (o *Operation) ComputePrometheusHost() string
  • func (o *Operation) ComputePrometheusHosts() []string
  • func (o *Operation) DeleteCheckSum(key string)
  • func (o *Operation) DeleteClusterResourceFromSeed(ctx context.Context) error
  • func (o *Operation) DeleteSecret(key string)
  • func (o *Operation) DeleteShootState(ctx context.Context) error
  • func (o *Operation) EnsureShootStateExists(ctx context.Context) error
  • func (o *Operation) GetSecretKeysOfRole(kind string) []string
  • func (o *Operation) GetShootState() *gardencorev1alpha1.ShootState
  • func (o *Operation) InitializeDesiredShootClients(ctx context.Context) error
  • func (o *Operation) InitializeSeedClients(ctx context.Context) error
  • func (o *Operation) InitializeShootClients(ctx context.Context) error
  • func (o *Operation) InjectSeedSeedImages(values map[string]interface{}, names ...string) (map[string]interface{}, error)
  • func (o *Operation) InjectSeedShootImages(values map[string]interface{}, names ...string) (map[string]interface{}, error)
  • func (o *Operation) InjectShootShootImages(values map[string]interface{}, names ...string) (map[string]interface{}, error)
  • func (o *Operation) IsAPIServerRunning(ctx context.Context) (bool, error)
  • func (o *Operation) LoadCheckSum(key string) string
  • func (o *Operation) LoadSecret(key string) *corev1.Secret
  • func (o *Operation) ReportShootProgress(ctx context.Context, stats *flow.Stats)
  • func (o *Operation) SaveGardenerResourceDataInShootState(ctx context.Context, f func(*[]gardencorev1alpha1.GardenerResourceData) error) error
  • func (o *Operation) SeedVersion() string
  • func (o *Operation) SetShootState(shootState *gardencorev1alpha1.ShootState)
  • func (o *Operation) ShootVersion() string
  • func (o *Operation) StoreCheckSum(key, value string)
  • func (o *Operation) StoreSecret(key string, secret *corev1.Secret)
  • func (o *Operation) ToAdvertisedAddresses() []gardencorev1beta1.ShootAdvertisedAddress

Types

type Builder

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

Builder is an object that builds Operation objects.

func NewBuilder

func NewBuilder() *Builder

NewBuilder returns a new Builder.

func (*Builder) Build

func (b *Builder) Build(ctx context.Context, clientMap clientmap.ClientMap) (*Operation, error)

Build initializes a new Operation object.

func (*Builder) WithConfig

func (b *Builder) WithConfig(cfg *config.GardenletConfiguration) *Builder

WithConfig sets the configFunc attribute at the Builder.

func (*Builder) WithExposureClassHandlerFromConfig

func (b *Builder) WithExposureClassHandlerFromConfig(cfg *config.GardenletConfiguration) *Builder

WithExposureClassHandlerFromConfig sets the exposureClassFunc attribute at the Builder which will find the the required exposure class handler in the passed Gardenlet config.

func (*Builder) WithGarden

func (b *Builder) WithGarden(g *garden.Garden) *Builder

WithGarden sets the gardenFunc attribute at the Builder.

func (*Builder) WithGardenClusterIdentity

func (b *Builder) WithGardenClusterIdentity(gardenClusterIdentity string) *Builder

WithGardenClusterIdentity sets the identity of the Garden cluster as attribute at the Builder.

func (*Builder) WithGardenFrom

func (b *Builder) WithGardenFrom(reader client.Reader, namespace string) *Builder

WithGardenFrom sets the gardenFunc attribute at the Builder which will build a new Garden object.

func (*Builder) WithGardenerInfo

func (b *Builder) WithGardenerInfo(gardenerInfo *gardencorev1beta1.Gardener) *Builder

WithGardenerInfo sets the gardenerInfoFunc attribute at the Builder.

func (*Builder) WithImageVector

func (b *Builder) WithImageVector(imageVector imagevector.ImageVector) *Builder

WithImageVector sets the imageVectorFunc attribute at the Builder.

func (*Builder) WithLogger

func (b *Builder) WithLogger(logger logrus.FieldLogger) *Builder

WithLogger sets the loggerFunc attribute at the Builder.

func (*Builder) WithSecrets

func (b *Builder) WithSecrets(secrets map[string]*corev1.Secret) *Builder

WithSecrets sets the secretsFunc attribute at the Builder.

func (*Builder) WithSeed

func (b *Builder) WithSeed(s *seed.Seed) *Builder

WithSeed sets the seedFunc attribute at the Builder.

func (*Builder) WithSeedFrom

func (b *Builder) WithSeedFrom(gardenClient client.Reader, seedName string) *Builder

WithSeedFrom sets the seedFunc attribute at the Builder which will build a new Seed object.

func (*Builder) WithShoot

func (b *Builder) WithShoot(s *shootpkg.Shoot) *Builder

WithShoot sets the shootFunc attribute at the Builder.

func (*Builder) WithShootFromCluster

func (b *Builder) WithShootFromCluster(gardenClient, seedClient kubernetes.Interface, s *gardencorev1beta1.Shoot) *Builder

WithShootFromCluster sets the shootFunc attribute at the Builder which will build a new Shoot object constructed from the cluster resource. The shoot status is still taken from the passed `shoot`, though.

type Operation

type Operation struct {
	Config                    *config.GardenletConfiguration
	Logger                    logrus.FieldLogger
	GardenerInfo              *gardencorev1beta1.Gardener
	GardenClusterIdentity     string
	ImageVector               imagevector.ImageVector
	Garden                    *garden.Garden
	Seed                      *seed.Seed
	Shoot                     *shoot.Shoot
	ManagedSeed               *seedmanagementv1alpha1.ManagedSeed
	ManagedSeedAPIServer      *gardencorev1beta1helper.ShootedSeedAPIServer
	ClientMap                 clientmap.ClientMap
	K8sGardenClient           kubernetes.Interface
	K8sSeedClient             kubernetes.Interface
	K8sShootClient            kubernetes.Interface
	APIServerAddress          string
	APIServerClusterIP        string
	APIServerHealthCheckToken string
	PromtailRBACAuthToken     string
	SeedNamespaceObject       *corev1.Namespace
	MonitoringClient          prometheusclient.API
	ExposureClassHandler      *config.ExposureClassHandler

	// ControlPlaneWildcardCert is a wildcard tls certificate which is issued for the seed's ingress domain.
	ControlPlaneWildcardCert *corev1.Secret
	// contains filtered or unexported fields
}

Operation contains all data required to perform an operation on a Shoot cluster.

func (*Operation) AllSecretKeys

func (o *Operation) AllSecretKeys() []string

AllSecretKeys returns all stored secret keys from the operation. Calling this function is thread-safe.

func (*Operation) CleanShootTaskErrorAndUpdateStatusLabel

func (o *Operation) CleanShootTaskErrorAndUpdateStatusLabel(ctx context.Context, taskID string)

CleanShootTaskErrorAndUpdateStatusLabel removes the error with taskID from the Shoot's status.LastErrors array. If the status.LastErrors array is empty then status.LastErrors is also removed. It also re-evaluates the shoot status in case the last error list is empty now, and if necessary, updates the status label on the shoot.

func (*Operation) ComputeAlertManagerHost

func (o *Operation) ComputeAlertManagerHost() string

ComputeAlertManagerHost computes the host for alert manager.

func (*Operation) ComputeAlertManagerHosts

func (o *Operation) ComputeAlertManagerHosts() []string

ComputeAlertManagerHosts computes the host for alert manager.

func (*Operation) ComputeGrafanaHosts

func (o *Operation) ComputeGrafanaHosts() []string

ComputeGrafanaHosts computes the host for both grafanas.

func (*Operation) ComputeGrafanaOperatorsHost

func (o *Operation) ComputeGrafanaOperatorsHost() string

ComputeGrafanaOperatorsHost computes the host for users Grafana.

func (*Operation) ComputeGrafanaUsersHost

func (o *Operation) ComputeGrafanaUsersHost() string

ComputeGrafanaUsersHost computes the host for operators Grafana.

func (*Operation) ComputeIngressHost

func (o *Operation) ComputeIngressHost(prefix string) string

ComputeIngressHost computes the host for a given prefix.

func (*Operation) ComputeLokiHost

func (o *Operation) ComputeLokiHost() string

ComputeLokiHost computes the host for loki.

func (*Operation) ComputeLokiHosts

func (o *Operation) ComputeLokiHosts() []string

ComputeLokiHosts computes the host for loki.

func (*Operation) ComputePrometheusHost

func (o *Operation) ComputePrometheusHost() string

ComputePrometheusHost computes the host for prometheus.

func (*Operation) ComputePrometheusHosts

func (o *Operation) ComputePrometheusHosts() []string

ComputePrometheusHosts computes the hosts for prometheus.

func (*Operation) DeleteCheckSum

func (o *Operation) DeleteCheckSum(key string)

DeleteCheckSum deletes the checksum entry under the given key from the operation. Calling this function is thread-safe.

func (*Operation) DeleteClusterResourceFromSeed

func (o *Operation) DeleteClusterResourceFromSeed(ctx context.Context) error

DeleteClusterResourceFromSeed deletes the `Cluster` extension resource for the shoot in the seed cluster.

func (*Operation) DeleteSecret

func (o *Operation) DeleteSecret(key string)

DeleteSecret deleted the secret under the given key from the operation. Calling this function is thread-safe.

func (*Operation) DeleteShootState

func (o *Operation) DeleteShootState(ctx context.Context) error

DeleteShootState deletes the ShootState resource for the corresponding shoot.

func (*Operation) EnsureShootStateExists

func (o *Operation) EnsureShootStateExists(ctx context.Context) error

EnsureShootStateExists creates the ShootState resource for the corresponding shoot and updates the operations object

func (*Operation) GetSecretKeysOfRole

func (o *Operation) GetSecretKeysOfRole(kind string) []string

GetSecretKeysOfRole returns a list of keys which are present in the Garden Secrets map and which are prefixed with <kind>.

func (*Operation) GetShootState

func (o *Operation) GetShootState() *gardencorev1alpha1.ShootState

GetShootState returns the shootstate resource of this Shoot in a concurrency safe way. This method should be used only for reading the data of the returned shootstate resource. The returned shootstate resource MUST NOT BE MODIFIED (except in test code) since this might interfere with other concurrent reads and writes. To properly update the shootstate resource of this Shoot use SaveGardenerResourceDataInShootState.

func (*Operation) InitializeDesiredShootClients

func (o *Operation) InitializeDesiredShootClients(ctx context.Context) error

InitializeDesiredShootClients will use the Seed Kubernetes client to read the gardener Secret in the Seed cluster which contains a Kubeconfig that can be used to authenticate against the Shoot cluster. With it, a Kubernetes client as well as a Chart renderer for the Shoot cluster will be initialized and attached to the already existing Operation object. In contrast to InitializeShootClients, InitializeDesiredShootClients returns an error if the discovered version via the client does not match the desired Kubernetes version from the shoot spec. This is especially useful, if the client is initialized after a rolling update of the Kube-Apiserver and you want to ensure that the discovered version matches the expected version.

func (*Operation) InitializeSeedClients

func (o *Operation) InitializeSeedClients(ctx context.Context) error

InitializeSeedClients will use the Garden Kubernetes client to read the Seed Secret in the Garden cluster which contains a Kubeconfig that can be used to authenticate against the Seed cluster. With it, a Kubernetes client as well as a Chart renderer for the Seed cluster will be initialized and attached to the already existing Operation object.

func (*Operation) InitializeShootClients

func (o *Operation) InitializeShootClients(ctx context.Context) error

InitializeShootClients will use the Seed Kubernetes client to read the gardener Secret in the Seed cluster which contains a Kubeconfig that can be used to authenticate against the Shoot cluster. With it, a Kubernetes client as well as a Chart renderer for the Shoot cluster will be initialized and attached to the already existing Operation object.

func (*Operation) InjectSeedSeedImages

func (o *Operation) InjectSeedSeedImages(values map[string]interface{}, names ...string) (map[string]interface{}, error)

InjectSeedSeedImages injects images that shall run on the Seed and target the Seed's Kubernetes version.

func (*Operation) InjectSeedShootImages

func (o *Operation) InjectSeedShootImages(values map[string]interface{}, names ...string) (map[string]interface{}, error)

InjectSeedShootImages injects images that shall run on the Seed but target the Shoot's Kubernetes version.

func (*Operation) InjectShootShootImages

func (o *Operation) InjectShootShootImages(values map[string]interface{}, names ...string) (map[string]interface{}, error)

InjectShootShootImages injects images that shall run on the Shoot and target the Shoot's Kubernetes version.

func (*Operation) IsAPIServerRunning

func (o *Operation) IsAPIServerRunning(ctx context.Context) (bool, error)

IsAPIServerRunning checks if the API server of the Shoot currently running (not scaled-down/deleted).

func (*Operation) LoadCheckSum

func (o *Operation) LoadCheckSum(key string) string

LoadCheckSum loads the checksum value under the given key from the operation. Calling this function is thread-safe.

func (*Operation) LoadSecret

func (o *Operation) LoadSecret(key string) *corev1.Secret

LoadSecret loads the secret under the given key from the operation. Calling this function is thread-safe. Be aware that the returned pointer and the underlying secret map refer to the same secret object. If you need to modify the returned secret, copy it first and store the changes via `StoreSecret`.

func (*Operation) ReportShootProgress

func (o *Operation) ReportShootProgress(ctx context.Context, stats *flow.Stats)

ReportShootProgress will update the last operation object in the Shoot manifest `status` section by the current progress of the Flow execution.

func (*Operation) SaveGardenerResourceDataInShootState

func (o *Operation) SaveGardenerResourceDataInShootState(ctx context.Context, f func(*[]gardencorev1alpha1.GardenerResourceData) error) error

SaveGardenerResourceDataInShootState updates the shootstate resource of this Shoot in a concurrency safe way, using the given context and mutate function. The mutate function should modify the passed GardenerResourceData so that changes are persisted. This method is protected by a mutex, so only a single SaveGardenerResourceDataInShootState operation can be executed at any point in time.

func (*Operation) SeedVersion

func (o *Operation) SeedVersion() string

SeedVersion is a shorthand for the kubernetes version of the K8sSeedClient.

func (*Operation) SetShootState

func (o *Operation) SetShootState(shootState *gardencorev1alpha1.ShootState)

SetShootState sets the shootstate resource of this Shoot in a concurrency safe way. This method is not protected by a mutex and does not update the shootstate resource in the cluster and so should be used only in exceptional situations, or as a convenience in test code. The shootstate passed as a parameter MUST NOT BE MODIFIED after the call to SetShootState (except in test code) since this might interfere with other concurrent reads and writes. To properly update the shootstate resource of this Shoot use SaveGardenerResourceDataInShootState.

func (*Operation) ShootVersion

func (o *Operation) ShootVersion() string

ShootVersion is a shorthand for the desired kubernetes version of the operation's shoot.

func (*Operation) StoreCheckSum

func (o *Operation) StoreCheckSum(key, value string)

StoreCheckSum stores the passed checksum under the given key from the operation. Calling this function is thread-safe.

func (*Operation) StoreSecret

func (o *Operation) StoreSecret(key string, secret *corev1.Secret)

StoreSecret stores the passed secret under the given key from the operation. Calling this function is thread-safe.

func (*Operation) ToAdvertisedAddresses

func (o *Operation) ToAdvertisedAddresses() []gardencorev1beta1.ShootAdvertisedAddress

ToAdvertisedAddresses returns list of advertised addresses on a Shoot cluster.