- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 11 for grpcprom (0.46 sec)
-
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) -
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) -
pkg/test/framework/components/echo/kube/workload_manager.go
var tls *echoCommon.TLSSettings if cfg.IsProxylessGRPC() { grpcInstancePort = grpcMagicPort } if grpcInstancePort == 0 { if grpcPort, found := cfg.Ports.ForProtocol(protocol.GRPC); found { if grpcPort.TLS { tls = cfg.TLSSettings } grpcInstancePort = grpcPort.WorkloadPort } } if grpcInstancePort == 0 { return nil, errors.New("unable to find GRPC command port") } m := &workloadManager{
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Aug 14 02:12:37 UTC 2023 - 6.4K bytes - Viewed (0) -
tests/integration/pilot/grpc_probe_test.go
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 02 21:29:40 UTC 2024 - 2.8K bytes - Viewed (0) -
pkg/test/framework/components/authz/kube.go
fqdn := fmt.Sprintf("ext-authz.%s.svc.cluster.local", s.ns.Name()) return map[string]any{ "fqdn": fqdn, "httpName": httpName, "grpcName": grpcName, "httpPort": httpPort, "grpcPort": grpcPort, } } func installProviders(ctx resource.Context, providerYAML string) error { var ist istio.Instance ist, err := istio.Get(ctx) if err != nil { return err }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Apr 10 20:33:28 UTC 2024 - 7K bytes - Viewed (0) -
pkg/test/framework/components/authz/kubelocal.go
return map[string]any{ "httpName": s.httpName(), "grpcName": s.grpcName(), "httpHost": s.httpHost(), "grpcHost": s.grpcHost(), "httpPort": httpPort, "grpcPort": grpcPort, } } func (s *localServerImpl) installProviders(ctx resource.Context) error { // Update the mesh config extension provider for the ext-authz service.
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Jul 25 19:30:47 UTC 2022 - 5.1K bytes - Viewed (0) -
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) -
pkg/kubelet/prober/prober.go
"k8s.io/kubernetes/pkg/kubelet/events" "k8s.io/kubernetes/pkg/kubelet/prober/results" "k8s.io/kubernetes/pkg/kubelet/util/format" "k8s.io/kubernetes/pkg/probe" execprobe "k8s.io/kubernetes/pkg/probe/exec" grpcprobe "k8s.io/kubernetes/pkg/probe/grpc" httpprobe "k8s.io/kubernetes/pkg/probe/http" tcpprobe "k8s.io/kubernetes/pkg/probe/tcp" "k8s.io/utils/exec" "k8s.io/klog/v2" ) const maxProbeRetries = 3
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Feb 16 10:50:13 UTC 2024 - 8.7K bytes - Viewed (0) -
pkg/test/framework/components/echo/kube/workload.go
"istio.io/istio/pkg/test/util/retry" ) const ( appContainerName = "app" ) var _ echo.Workload = &workload{} type workloadConfig struct { pod corev1.Pod hasSidecar bool grpcPort uint16 cluster cluster.Cluster tls *common.TLSSettings stop chan struct{} } type workload struct { client *echoClient.Client workloadConfig forwarder istioKube.PortForwarder
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Oct 25 19:46:28 UTC 2023 - 7.4K bytes - Viewed (0) -
samples/extauthz/cmd/extauthz/main_test.go
if err != nil { t.Fatalf(err.Error()) } // Prepare the gRPC request. conn, err := grpc.Dial(fmt.Sprintf("localhost:%d", <-server.grpcPort), grpc.WithTransportCredentials(insecure.NewCredentials())) if err != nil { t.Fatalf(err.Error()) } defer func() { _ = conn.Close() }() grpcV3Client := authv3.NewAuthorizationClient(conn)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Feb 23 16:58:02 UTC 2023 - 3.6K bytes - Viewed (0)