Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 3 of 3 for NewDiscoveryServer (0.17 sec)

  1. pilot/pkg/xds/discovery.go

    	pushVersion atomic.Uint64
    
    	// DiscoveryStartTime is the time since the binary started
    	DiscoveryStartTime time.Time
    }
    
    // NewDiscoveryServer creates DiscoveryServer that sources data from Pilot's internal mesh data structures
    func NewDiscoveryServer(env *model.Environment, clusterAliases map[string]string) *DiscoveryServer {
    	out := &DiscoveryServer{
    		Env:                 env,
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed May 15 20:21:09 UTC 2024
    - 19K bytes
    - Viewed (0)
  2. pilot/test/xds/fake.go

    	m := opts.MeshConfig
    	if m == nil {
    		m = mesh.DefaultMeshConfig()
    	}
    
    	// Init with a dummy environment, since we have a circular dependency with the env creation.
    	s := xds.NewDiscoveryServer(model.NewEnvironment(), map[string]string{})
    	// Disable debounce to reduce test times
    	s.DebounceOptions.DebounceAfter = opts.DebounceTime
    	// Setup time to Now instead of process start to make logs not misleading
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Mon Jun 10 16:08:52 UTC 2024
    - 18.4K bytes
    - Viewed (0)
  3. pilot/pkg/bootstrap/server.go

    	// Apply custom initialization functions.
    	for _, fn := range initFuncs {
    		fn(s)
    	}
    	// Initialize workload Trust Bundle before XDS Server
    	e.TrustBundle = s.workloadTrustBundle
    	s.XDSServer = xds.NewDiscoveryServer(e, args.RegistryOptions.KubeOptions.ClusterAliases)
    	configGen := core.NewConfigGenerator(s.XDSServer.Cache)
    
    	grpcprom.EnableHandlingTimeHistogram()
    
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Jun 13 17:48:28 UTC 2024
    - 46.3K bytes
    - Viewed (0)
Back to top