- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 65 for Aggregate (0.36 sec)
-
api/pom.xml
Registered: Wed Jun 12 09:55:16 UTC 2024 - Last Modified: Wed May 22 14:07:09 UTC 2024 - 3.7K bytes - Viewed (0) -
pilot/pkg/bootstrap/servicecontroller.go
import ( "fmt" "istio.io/istio/pilot/pkg/serviceregistry/aggregate" kubecontroller "istio.io/istio/pilot/pkg/serviceregistry/kube/controller" "istio.io/istio/pilot/pkg/serviceregistry/provider" "istio.io/istio/pilot/pkg/serviceregistry/serviceentry" "istio.io/istio/pkg/log" "istio.io/istio/pkg/util/sets" ) func (s *Server) ServiceController() *aggregate.Controller { return s.environment.ServiceDiscovery.(*aggregate.Controller)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 23 21:07:03 UTC 2024 - 3.2K bytes - Viewed (0) -
prow/config/metrics/metrics.yaml
--- apiVersion: rbac.authorization.k8s.io/v1 kind: ClusterRole metadata: labels: k8s-app: metrics-server rbac.authorization.k8s.io/aggregate-to-admin: "true" rbac.authorization.k8s.io/aggregate-to-edit: "true" rbac.authorization.k8s.io/aggregate-to-view: "true" name: system:aggregated-metrics-reader rules: - apiGroups: - metrics.k8s.io resources: - pods - nodes verbs: - get
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Apr 11 20:51:38 UTC 2024 - 4.6K bytes - Viewed (0) -
maven-api-impl/src/main/java/org/apache/maven/internal/impl/resolver/DefaultModelRepositoryHolder.java
repositories = repositoryFactory.aggregate(session, repositories, repos, true); pomRepositories = repositories; } else { pomRepositories = repositoryFactory.aggregate(session, pomRepositories, repos, true); repositories = repositoryFactory.aggregate(session, pomRepositories, externalRepositories, false); } } @Override
Registered: Wed Jun 12 09:55:16 UTC 2024 - Last Modified: Thu May 02 15:10:38 UTC 2024 - 4.3K bytes - Viewed (0) -
pilot/pkg/serviceregistry/kube/controller/fake.go
} f := namespace.NewDiscoveryNamespacesFilter( kclient.New[*corev1.Namespace](opts.Client), opts.MeshWatcher, stop, ) kubelib.SetObjectFilter(opts.Client, f) meshServiceController := aggregate.NewController(aggregate.Options{MeshHolder: opts.MeshWatcher}) options := Options{ DomainSuffix: domainSuffix, XDSUpdater: xdsUpdater, Metrics: &model.Environment{},
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 23 21:07:03 UTC 2024 - 4K bytes - Viewed (0) -
pilot/pkg/serviceregistry/kube/controller/multicluster_test.go
) const ( testSecretNameSpace = "istio-system" DomainSuffix = "fake_domain" ) func newMockserviceController() *aggregate.Controller { return aggregate.NewController(aggregate.Options{}) } func createMultiClusterSecret(k8s kube.Client, sname, cname string) error { data := map[string][]byte{} secret := v1.Secret{ ObjectMeta: metav1.ObjectMeta{ Name: sname,
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Apr 12 16:44:32 UTC 2024 - 6.7K bytes - Viewed (0) -
platforms/software/reporting/src/main/java/org/gradle/api/reporting/GenerateBuildDashboard.java
} /** * Configures which reports are to be aggregated in the build dashboard report generated by this task. * * <pre> * buildDashboard { * aggregate codenarcMain, checkstyleMain * } * </pre> * * @param reportings an array of {@link Reporting} instances that are to be aggregated */ @SuppressWarnings("unchecked")
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Feb 22 11:30:12 UTC 2024 - 7.2K bytes - Viewed (0) -
pilot/pkg/serviceregistry/aggregate/leak_test.go
// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. // See the License for the specific language governing permissions and // limitations under the License. package aggregate import ( "testing" "istio.io/istio/tests/util/leak" ) func TestMain(m *testing.M) { // CheckMain asserts that no goroutines are leaked after a test package exits. leak.CheckMain(m)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Sun Apr 28 04:22:19 UTC 2024 - 794 bytes - Viewed (0) -
platforms/software/testing-base/src/main/java/org/gradle/api/tasks/testing/TestListener.java
*/ void beforeSuite(TestDescriptor suite); /** * Called after a test suite is finished. * @param suite The suite whose tests have finished being executed. * @param result The aggregate result for the suite. */ void afterSuite(TestDescriptor suite, TestResult result); /** * Called before an atomic test is started. * @param testDescriptor The test which is about to be executed.
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Mar 12 02:21:10 UTC 2024 - 2K bytes - Viewed (0) -
src/internal/coverage/cformat/format.go
var totalStmts, coveredStmts uint64 for _, importpath := range pkgs { p := fm.pm[importpath] if !aggregate { totalStmts, coveredStmts = 0, 0 } for unit, count := range p.unitTable { nx := uint64(unit.NxStmts) totalStmts += nx if count != 0 { coveredStmts += nx } } if !aggregate { if _, err := fmt.Fprintf(w, "\t%s\t\t", importpath); err != nil { return err }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 23 01:00:11 UTC 2024 - 9.7K bytes - Viewed (0)