Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 2 of 2 for adsReceiveChannel (0.21 sec)

  1. pilot/pkg/xds/adstest.go

    		timeout:       time.Second,
    		Type:          v3.ClusterType,
    		responses:     make(chan *discovery.DiscoveryResponse),
    		error:         make(chan error),
    	}
    	t.Cleanup(resp.Cleanup)
    
    	go resp.adsReceiveChannel()
    
    	return resp
    }
    
    type AdsTest struct {
    	client    DiscoveryClient
    	responses chan *discovery.DiscoveryResponse
    	error     chan error
    	conn      *grpc.ClientConn
    	metadata  model.NodeMetadata
    
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Sun Feb 04 03:39:42 UTC 2024
    - 6K bytes
    - Viewed (0)
  2. pilot/pkg/xds/deltaadstest.go

    		timeout:       time.Second,
    		Type:          v3.ClusterType,
    		responses:     make(chan *discovery.DeltaDiscoveryResponse),
    		error:         make(chan error),
    	}
    	t.Cleanup(resp.Cleanup)
    
    	go resp.adsReceiveChannel()
    
    	return resp
    }
    
    type DeltaAdsTest struct {
    	client    DeltaDiscoveryClient
    	responses chan *discovery.DeltaDiscoveryResponse
    	error     chan error
    	t         test.Failer
    	conn      *grpc.ClientConn
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Sun Feb 04 03:39:42 UTC 2024
    - 6.9K bytes
    - Viewed (0)
Back to top