package repair

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

var (
	typeLabel  = monitoring.CreateLabel("type")
	deleteType = "delete"
	repairType = "repair"
	labelType  = "label"

	resultLabel   = monitoring.CreateLabel("result")
	resultSuccess = "success"
	resultSkip    = "skip"
	resultFail    = "fail"

	podsRepaired = monitoring.NewSum(
		"istio_cni_repair_pods_repaired_total",

// See the License for the specific language governing permissions and
// limitations under the License.

package model

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

var providerLookupClusterFailures = monitoring.NewSum(
	"provider_lookup_cluster_failures",
	"Number of times a cluster lookup failed",
)

func IncLookupClusterFailures(provider string) {

	"istio.io/istio/pkg/maps"
	"istio.io/istio/pkg/slices"
)

var (
	meter = func() api.Meter {
		return otel.GetMeterProvider().Meter("istio")
	}

	monitoringLogger = log.RegisterScope("monitoring", "metrics monitoring")
)

func init() {
	otel.SetLogger(log.NewLogrAdapter(monitoringLogger))
}

// RegisterPrometheusExporter sets the global metrics handler to the provided Prometheus registerer and gatherer.

	"google.golang.org/grpc/status"

	"istio.io/istio/pilot/pkg/model"
	v3 "istio.io/istio/pilot/pkg/xds/v3"
	"istio.io/istio/pkg/monitoring"
)

var (
	typeTag    = monitoring.CreateLabel("type")
	versionTag = monitoring.CreateLabel("version")

	monServices = monitoring.NewGauge(
		"pilot_services",
		"Total services known to pilot.",
	)

	// TODO: Update all the resource stats in separate routine

package webhooks

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

var (
	// webhookConfigNameTag holds the target webhook config name for the context.
	webhookConfigNameTag = monitoring.CreateLabel("name")

	// reasonTag holds the error reason for the context.
	reasonTag = monitoring.CreateLabel("reason")
)

var (
	metricWebhookPatchAttempts = monitoring.NewSum(
		"webhook_patch_attempts_total",

		return time.Since(serverStart).Seconds()
	})

	versionTag   = monitoring.CreateLabel("version")
	pilotVersion = monitoring.NewGauge(
		"pilot_info",
		"Pilot version and build information.",
	)
)

func init() {
	pilotVersion.With(versionTag.Value(version.Info.String())).Record(1)
}

func addMonitor(mux *http.ServeMux) error {
	exporter, err := monitoring.RegisterPrometheusExporter(nil, nil)
	if err != nil {

// limitations under the License.

package monitoring

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

// RequestType specifies the type of request we are monitoring. Current supported are CSR and TokenExchange
var RequestType = monitoring.CreateLabel("request_type")

const (
	TokenExchange = "token_exchange"
	CSR           = "csr"
)

var NumOutgoingRetries = monitoring.NewSum(
	"num_outgoing_retries",

package client

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

var (
	requests = monitoring.NewSum(
		"dns_requests_total",
		"Total number of DNS requests.",
	)

	upstreamRequests = monitoring.NewSum(
		"dns_upstream_requests_total",
		"Total number of DNS requests forwarded to upstream.",
	)

	failures = monitoring.NewSum(
		"dns_upstream_failures_total",
		"Total number of DNS failures.",

// See the License for the specific language governing permissions and
// limitations under the License.

package monitoring

import (
	"fmt"
	"net"
	"net/http"

	"istio.io/istio/pkg/log"
	"istio.io/istio/pkg/monitoring"
	"istio.io/istio/pkg/network"
)

func SetupMonitoring(port int, path string, stop <-chan struct{}) {
	if port <= 0 {
		return
	}

#include "absl/status/statusor.h"
#include "absl/strings/string_view.h"
#include "tensorflow/core/lib/monitoring/counter.h"
#include "tensorflow/core/lib/monitoring/gauge.h"
#include "tensorflow/core/lib/monitoring/sampler.h"
#include "tensorflow/core/protobuf/fingerprint.pb.h"

namespace tensorflow {
namespace metrics {

const char kFingerprintFound[] = "FOUND";
const char kFingerprintNotFound[] = "NOT_FOUND";