forked from knative/serving
/
config.go
91 lines (79 loc) · 2.87 KB
/
config.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
/*
Copyright 2018 The Knative Authors
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
https://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 gc
import (
"errors"
"strconv"
"time"
corev1 "k8s.io/api/core/v1"
"knative.dev/pkg/configmap"
)
const (
ConfigName = "config-gc"
)
type Config struct {
// Delay duration after a revision create before considering it for GC
StaleRevisionCreateDelay time.Duration
// Timeout since a revision lastPinned before it should be GC'd
// This must be longer than the controller resync period
StaleRevisionTimeout time.Duration
// Minimum number of generations of revisions to keep before considering for GC
StaleRevisionMinimumGenerations int64
// Minimum staleness duration before updating lastPinned
StaleRevisionLastpinnedDebounce time.Duration
}
func NewConfigFromConfigMapFunc(logger configmap.Logger, minRevisionTimeout time.Duration) func(configMap *corev1.ConfigMap) (*Config, error) {
return func(configMap *corev1.ConfigMap) (*Config, error) {
c := Config{}
for _, dur := range []struct {
key string
field *time.Duration
defaultValue time.Duration
}{{
key: "stale-revision-create-delay",
field: &c.StaleRevisionCreateDelay,
defaultValue: 24 * time.Hour,
}, {
key: "stale-revision-timeout",
field: &c.StaleRevisionTimeout,
defaultValue: 15 * time.Hour,
}, {
key: "stale-revision-lastpinned-debounce",
field: &c.StaleRevisionLastpinnedDebounce,
defaultValue: 5 * time.Hour,
}} {
if raw, ok := configMap.Data[dur.key]; !ok {
*dur.field = dur.defaultValue
} else if val, err := time.ParseDuration(raw); err != nil {
return nil, err
} else {
*dur.field = val
}
}
if raw, ok := configMap.Data["stale-revision-minimum-generations"]; !ok {
c.StaleRevisionMinimumGenerations = 1
} else if val, err := strconv.ParseInt(raw, 10, 64); err != nil {
return nil, err
} else if val < 0 {
return nil, errors.New("stale-revision-minimum-generations must be zero or greater")
} else {
c.StaleRevisionMinimumGenerations = val
}
if c.StaleRevisionTimeout-c.StaleRevisionLastpinnedDebounce < minRevisionTimeout {
logger.Errorf("Got revision timeout of %v, minimum supported value is %v", c.StaleRevisionTimeout, minRevisionTimeout+c.StaleRevisionLastpinnedDebounce)
c.StaleRevisionTimeout = minRevisionTimeout + c.StaleRevisionLastpinnedDebounce
return &c, nil
}
return &c, nil
}
}