Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 640 for Remotes (0.33 sec)

  1. pkg/test/framework/components/cluster/clusters.go

    func (c Clusters) Configs(excluded ...Cluster) Clusters {
    	return c.filterClusters(func(cc Cluster) bool {
    		return cc.IsConfig()
    	}, exclude(excluded...))
    }
    
    // Remotes returns the subset that are remote clusters.
    func (c Clusters) Remotes(excluded ...Cluster) Clusters {
    	return c.filterClusters(func(cc Cluster) bool {
    		return cc.IsRemote()
    	}, exclude(excluded...))
    }
    
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Jun 06 22:12:34 UTC 2024
    - 4.7K bytes
    - Viewed (0)
  2. pkg/test/framework/components/istio/cleanup.go

    	if i.cfg.DeployIstio {
    		errG := multierror.Group{}
    		// Make sure to clean up primary clusters before remotes, or istiod will recreate some of the CMs that we delete
    		// in the remote clusters before it's deleted.
    		for _, c := range i.ctx.AllClusters().Primaries() {
    			i.cleanupCluster(c, &errG)
    		}
    		for _, c := range i.ctx.Clusters().Remotes() {
    			i.cleanupCluster(c, &errG)
    		}
    		return errG.Wait().ErrorOrNil()
    	}
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Jun 06 22:12:34 UTC 2024
    - 5K bytes
    - Viewed (0)
  3. pilot/pkg/serviceregistry/kube/controller/multicluster.go

    			m.serviceEntryController.AppendWorkloadHandler(kubeRegistry.WorkloadInstanceHandler)
    		} else if features.WorkloadEntryCrossCluster {
    			// TODO only do this for non-remotes, can't guarantee CRDs in remotes (depends on https://github.com/istio/istio/pull/29824)
    			configStore := createWleConfigStore(client, m.revision, options)
    			kubeController.workloadEntryController = serviceentry.NewWorkloadEntryController(
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu May 23 21:07:03 UTC 2024
    - 12.7K bytes
    - Viewed (0)
  4. pkg/test/framework/components/istio/kube.go

    }
    
    // installRemoteCluster installs istio to a remote cluster that does not also serve as a config cluster.
    func (i *istioImpl) installRemoteCluster(c cluster.Cluster) error {
    	scopes.Framework.Infof("setting up %s as remote cluster", c.Name())
    	return i.installRemoteCommon(c, i.cfg.RemoteClusterIOPFile, i.remoteIOP.file, true)
    }
    
    // Common install on a either a remote-config or pure remote cluster.
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Jun 06 22:12:34 UTC 2024
    - 31.1K bytes
    - Viewed (0)
  5. internal/grid/manager.go

    		if err != nil {
    			writeErr(fmt.Errorf("error parsing connectReq: %w", err))
    			return
    		}
    		remote := m.targets[cReq.Host]
    		if remote == nil {
    			writeErr(fmt.Errorf("unknown incoming host: %v", cReq.Host))
    			return
    		}
    		if debugPrint {
    			fmt.Printf("handler: Got Connect Req %+v\n", cReq)
    		}
    		writeErr(remote.handleIncoming(ctx, conn, cReq))
    	}
    }
    
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Mon Jun 10 17:40:33 UTC 2024
    - 9.8K bytes
    - Viewed (0)
  6. cmd/bucket-replication.go

    	r = ResyncDecision{
    		targets: make(map[string]ResyncTargetDecision, len(dsc.targetsMap)),
    	}
    	if c.remotes == nil {
    		return
    	}
    	for _, tgt := range c.remotes.Targets {
    		d, ok := dsc.targetsMap[tgt.Arn]
    		if !ok {
    			continue
    		}
    		if !d.Replicate {
    			continue
    		}
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Thu Jun 13 06:56:12 UTC 2024
    - 114.4K bytes
    - Viewed (0)
  7. pkg/test/framework/components/istio/config.go

    	// These values are only applied to remote clusters
    	// Default value will be ControlPlaneValues if no remote values provided
    	RemoteClusterValues string
    
    	// Override values specifically for the ICP crd
    	// This is mostly required for cases where --set cannot be used
    	// These values are only applied to remote config clusters
    	// Default value will be ControlPlaneValues if no remote values provided
    	ConfigClusterValues string
    
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed Apr 10 20:33:28 UTC 2024
    - 14.8K bytes
    - Viewed (0)
  8. cmd/metacache-set.go

    	tgts, _ := globalBucketTargetSys.ListBucketTargets(ctx, o.Bucket)
    	o.Lifecycle = lc
    	o.Versioning = vc
    	o.Replication = replicationConfig{
    		Config:  replCfg,
    		remotes: tgts,
    	}
    	o.Retention = rcfg
    }
    
    // newMetacache constructs a new metacache from the options.
    func (o listPathOptions) newMetacache() metacache {
    	return metacache{
    		id:          o.ID,
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Fri Jun 07 22:18:44 UTC 2024
    - 30.4K bytes
    - Viewed (0)
  9. cmd/xl-storage.go

    		if rcfg.HasActiveRules("", true) {
    			tgts, err := globalBucketTargetSys.ListBucketTargets(ctx, cache.Info.Name)
    			if err == nil {
    				cache.Info.replication = replicationConfig{
    					Config:  rcfg,
    					remotes: tgts,
    				}
    			}
    		}
    	}
    
    	vcfg, _ := globalBucketVersioningSys.Get(cache.Info.Name)
    
    	// return initialized object layer
    	objAPI := newObjectLayerFn()
    	// object layer not initialized, return.
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Mon Jun 10 15:51:27 UTC 2024
    - 85.3K bytes
    - Viewed (0)
  10. releasenotes/notes/release-channels-remote-cluster.yaml

    area: installation
    issue:
    - https://github.com/istio/enhancements/issues/173
    releaseNotes:
    - |
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Tue May 28 19:46:57 UTC 2024
    - 297 bytes
    - Viewed (0)
Back to top