forked from vmware-archive/kubeless
/
autoscaleCreate.go
83 lines (73 loc) · 2.48 KB
/
autoscaleCreate.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
package autoscale
import (
"github.com/kubeless/kubeless/pkg/utils"
"github.com/sirupsen/logrus"
"github.com/spf13/cobra"
)
var autoscaleCreateCmd = &cobra.Command{
Use: "create <name> FLAG",
Short: "automatically scale function based on monitored metrics",
Long: `automatically scale function based on monitored metrics`,
Run: func(cmd *cobra.Command, args []string) {
if len(args) != 1 {
logrus.Fatal("Need exactly one argument - function name")
}
funcName := args[0]
ns, err := cmd.Flags().GetString("namespace")
if err != nil {
logrus.Fatal(err)
}
if ns == "" {
ns = utils.GetDefaultNamespace()
}
function, err := utils.GetFunction(funcName, ns)
if err != nil {
logrus.Fatalf("Unable to find the function %s. Received %s: ", funcName, err)
}
min, err := cmd.Flags().GetInt32("min")
if err != nil {
logrus.Fatal(err)
} else if min <= 0 {
logrus.Fatalf("min can't be negative or zero")
}
max, err := cmd.Flags().GetInt32("max")
if err != nil {
logrus.Fatal(err)
} else if max < min {
logrus.Fatalf("max must be greater than or equal to min")
}
metric, err := cmd.Flags().GetString("metric")
if err != nil {
logrus.Fatal(err)
}
if metric != "cpu" && metric != "qps" {
logrus.Fatalf("only supported metrics: cpu, qps")
}
value, err := cmd.Flags().GetString("value")
if err != nil {
logrus.Fatal(err)
}
hpa, err := getHorizontalAutoscaleDefinition(funcName, ns, metric, min, max, value, function.ObjectMeta.Labels)
if err != nil {
logrus.Fatal(err)
}
function.Spec.HorizontalPodAutoscaler = hpa
kubelessClient, err := utils.GetKubelessClientOutCluster()
if err != nil {
logrus.Fatal(err)
}
logrus.Infof("Adding autoscaling rule to the function...")
err = utils.UpdateFunctionCustomResource(kubelessClient, &function)
if err != nil {
logrus.Fatal(err)
}
logrus.Infof("Autoscaling rule for %s submitted for deployment", funcName)
},
}
func init() {
autoscaleCreateCmd.Flags().Int32("min", 1, "minimum number of replicas")
autoscaleCreateCmd.Flags().Int32("max", 1, "maximum number of replicas")
autoscaleCreateCmd.Flags().String("metric", "cpu", "metric to use for calculating the autoscale. Supported metrics: cpu, qps")
autoscaleCreateCmd.Flags().String("value", "", "value of the average of the metric across all replicas. If metric is cpu, value is a number represented as percentage. If metric is qps, value must be in format of Quantity")
autoscaleCreateCmd.MarkFlagRequired("value")
}