- Sort Score
- Result 10 results
- Languages All
Results 111 - 120 of 359 for Aggregate (2.72 sec)
-
README.md
microservices](https://istio.io/latest/docs/examples/microservices-istio/), manage [traffic flow](https://istio.io/latest/docs/concepts/traffic-management/) across microservices, enforce policies and aggregate telemetry data. Istio's control plane provides an abstraction layer over the underlying cluster management platform, such as Kubernetes. Istio is composed of these components:
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Jan 26 15:28:59 UTC 2024 - 6.6K bytes - Viewed (0) -
pkg/config/analysis/local/istiod_analyze.go
// The order here does matter - aggregated store takes the first available resource. allstores = append([]model.ConfigStoreController{sa.fileSource}, allstores...) } for _, c := range sa.clientsToRun { // TODO: this could be parallel c.RunAndWait(cancel) } store, err := aggregate.MakeWriteableCache(allstores, nil) if err != nil { return err }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Apr 02 21:06:13 UTC 2024 - 21.6K bytes - Viewed (0) -
pkg/test/framework/components/echo/check/checkers.go
return v.Checker() } // And is an aggregate Checker that requires all Checkers succeed. Any nil Checkers are ignored. func And(checkers ...echo.Checker) echo.Checker { return func(result echo.CallResult, err error) error { for _, c := range filterNil(checkers) { if err := c(result, err); err != nil { return err } } return nil } } // Or is an aggregate Checker that requires at least one Checker succeeds.
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Mar 03 16:19:07 UTC 2023 - 17.5K bytes - Viewed (0) -
guava/src/com/google/common/util/concurrent/AggregateFutureState.java
import java.util.logging.Level; import javax.annotation.CheckForNull; import org.checkerframework.checker.nullness.qual.Nullable; /** * A helper which does some thread-safe operations for aggregate futures, which must be implemented * differently in GWT. Namely: * * <ul> * <li>Lazily initializes a set of seen exceptions * <li>Decrements a counter atomically * </ul> */
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Tue May 28 20:40:51 UTC 2024 - 8.4K bytes - Viewed (0) -
tensorflow/compiler/jit/encapsulate_util.h
// least >= 7.3 does not. See also c++11 [class.ctor] p5. // // TODO(klimek): In c++17 we'll be able to initialize host_compute_core // without losing aggregate initialization, which allows us to get rid of // the constructor definitions again. XlaClusterInfo() {} XlaClusterInfo(const string& cluster_name, const NameAttrList& func_name_attrs, Node* node,
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Thu Feb 22 06:59:07 UTC 2024 - 7.4K bytes - Viewed (0) -
cmd/kubeadm/app/phases/upgrade/postupgrade_test.go
ComponentConfigs: kubeadmapi.ComponentConfigMap{ componentconfigs.KubeletGroup: &componentConfig{}, }, }, }, }, { name: "aggregate errs: no kubelet config file and cannot read config file", dryrun: true, errPattern: missingKubeletConfig, cfg: &kubeadmapi.InitConfiguration{}, }, {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Jan 15 11:40:04 UTC 2024 - 7.2K bytes - Viewed (0) -
pkg/quota/v1/evaluator/core/persistent_volume_claims.go
if allocatedRequest.Cmp(*result) > 0 { result = roundUpFunc(&allocatedRequest) } } } return result } // UsageStats calculates aggregate usage for the object. func (p *pvcEvaluator) UsageStats(options quota.UsageStatsOptions) (quota.UsageStats, error) { return generic.CalculateUsageStats(options, p.listFuncByNamespace, generic.MatchesNoScopeFunc, p.Usage) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Sep 23 23:36:24 UTC 2022 - 9.2K bytes - Viewed (0) -
pkg/kube/informerfactory/factory.go
// Package informerfactory provides a "factory" to generate informers. This allows users to create the // same informers in multiple different locations, while still using the same underlying resources. // Additionally, aggregate operations like Start, Shutdown, and Wait are available. // Kubernetes core has informer factories with very similar logic. However, this has a few problems that // spurred a fork:
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue May 23 17:08:31 UTC 2023 - 7.9K bytes - Viewed (0) -
staging/src/k8s.io/api/rbac/v1/generated.proto
import "k8s.io/apimachinery/pkg/runtime/schema/generated.proto"; // Package-wide variables from generator "generated". option go_package = "k8s.io/api/rbac/v1"; // AggregationRule describes how to locate ClusterRoles to aggregate into the ClusterRole message AggregationRule { // ClusterRoleSelectors holds a list of selectors which will be used to find ClusterRoles and create the rules.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Mar 28 15:34:11 UTC 2024 - 7.9K bytes - Viewed (0) -
pilot/pkg/xds/endpoints/ep_filters.go
Locality: ep.llbEndpoints.Locality, Priority: ep.llbEndpoints.Priority, // Endpoints and weight will be reset below. }, } // Create a map to keep track of the gateways used and their aggregate weights. gatewayWeights := make(map[model.NetworkGateway]uint32) // Process all the endpoints. for i, lbEp := range ep.llbEndpoints.LbEndpoints { istioEndpoint := ep.istioEndpoints[i]
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed May 29 01:17:58 UTC 2024 - 9.1K bytes - Viewed (0)