Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 2 of 2 for awaitReady (0.1 sec)

  1. 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)
  2. 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)
Back to top