- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 12 for Aggregate (0.31 sec)
-
pilot/pkg/serviceregistry/serviceregistry_test.go
client, kubecontroller.Options{ XDSUpdater: xdsUpdater, DomainSuffix: "cluster.local", MeshWatcher: meshWatcher, MeshServiceController: aggregate.NewController(aggregate.Options{MeshHolder: meshWatcher}), }, ) configController := memory.NewController(memory.Make(collections.Pilot)) stop := istiotest.NewStop(t) go configController.Run(stop)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 23 21:07:03 UTC 2024 - 51.2K bytes - Viewed (0) -
platforms/documentation/docs/src/docs/userguide/jvm/java_testing.adoc
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Mar 29 16:24:12 UTC 2024 - 53.1K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/endpoints/installer.go
Params []*restful.Parameter // List of parameters associated with the action. Namer handlers.ScopeNamer AllNamespaces bool // true iff the action is namespaced but works on aggregate result for all namespaces } func ConvertGroupVersionIntoToDiscovery(list []metav1.APIResource) ([]apidiscoveryv2.APIResourceDiscovery, error) { var apiResourceList []apidiscoveryv2.APIResourceDiscovery
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Mar 01 18:15:22 UTC 2024 - 51.5K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/cacher/cacher.go
klog.V(1).Infof("cacher (%v): %v objects queued in incoming channel.", c.groupResource.String(), curLen) } c.incoming <- *event } func (c *Cacher) dispatchEvents() { // Jitter to help level out any aggregate load. bookmarkTimer := c.clock.NewTimer(wait.Jitter(time.Second, 0.25)) defer bookmarkTimer.Stop() // The internal informer populates the RV as soon as it conducts
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 12 10:12:02 UTC 2024 - 51.8K bytes - Viewed (0) -
cmd/api-errors.go
HTTPStatusCode: http.StatusBadRequest, }, ErrParseNonUnaryAggregateFunctionCall: { Code: "ParseNonUnaryAggregateFunctionCall", Description: "Only one argument is supported for aggregate functions in the SQL expression.", HTTPStatusCode: http.StatusBadRequest, }, ErrParseMalformedJoin: { Code: "ParseMalformedJoin", Description: "JOIN is not supported in the SQL expression.",
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Thu Jun 13 22:26:38 UTC 2024 - 92.1K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/apis/apiserver/validation/validation_test.go
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 10 22:07:40 UTC 2024 - 87.2K bytes - Viewed (0) -
pkg/kubelet/eviction/helpers.go
if volume.HostPath != nil || volumeutils.IsLocalEphemeralVolume(volume) { result = append(result, volume.Name) } } return result } // containerUsage aggregates container disk usage and inode consumption for the specified stats to measure. func containerUsage(podStats statsapi.PodStats, statsToMeasure []fsStatsType) v1.ResourceList { disk := resource.Quantity{Format: resource.BinarySI}
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Nov 01 18:46:33 UTC 2023 - 53.6K bytes - Viewed (0) -
hack/local-up-cluster.sh
echo "use 'kubectl --kubeconfig=${CERT_DIR}/admin-kube-aggregator.kubeconfig' to use the aggregated API server" } function start_controller_manager { cloud_config_arg=("--cloud-provider=${CLOUD_PROVIDER}" "--cloud-config=${CLOUD_CONFIG}")
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 25 02:33:52 UTC 2024 - 53.3K bytes - Viewed (0) -
operator/pkg/apis/istio/v1alpha1/values_types.proto
// globally/universally unique. For example, if any of the following are true, // then two meshes must have different Mesh IDs: // - Meshes will have their telemetry aggregated in one place // - Meshes will be federated together // - Policy will be written referencing one mesh from the other // // If an administrator expects that any of these conditions may become true in
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Jun 03 01:55:05 UTC 2024 - 57.2K bytes - Viewed (0) -
pkg/scheduler/internal/cache/cache_test.go
nodeInfo.NonZeroRequested = nonzeroRequest nodeInfo.UsedPorts = usedPorts nodeInfo.ImageStates = imageStates return nodeInfo } // TestAssumePodScheduled tests that after a pod is assumed, its information is aggregated // on node level. func TestAssumePodScheduled(t *testing.T) { nodeName := "node" testPods := []*v1.Pod{
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Oct 17 01:38:03 UTC 2023 - 63.8K bytes - Viewed (0)