Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 3 of 3 for grpcprom (0.25 sec)

  1. staging/src/k8s.io/apiserver/pkg/storage/storagebackend/factory/etcd3.go

    func init() {
    	// grpcprom auto-registers (via an init function) their client metrics, since we are opting out of
    	// using the global prometheus registry and using our own wrapped global registry,
    	// we need to explicitly register these metrics to our global registry here.
    	// For reference: https://github.com/kubernetes/kubernetes/pull/81387
    	legacyregistry.RawMustRegister(grpcprom.DefaultClientMetrics)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Apr 24 07:56:39 UTC 2024
    - 15.1K bytes
    - Viewed (0)
  2. pilot/pkg/bootstrap/server.go

    import (
    	"context"
    	"crypto/tls"
    	"crypto/x509"
    	"encoding/json"
    	"fmt"
    	"net"
    	"net/http"
    	"os"
    	"strings"
    	"sync"
    	"sync/atomic"
    	"time"
    
    	"github.com/fsnotify/fsnotify"
    	grpcprom "github.com/grpc-ecosystem/go-grpc-prometheus"
    	"golang.org/x/net/http2"
    	"google.golang.org/grpc"
    	"google.golang.org/grpc/credentials"
    	"google.golang.org/grpc/reflection"
    	corev1 "k8s.io/api/core/v1"
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Jun 13 17:48:28 UTC 2024
    - 46.3K bytes
    - Viewed (0)
  3. samples/extauthz/cmd/extauthz/main.go

    	return &ExtAuthzServer{
    		grpcV2:   &extAuthzServerV2{},
    		grpcV3:   &extAuthzServerV3{},
    		httpPort: make(chan int, 1),
    		grpcPort: make(chan int, 1),
    	}
    }
    
    func main() {
    	flag.Parse()
    	s := NewExtAuthzServer()
    	go s.run(fmt.Sprintf(":%s", *httpPort), fmt.Sprintf(":%s", *grpcPort))
    	defer s.stop()
    
    	// Wait for the process to be shutdown.
    	sigs := make(chan os.Signal, 1)
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Feb 15 18:23:48 UTC 2024
    - 10.4K bytes
    - Viewed (0)
Back to top