// limitations under the License.

package version

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

var (
	gitTagKey       = monitoring.CreateLabel("tag")
	componentTagKey = monitoring.CreateLabel("component")
	istioBuildTag   = monitoring.NewGauge(
		"istio_build",
		"Istio component build info",
	)
)

# MinIO Monitoring Guide

MinIO server exposes monitoring data over endpoints. Monitoring tools can pick the data from these endpoints. This document lists the monitoring endpoints and relevant documentation.

## Healthcheck Probe

MinIO server has two healthcheck related un-authenticated endpoints, a liveness probe to indicate if server is responding, cluster probe to check if server can be taken down for maintenance.

	cmd.PersistentFlags().Uint32Var(&args.monitoring.port, "monitoring-port", metricsPort, "HTTP port to use for operator's self-monitoring information")
}

func serverCmd() *cobra.Command {
	loggingOptions := log.DefaultOptions()
	introspectionOptions := ctrlz.DefaultOptions()
	sArgs := &serverArgs{}
	serverCmd := &cobra.Command{
		Use:   "server",
		Short: "Starts the Istio operator server",
		Args:  cobra.ExactArgs(0),

import (
	"time"

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

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

	// StartupTime measures the time it takes for the agent to get ready Note: This
	// is dependent on readiness probes. This means our granularity is correlated to
	// the probing interval.
	startupTime = monitoring.NewGauge(
		"startup_duration_seconds",

// limitations under the License.

package crdclient

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

var (
	typeTag  = monitoring.CreateLabel("type")
	eventTag = monitoring.CreateLabel("event")

	k8sEvents = monitoring.NewSum(
		"pilot_k8s_cfg_events",
		"Events from k8s config.",
	)
)

func incrementEvent(kind, event string) {

#include <memory>

#include "tensorflow/core/lib/monitoring/cell_reader.h"

struct TFE_MonitoringCounterReader {
  explicit TFE_MonitoringCounterReader(const char* name) {
    counter = std::make_unique<
        ::tensorflow::monitoring::testing::CellReader<int64_t>>(name);
  }
  template <typename... LabelType>
  int64_t Read(const LabelType&... labels);
  std::unique_ptr<::tensorflow::monitoring::testing::CellReader<int64_t>>
      counter;

	return func(attempt uint) time.Duration {
		wait := bf(attempt)
		caLog.Warnf("ca request failed, starting attempt %d in %v", attempt, wait)
		monitoring.NumOutgoingRetries.With(monitoring.RequestType.Value(monitoring.CSR)).Increment()
		return wait
	}

func (s *Server) CreateCertificate(ctx context.Context, request *pb.IstioCertificateRequest) (
	*pb.IstioCertificateResponse, error,
) {
	s.monitoring.CSR.Increment()
	caller, err := security.Authenticate(ctx, s.Authenticators)
	if caller == nil || err != nil {
		s.monitoring.AuthnError.Increment()
		return nil, status.Error(codes.Unauthenticated, "request authenticate failure")
	}

package informermetric

import (
	"sync"

	"k8s.io/client-go/tools/cache"

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

var (
	clusterLabel = monitoring.CreateLabel("cluster")

	errorMetric = monitoring.NewSum(
		"controller_sync_errors_total",
		"Total number of errorMetric syncing controllers.",
	)

	mu       sync.RWMutex

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

package monitoring_test

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

var (
	protocol = monitoring.CreateLabel("protocol")

	requests = monitoring.NewSum(
		"requests_total",
		"Number of requests handled, by protocol",
	)
)

func ExampleNewSum() {
	// increment on every http request