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.
*/
packageinitialresources
import(
"flag"
"fmt"
"io"
"sort"
"strings"
"time"
"github.com/golang/glog"
apierrors"k8s.io/apimachinery/pkg/api/errors"
"k8s.io/apimachinery/pkg/api/resource"
"k8s.io/apiserver/pkg/admission"
api"k8s.io/kubernetes/pkg/apis/core"
)
var(
source=flag.String("ir-data-source","influxdb","Data source used by InitialResources. Supported options: influxdb, gcm.")
percentile=flag.Int64("ir-percentile",90,"Which percentile of samples should InitialResources use when estimating resources. For experiment purposes.")
nsOnly=flag.Bool("ir-namespace-only",false,"Whether the estimation should be made only based on data from the same namespace.")
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.
*/
packageinitialresources
import(
"flag"
"fmt"
api"k8s.io/kubernetes/pkg/apis/core"
"time"
)
var(
influxdbHost=flag.String("ir-influxdb-host","localhost:8080/api/v1/namespaces/kube-system/services/monitoring-influxdb:api/proxy","Address of InfluxDB which contains metrics required by InitialResources")
user=flag.String("ir-user","root","User used for connecting to InfluxDB")
// TODO: figure out how to better pass password here
password=flag.String("ir-password","root","Password used for connecting to InfluxDB")
db=flag.String("ir-dbname","k8s","InfluxDB database name which contains metrics required by InitialResources")
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.
*/
packageinitialresources
import(
"fmt"
"strings"
"time"
influxdb"github.com/influxdata/influxdb/client"
api"k8s.io/kubernetes/pkg/apis/core"
)
const(
cpuSeriesName="autoscaling.cpu.usage.2m"
memSeriesName="autoscaling.memory.usage.2m"
cpuContinuousQuery="select derivative(value) as value from \"cpu/usage_ns_cumulative\" where pod_id <> '' group by pod_id, pod_namespace, container_name, container_base_image, time(2m) into "+cpuSeriesName
memContinuousQuery="select mean(value) as value from \"memory/usage_bytes_gauge\" where pod_id <> '' group by pod_id, pod_namespace, container_name, container_base_image, time(2m) into "+memSeriesName
timeFormat="2006-01-02 15:04:05"
)
// TODO(piosz): rewrite this once we will migrate into InfluxDB v0.9.
namespaceCond=" and pod_namespace='"+namespace+"'"
}
query:=fmt.Sprintf("select percentile(value, %v), count(pod_id) from %v where container_base_image%v%v and time > '%v' and time < '%v'",perc,series,imgPattern,namespaceCond,start.UTC().Format(timeFormat),end.UTC().Format(timeFormat))
if_,err:=s.query(query);err!=nil{
return0,0,fmt.Errorf("error while trying to query InfluxDB: %v",err)
