pkg/webhooks/validation/server/monitoring.go

// Copyright Istio 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
//
//     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 server

import (
	"strconv"
)

import (
	"istio.io/pkg/monitoring"
)

import (
	"github.com/apache/dubbo-go-pixiu/pkg/kube"
)

const (
	group       = "group"
	version     = "version"
	resourceTag = "resource"
	reason      = "reason"
	status      = "status"
)

var (
	// GroupTag holds the resource group for the context.
	GroupTag = monitoring.MustCreateLabel(group)

	// VersionTag holds the resource version for the context.
	VersionTag = monitoring.MustCreateLabel(version)

	// ResourceTag holds the resource name for the context.
	ResourceTag = monitoring.MustCreateLabel(resourceTag)

	// ReasonTag holds the error reason for the context.
	ReasonTag = monitoring.MustCreateLabel(reason)

	// StatusTag holds the error code for the context.
	StatusTag = monitoring.MustCreateLabel(status)
)

var (
	metricValidationPassed = monitoring.NewSum(
		"galley/validation/passed",
		"Resource is valid",
		monitoring.WithLabels(GroupTag, VersionTag, ResourceTag),
	)
	metricValidationFailed = monitoring.NewSum(
		"galley/validation/failed",
		"Resource validation failed",
		monitoring.WithLabels(GroupTag, VersionTag, ResourceTag, ReasonTag),
	)
	metricValidationHTTPError = monitoring.NewSum(
		"galley/validation/http_error",
		"Resource validation http serve errors",
		monitoring.WithLabels(StatusTag),
	)
)

func init() {
	monitoring.MustRegister(
		metricValidationPassed,
		metricValidationFailed,
		metricValidationHTTPError,
	)
}

func reportValidationFailed(request *kube.AdmissionRequest, reason string) {
	metricValidationFailed.
		With(GroupTag.Value(request.Resource.Group)).
		With(VersionTag.Value(request.Resource.Version)).
		With(ResourceTag.Value(request.Resource.Resource)).
		With(ReasonTag.Value(reason)).
		Increment()
}

func reportValidationPass(request *kube.AdmissionRequest) {
	metricValidationPassed.
		With(GroupTag.Value(request.Resource.Group)).
		With(VersionTag.Value(request.Resource.Version)).
		With(ResourceTag.Value(request.Resource.Resource)).
		Increment()
}

func reportValidationHTTPError(status int) {
	metricValidationHTTPError.
		With(StatusTag.Value(strconv.Itoa(status))).
		Increment()
}

const (
	reasonUnsupportedOperation = "unsupported_operation"
	reasonYamlDecodeError      = "yaml_decode_error"
	reasonUnknownType          = "unknown_type"
	reasonCRDConversionError   = "crd_conversion_error"
	reasonInvalidConfig        = "invalid_resource"
)