-
Notifications
You must be signed in to change notification settings - Fork 450
/
shoot_care_control_types.go
122 lines (107 loc) · 4.77 KB
/
shoot_care_control_types.go
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
// Copyright (c) 2021 SAP SE or an SAP affiliate company. All rights reserved. This file is licensed under the Apache Software License, v. 2 except as noted otherwise in the LICENSE file
//
// Licensed under the Apache License, Version 2.0 (the "License");
// you may not use this file except in compliance with the License.
// You may obtain a copy of the License at
//
// http://www.apache.org/licenses/LICENSE-2.0
//
// Unless required by applicable law or agreed to in writing, software
// distributed under the License is distributed on an "AS IS" BASIS,
// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
// See the License for the specific language governing permissions and
// limitations under the License.
package shoot
import (
"context"
"time"
gardencorev1beta1 "github.com/gardener/gardener/pkg/apis/core/v1beta1"
"github.com/gardener/gardener/pkg/client/core/informers/externalversions/core/v1beta1"
"github.com/gardener/gardener/pkg/client/kubernetes"
"github.com/gardener/gardener/pkg/client/kubernetes/clientmap"
"github.com/gardener/gardener/pkg/gardenlet/apis/config"
"github.com/gardener/gardener/pkg/operation"
"github.com/gardener/gardener/pkg/operation/care"
"github.com/gardener/gardener/pkg/utils/imagevector"
"github.com/sirupsen/logrus"
corev1 "k8s.io/api/core/v1"
metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
)
// HealthCheck is an interface used to perform health checks.
type HealthCheck interface {
Check(ctx context.Context, thresholdMapping map[gardencorev1beta1.ConditionType]time.Duration, threshold *metav1.Duration, conditions []gardencorev1beta1.Condition) []gardencorev1beta1.Condition
}
// NewHealthCheckFunc is a function used to create a new instance for performing health checks.
type NewHealthCheckFunc func(op *operation.Operation, init care.ShootClientInit) HealthCheck
// defaultNewHealthCheck is the default function to create a new instance for performing health checks.
var defaultNewHealthCheck NewHealthCheckFunc = func(op *operation.Operation, init care.ShootClientInit) HealthCheck {
return care.NewHealth(op, init)
}
// ConstraintCheck is an interface used to perform constraint checks.
type ConstraintCheck interface {
Check(ctx context.Context, constraints []gardencorev1beta1.Condition) []gardencorev1beta1.Condition
}
// NewConstraintCheckFunc is a function used to create a new instance for performing constraint checks.
type NewConstraintCheckFunc func(op *operation.Operation, init care.ShootClientInit) ConstraintCheck
// defaultNewConstraintCheck is the default function to create a new instance for performing constraint checks.
var defaultNewConstraintCheck = func(op *operation.Operation, init care.ShootClientInit) ConstraintCheck {
return care.NewConstraint(op, init)
}
// GarbageCollector is an interface used to perform garbage collection.
type GarbageCollector interface {
Collect(ctx context.Context)
}
// NewGarbageCollectorFunc is a function used to create a new instance to perform garbage collection.
type NewGarbageCollectorFunc func(op *operation.Operation, init care.ShootClientInit) GarbageCollector
// defaultNewGarbageCollector is the default function to create a new instance to perform garbage collection.
var defaultNewGarbageCollector = func(op *operation.Operation, init care.ShootClientInit) GarbageCollector {
return care.NewGarbageCollection(op, init)
}
// NewOperationFunc is a function used to create a new `operation.Operation` instance.
type NewOperationFunc func(
ctx context.Context,
gardenClient kubernetes.Interface,
seedClient kubernetes.Interface,
config *config.GardenletConfiguration,
gardenerInfo *gardencorev1beta1.Gardener,
gardenClusterIdentity string,
secrets map[string]*corev1.Secret,
imageVector imagevector.ImageVector,
k8sGardenCoreInformers v1beta1.Interface,
clientMap clientmap.ClientMap,
shoot *gardencorev1beta1.Shoot,
logger *logrus.Entry,
) (
*operation.Operation,
error,
)
var defaultNewOperationFunc = func(
ctx context.Context,
gardenClient kubernetes.Interface,
seedClient kubernetes.Interface,
config *config.GardenletConfiguration,
gardenerInfo *gardencorev1beta1.Gardener,
gardenClusterIdentity string,
secrets map[string]*corev1.Secret,
imageVector imagevector.ImageVector,
k8sGardenCoreInformers v1beta1.Interface,
clientMap clientmap.ClientMap,
shoot *gardencorev1beta1.Shoot,
logger *logrus.Entry,
) (
*operation.Operation,
error,
) {
return operation.
NewBuilder().
WithLogger(logger).
WithConfig(config).
WithGardenerInfo(gardenerInfo).
WithGardenClusterIdentity(gardenClusterIdentity).
WithSecrets(secrets).
WithImageVector(imageVector).
WithGardenFrom(k8sGardenCoreInformers, shoot.Namespace).
WithSeedFrom(k8sGardenCoreInformers, *shoot.Spec.SeedName).
WithShootFromCluster(gardenClient, seedClient, shoot).
Build(ctx, clientMap)
}