- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 998 for _instances (0.27 sec)
-
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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)