- Sort Score
- Result 10 results
- Languages All
Results 141 - 150 of 359 for Aggregate (0.28 sec)
-
pilot/pkg/bootstrap/configcontroller.go
"google.golang.org/grpc" "google.golang.org/grpc/credentials/insecure" meshconfig "istio.io/api/mesh/v1alpha1" "istio.io/istio/pilot/pkg/autoregistration" configaggregate "istio.io/istio/pilot/pkg/config/aggregate" "istio.io/istio/pilot/pkg/config/kube/crdclient" "istio.io/istio/pilot/pkg/config/kube/gateway" ingress "istio.io/istio/pilot/pkg/config/kube/ingress" "istio.io/istio/pilot/pkg/config/memory"
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Feb 28 16:41:38 UTC 2024 - 14.1K bytes - Viewed (0) -
staging/src/k8s.io/api/rbac/v1alpha1/types.go
// stomped by the controller. // +optional AggregationRule *AggregationRule `json:"aggregationRule,omitempty" protobuf:"bytes,3,opt,name=aggregationRule"` } // AggregationRule describes how to locate ClusterRoles to aggregate into the ClusterRole type AggregationRule struct { // 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 22:49:19 UTC 2024 - 11.2K bytes - Viewed (0) -
src/runtime/runtime.go
// from nanotime that we can use (some platforms have a really coarse system time granularity). // We require some amount of time to pass to ensure that the conversion rate is fairly accurate // in aggregate. But because we compute this rate lazily, there's a pretty good chance a decent // amount of time has passed by the time we get here. // // Must be called from a normal goroutine context (running regular goroutine with a P). //
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 23 01:16:47 UTC 2024 - 9.9K bytes - Viewed (0) -
src/go/doc/testdata/testing.go
cpuProfile = flag.String("test.cpuprofile", "", "write a cpu profile to the named file during execution") timeout = flag.Duration("test.timeout", 0, "if positive, sets an aggregate time limit for all tests") cpuListStr = flag.String("test.cpu", "", "comma-separated list of number of CPUs to use for each test") parallel = flag.Int("test.parallel", runtime.GOMAXPROCS(0), "maximum test parallelism")
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Sun Oct 02 02:28:27 UTC 2022 - 11.8K bytes - Viewed (0) -
staging/src/k8s.io/api/rbac/v1beta1/types.go
// stomped by the controller. // +optional AggregationRule *AggregationRule `json:"aggregationRule,omitempty" protobuf:"bytes,3,opt,name=aggregationRule"` } // AggregationRule describes how to locate ClusterRoles to aggregate into the ClusterRole type AggregationRule struct { // 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 22:49:19 UTC 2024 - 13.1K bytes - Viewed (0) -
cmd/bucket-replication-metrics.go
atomic.AddUint64(&m.bytesSinceLastWindow, bytes) } // updateExponentialMovingAverage processes the measurements captured so far. func (m *rateMeasurement) updateExponentialMovingAverage(endTime time.Time) { // Calculate aggregate avg bandwidth and exp window avg m.lock.Lock() defer func() { m.startTime = endTime m.lock.Unlock() }() if m.startTime.IsZero() { return } if endTime.Before(m.startTime) { return
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Tue Feb 06 06:00:45 UTC 2024 - 14.2K bytes - Viewed (0) -
pilot/pkg/serviceregistry/kube/controller/controller.go
"k8s.io/apimachinery/pkg/types" "istio.io/api/label" "istio.io/istio/pilot/pkg/features" "istio.io/istio/pilot/pkg/model" "istio.io/istio/pilot/pkg/serviceregistry" "istio.io/istio/pilot/pkg/serviceregistry/aggregate" "istio.io/istio/pilot/pkg/serviceregistry/kube" "istio.io/istio/pilot/pkg/serviceregistry/kube/controller/ambient" "istio.io/istio/pilot/pkg/serviceregistry/provider"
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 23 21:07:03 UTC 2024 - 41.2K bytes - Viewed (0) -
pkg/registry/rbac/rest/storage_rbac.go
return false, nil } // if the new cluster roles to aggregate do not yet exist, then we need to copy the old roles if they don't exist // in new locations if err := primeAggregatedClusterRoles(p.ClusterRolesToAggregate, client.RbacV1()); err != nil { utilruntime.HandleError(fmt.Errorf("unable to prime aggregated clusterroles: %v", err)) return false, nil }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Jul 14 03:25:19 UTC 2022 - 18.5K bytes - Viewed (0) -
staging/src/k8s.io/api/rbac/v1/types.go
// stomped by the controller. // +optional AggregationRule *AggregationRule `json:"aggregationRule,omitempty" protobuf:"bytes,3,opt,name=aggregationRule"` } // AggregationRule describes how to locate ClusterRoles to aggregate into the ClusterRole type AggregationRule struct { // 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 May 23 17:42:49 UTC 2024 - 10.7K bytes - Viewed (0) -
pilot/pkg/bootstrap/server.go
e := model.NewEnvironment() e.DomainSuffix = args.RegistryOptions.KubeOptions.DomainSuffix e.SetLedger(buildLedger(args.RegistryOptions)) ac := aggregate.NewController(aggregate.Options{ MeshHolder: e, }) e.ServiceDiscovery = ac s := &Server{ clusterID: getClusterID(args), environment: e,
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 13 17:48:28 UTC 2024 - 46.3K bytes - Viewed (0)