- Sort Score
- Result 10 results
- Languages All
Results 1 - 2 of 2 for awaitReady (0.1 sec)
-
pkg/test/echo/server/endpoint/grpc.go
}() // Notify the WaitGroup once the port has transitioned to ready. go s.awaitReady(func() { healthServer.SetServingStatus("", grpcHealth.HealthCheckResponse_SERVING) onReady() }, listener) return nil } func (s *grpcInstance) awaitReady(onReady OnReadyFunc, listener net.Listener) { defer onReady() err := retry.UntilSuccess(func() error {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Sep 25 17:30:37 UTC 2023 - 8.7K bytes - Viewed (0) -
istioctl/pkg/waypoint/waypoint.go
"istio.io/istio/pkg/config/protocol" "istio.io/istio/pkg/config/schema/gvk" "istio.io/istio/pkg/kube" "istio.io/istio/pkg/slices" "istio.io/istio/pkg/util/sets" ) var ( revision = "" waitReady bool allNamespaces bool deleteAll bool trafficType = "" validTrafficTypes = sets.New(constants.ServiceTraffic, constants.WorkloadTraffic, constants.AllTraffic, constants.NoTraffic)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 06 15:59:33 UTC 2024 - 16.4K bytes - Viewed (0)