Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 5 of 5 for clusterLocal (1.65 sec)

  1. pilot/pkg/serviceregistry/kube/controller/multicluster.go

    		startNsController:      startNsController,
    		caBundleWatcher:        caBundleWatcher,
    		revision:               revision,
    		XDSUpdater:             opts.XDSUpdater,
    		clusterLocal:           clusterLocal,
    		secretNamespace:        secretNamespace,
    		client:                 kc,
    		s:                      s,
    	}
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu May 23 21:07:03 UTC 2024
    - 12.7K bytes
    - Viewed (0)
  2. pilot/pkg/bootstrap/servicecontroller.go

    		args.RegistryOptions.KubeOptions,
    		s.serviceEntryController,
    		s.configController,
    		s.istiodCertBundleWatcher,
    		args.Revision,
    		s.shouldStartNsController(),
    		s.environment.ClusterLocal(),
    		s.server,
    		s.multiclusterController)
    
    	return
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu May 23 21:07:03 UTC 2024
    - 3.2K bytes
    - Viewed (0)
  3. pilot/pkg/model/context.go

    }
    
    func (e *Environment) InitNetworksManager(updater XDSUpdater) (err error) {
    	e.NetworkManager, err = NewNetworkManager(e, updater)
    	return
    }
    
    func (e *Environment) ClusterLocal() ClusterLocalProvider {
    	return e.clusterLocalServices
    }
    
    func (e *Environment) GetLedger() ledger.Ledger {
    	return e.ledger
    }
    
    func (e *Environment) SetLedger(l ledger.Ledger) {
    	e.ledger = l
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Mon Jun 03 08:29:05 UTC 2024
    - 33.6K bytes
    - Viewed (1)
  4. pilot/pkg/networking/core/cluster_test.go

    	m.ServiceSettings = append(append(make([]*meshconfig.MeshConfig_ServiceSettings, 0), m.ServiceSettings...),
    		&meshconfig.MeshConfig_ServiceSettings{
    			Settings: &meshconfig.MeshConfig_ServiceSettings_Settings{
    				ClusterLocal: true,
    			},
    			Hosts: hosts,
    		})
    	return m
    }
    
    func TestBuildSidecarClustersWithIstioMutualAndSNI(t *testing.T) {
    	cases := []struct {
    		sni      string
    		expected string
    	}{
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Jun 13 01:56:28 UTC 2024
    - 108.8K bytes
    - Viewed (0)
  5. pilot/pkg/model/push_context.go

    		}
    	} else {
    		if err := ps.updateContext(env, oldPushContext, pushReq); err != nil {
    			return err
    		}
    	}
    
    	ps.networkMgr = env.NetworkManager
    
    	ps.clusterLocalHosts = env.ClusterLocal().GetClusterLocalHosts()
    
    	ps.InitDone.Store(true)
    	return nil
    }
    
    func (ps *PushContext) createNewContext(env *Environment) error {
    	ps.initServiceRegistry(env, nil)
    
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed May 15 09:02:11 UTC 2024
    - 91.8K bytes
    - Viewed (0)
Back to top