Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 998 for _instances (0.27 sec)

  1. pkg/controlplane/instance.go

    // used by the master.
    type EndpointReconcilerConfig struct {
    	Reconciler reconcilers.EndpointReconciler
    	Interval   time.Duration
    }
    
    // Instance contains state for a Kubernetes cluster api server instance.
    type Instance struct {
    	ControlPlane *controlplaneapiserver.Server
    }
    
    func (c *Config) createMasterCountReconciler() reconcilers.EndpointReconciler {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Jun 03 11:50:04 UTC 2024
    - 21.2K bytes
    - Viewed (0)
  2. pkg/bootstrap/option/instances.go

    	return newOption("nodeID", value)
    }
    
    func NodeType(value string) Instance {
    	ntype := strings.Split(value, "~")[0]
    	return newOption("nodeType", ntype)
    }
    
    func XdsType(value string) Instance {
    	return newOption("xds_type", value)
    }
    
    func Region(value string) Instance {
    	return newOptionOrSkipIfZero("region", value)
    }
    
    func Zone(value string) Instance {
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Tue May 14 17:02:38 UTC 2024
    - 9K bytes
    - Viewed (0)
  3. pkg/test/framework/components/echo/deployment/builder.go

    }
    
    func assignRefs(refs []*echo.Instance, instances echo.Instances) error {
    	if len(refs) != len(instances) {
    		return fmt.Errorf("cannot set %d references, only %d instances were built", len(refs), len(instances))
    	}
    	for i, ref := range refs {
    		if ref != nil {
    			*ref = instances[i]
    		}
    	}
    	return nil
    }
    
    func (b *builder) BuildOrFail(t test.Failer) echo.Instances {
    	t.Helper()
    	out, err := b.Build()
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Jun 06 22:12:34 UTC 2024
    - 12K bytes
    - Viewed (0)
  4. pilot/pkg/serviceregistry/serviceentry/controller_test.go

    	}
    }
    
    func sortServiceTargets(instances []model.ServiceTarget) {
    	sort.Slice(instances, func(i, j int) bool {
    		if instances[i].Service.Hostname == instances[j].Service.Hostname {
    			if instances[i].Port.TargetPort == instances[j].Port.TargetPort {
    				return instances[i].Port.TargetPort < instances[j].Port.TargetPort
    			}
    		}
    		return instances[i].Service.Hostname < instances[j].Service.Hostname
    	})
    }
    
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed May 29 15:31:09 UTC 2024
    - 92.9K bytes
    - Viewed (0)
  5. pkg/test/framework/components/echo/echotest/filters.go

    			}
    		}
    
    		return outServices.Instances()
    	}
    }
    
    func notRegularPods() Filter {
    	return func(instances echo.Instances) echo.Instances {
    		return match.NotRegularPod.GetMatches(instances)
    	}
    }
    
    // FilterMatch returns a filter that simply applies the given matcher.
    func FilterMatch(matcher match.Matcher) Filter {
    	return func(instances echo.Instances) echo.Instances {
    		return matcher.GetMatches(instances)
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Mon Apr 29 23:48:45 UTC 2024
    - 8.9K bytes
    - Viewed (0)
  6. pkg/test/framework/components/echo/match/matchers.go

    	return func(i echo.Instance) bool {
    		return n == i.NamespacedName()
    	}
    }
    
    // AnyServiceName matches instances if they have the same Service and Namespace as any of the provided instances.
    func AnyServiceName(expected echo.NamespacedNames) Matcher {
    	return func(instance echo.Instance) bool {
    		serviceName := instance.NamespacedName()
    		for _, expectedName := range expected {
    			if serviceName == expectedName {
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu May 02 21:29:40 UTC 2024
    - 5.6K bytes
    - Viewed (0)
  7. pilot/pkg/serviceregistry/serviceentry/store.go

    			continue
    		}
    		if _, f := s.instances[ikey]; !f {
    			s.instances[ikey] = map[configKeyWithParent][]*model.ServiceInstance{}
    		}
    		s.instancesByHostAndPort.Insert(hostPort)
    		s.instances[ikey][key] = append(s.instances[ikey][key], instance)
    		if instance.Endpoint.Address != "" {
    			s.ip2instance[instance.Endpoint.Address] = append(s.ip2instance[instance.Endpoint.Address], instance)
    		}
    	}
    }
    
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed May 29 15:31:09 UTC 2024
    - 6.1K bytes
    - Viewed (0)
  8. pilot/pkg/serviceregistry/aggregate/controller_test.go

    		}
    	}
    
    	// Get Instances from mockAdapter2
    	instances = aggregateCtl.GetProxyServiceTargets(&model.Proxy{IPAddresses: []string{mock.MakeIP(mock.WorldService, 1)}})
    	if len(instances) != 6 {
    		t.Fatalf("Returned GetProxyServiceTargets' amount %d is not correct", len(instances))
    	}
    	for _, inst := range instances {
    		if inst.Service.Hostname != mock.WorldService.Hostname {
    			t.Fatal("Returned Instance is incorrect")
    		}
    	}
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed May 15 06:28:11 UTC 2024
    - 14.5K bytes
    - Viewed (0)
  9. platforms/software/dependency-management/src/main/java/org/gradle/internal/component/model/ComponentGraphResolveState.java

        /**
         * Does this instance represent some temporary or mutated view of the component?
         *
         * Generally you should avoid retaining ad hoc instances in memory, whereas non-ad hoc instances can safely be cached for the lifetime of the build tree.
         *
         * @return true when this instance is ad hoc, false when this instance is not ad hoc and can be cached.
         */
        boolean isAdHoc();
    
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Wed May 22 16:00:57 UTC 2024
    - 4.6K bytes
    - Viewed (0)
  10. security/pkg/credentialfetcher/plugin/gce.go

    	rotateToken = enable
    }
    
    // GCEPlugin is the plugin object.
    type GCEPlugin struct {
    	// aud is the unique URI agreed upon by both the instance and the system verifying the instance's identity.
    	// For more info: https://cloud.google.com/compute/docs/instances/verifying-instance-identity
    	aud string
    
    	// The location to save the identity token
    	jwtPath string
    
    	// identity provider
    	identityProvider string
    
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Tue Apr 30 13:56:46 UTC 2024
    - 4.7K bytes
    - Viewed (0)
Back to top