Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 2,154 for _instances (0.34 sec)

  1. pkg/test/framework/components/echo/instances.go

    	sort.Stable(out)
    	return out
    }
    
    // Copy this Instances array.
    func (i Instances) Copy() Instances {
    	return append(Instances{}, i...)
    }
    
    // Append returns a new Instances array with the given values appended.
    func (i Instances) Append(instances Instances) Instances {
    	return append(i.Copy(), instances...)
    }
    
    // Restart each Instance
    func (i Instances) Restart() error {
    	g := multierror.Group{}
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Mon Mar 25 18:26:17 UTC 2024
    - 4.7K bytes
    - Viewed (0)
  2. pkg/scheduler/framework/plugins/dynamicresources/structured/namedresources/namedresourcesmodel_test.go

    		Selector: `attributes.bool["usable"]`,
    	}
    
    	instance1 := "instance-1"
    	oneInstance := Model{
    		Instances: []InstanceAllocation{{
    			Instance: &resourceapi.NamedResourcesInstance{
    				Name: instance1,
    			},
    		}},
    	}
    
    	instance2 := "instance-2"
    	twoInstances := Model{
    		Instances: []InstanceAllocation{
    			{
    				Instance: &resourceapi.NamedResourcesInstance{
    					Name: instance1,
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Mar 27 09:27:01 UTC 2024
    - 7.9K bytes
    - Viewed (0)
  3. 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)
  4. pkg/bootstrap/instance.go

    var overrideVar = env.Register("ISTIO_BOOTSTRAP", "", "")
    
    // Instance of a configured Envoy bootstrap writer.
    type Instance interface {
    	// WriteTo writes the content of the Envoy bootstrap to the given writer.
    	WriteTo(templateFile string, w io.Writer) error
    
    	// CreateFile generates an Envoy bootstrap file.
    	CreateFile() (string, error)
    }
    
    // New creates a new Instance of an Envoy bootstrap writer.
    func New(cfg Config) Instance {
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Mar 28 20:38:02 UTC 2024
    - 3.9K bytes
    - Viewed (0)
  5. 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)
  6. pkg/scheduler/framework/plugins/dynamicresources/structuredparameters_test.go

    								{
    									Instance: &resourceapi.NamedResourcesInstance{Name: "X"},
    								},
    								{
    									Instance: &resourceapi.NamedResourcesInstance{Name: "Y"},
    								},
    							},
    						},
    					},
    					"driver-b": {
    						NamedResources: namedresourcesmodel.Model{
    							Instances: []namedresourcesmodel.InstanceAllocation{
    								{
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Mar 27 09:27:01 UTC 2024
    - 34.8K bytes
    - Viewed (0)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to top