- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 4,116 for _instances (0.13 sec)
-
pkg/test/loadbalancersim/timeseries/instance.go
package timeseries import ( "sync" "time" ) type Instance struct { data Data times times mutex sync.Mutex } func (ts *Instance) AddObservation(val float64, t time.Time) { ts.mutex.Lock() defer ts.mutex.Unlock() ts.data = append(ts.data, val) ts.times = append(ts.times, t) } func (ts *Instance) AddAll(o *Instance) { ts.mutex.Lock() defer ts.mutex.Unlock()
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Feb 03 18:19:25 UTC 2022 - 1.8K bytes - Viewed (0) -
pkg/test/util/structpath/instance.go
} // Success. return &Instance{ isJSON: i.isJSON, structure: value, } } func (i *Instance) appendConstraint(fn func() error) *Instance { i.constraints = append(i.constraints, fn) return i } func (i *Instance) Equals(expected any, path string, args ...any) *Instance { path = fmt.Sprintf(path, args...) return i.appendConstraint(func() error {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Jul 25 19:30:47 UTC 2022 - 9.4K bytes - Viewed (0) -
pkg/test/framework/components/echo/instance.go
Addresses() []string // Restart restarts the workloads associated with this echo instance Restart() error // UpdateWorkloadLabel update pod labels of this echo instance UpdateWorkloadLabel(add map[string]string, remove []string) error // WithWorkloads returns a target with only the specified subset of workloads WithWorkloads(wl ...Workload) Instance
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Aug 11 03:58:03 UTC 2022 - 1.3K bytes - Viewed (0) -
pilot/pkg/server/instance.go
// the server Instance is shutting down, it will wait for the component // to complete before exiting. // Note: this is best effort; a process can die at any time. RunComponentAsyncAndWait(name string, t Component) // Wait for this server Instance to shutdown. Wait() } var _ Instance = &instance{} // New creates a new server Instance. func New() Instance { return &instance{
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue May 23 17:08:31 UTC 2023 - 4.6K 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) -
releasenotes/notes/update-se-instances.yaml
dwq <******@****.***> 1656083735 +0800
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Jun 24 15:15:35 UTC 2022 - 163 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) -
pilot/pkg/serviceregistry/util/workloadinstances/util.go
) // FindInstance returns the first workload instance matching given predicate. func FindInstance(instances []*model.WorkloadInstance, predicate func(*model.WorkloadInstance) bool) *model.WorkloadInstance { for _, instance := range instances { if predicate(instance) { return instance } } return nil } // InstanceNameForProxy returns a name of the workload instance that // corresponds to a given proxy, if any.
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed May 24 17:36:41 UTC 2023 - 2.8K 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) -
subprojects/diagnostics/src/main/resources/org/gradle/api/tasks/diagnostics/htmldependencyreport/jquery.jstree.js
// if a method call execute the method on all selected instances if(isMethodCall) { if(settings.substring(0, 1) == '_') { return returnValue; } this.each(function() { var instance = instances[$.data(this, "jstree_instance_id")], methodValue = (instance && $.isFunction(instance[settings])) ? instance[settings].apply(instance, args) : instance;
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Nov 04 09:03:42 UTC 2021 - 49.5K bytes - Viewed (0)