- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 31 for isSubscribed (0.29 sec)
-
subprojects/build-events/src/test/groovy/org/gradle/internal/build/event/DefaultBuildEventsListenerRegistryTest.groovy
signalBuildFinished() } then: 1 * listener.finished(descriptor, finishEvent) 0 * listener._ } def "does nothing when listener is already subscribed"() { def listener = Mock(OperationCompletionListener) def provider = Providers.of(listener) when: registry.onTaskCompletion(provider) registry.onTaskCompletion(provider)
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Mar 12 02:21:10 UTC 2024 - 8K bytes - Viewed (0) -
pilot/pkg/serviceregistry/kube/controller/ambient/ambientindex.go
// The client wouldn't be explicitly subscribed to Pod1, so it would normally ignore it. // Since it is a part of VIP1 which we are subscribe to, add it to the subscriptions for addr := range allAddresses { for _, wl := range model.ExtractWorkloadsFromAddresses(a.Lookup(addr)) { // We may have gotten an update for Pod, but are subscribed to a Service. // We need to force a subscription on the Pod as well
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Apr 19 17:19:41 UTC 2024 - 15.8K bytes - Viewed (0) -
pilot/pkg/xds/deltatest.go
missedChanges := sets.SortedList(wantChanged.Difference(gotChanged)) // Optimization Potential extraChanges := sets.SortedList(gotChanged.Difference(wantChanged).Difference(knownOptimizationGaps)) if len(delta.Subscribed) > 0 { // Delta is configured to build only the request resources. Make sense we didn't build anything extra if !wantChanged.SupersetOf(gotChanged) {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 13 01:56:28 UTC 2024 - 5.7K bytes - Viewed (0) -
security/pkg/nodeagent/sds/sdsservice.go
shouldRespond, delta := xds.ShouldRespond(c.Watcher(), c.XdsConnection().ID(), req) if !shouldRespond { return nil } resources := req.ResourceNames if !delta.IsEmpty() { resources = delta.Subscribed.UnsortedList() } res, err := c.s.generate(resources) if err != nil { return err } return xds.Send(c, res) } func (c *Context) Push(ev any) error { secretName := ev.(string)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Sat May 25 00:20:04 UTC 2024 - 10.9K bytes - Viewed (0) -
src/compress/flate/inflate.go
} // Initialize Huffman decoding tables from array of code lengths. // Following this function, h is guaranteed to be initialized into a complete // tree (i.e., neither over-subscribed nor under-subscribed). The exception is a // degenerate case where the tree has only a single symbol with length 1. Empty // trees are permitted. func (h *huffmanDecoder) init(lengths []int) bool {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Oct 13 23:20:03 UTC 2023 - 20.4K bytes - Viewed (0) -
guava/src/com/google/common/eventbus/EventBus.java
* event has been posted to all subscribers, and regardless of any exceptions thrown by * subscribers. * * <p>If no subscribers have been subscribed for {@code event}'s class, and {@code event} is not * already a {@link DeadEvent}, it will be wrapped in a DeadEvent and reposted. * * @param event event to post. */ public void post(Object event) {
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Mon Jul 17 16:01:41 UTC 2023 - 12.8K bytes - Viewed (0) -
cni/pkg/nodeagent/net.go
// the following fails. // This is so that if it is removed from the mesh, the inpod rules will unconditionally // be removed. log.Debug("notifying subscribed node proxies") if err := s.sendPodToZtunnelAndWaitForAck(ctx, pod, openNetns); err != nil { return NewErrPartialAdd(err) } return nil }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 06 05:10:23 UTC 2024 - 13.4K bytes - Viewed (0) -
android/guava/src/com/google/common/eventbus/EventBus.java
* event has been posted to all subscribers, and regardless of any exceptions thrown by * subscribers. * * <p>If no subscribers have been subscribed for {@code event}'s class, and {@code event} is not * already a {@link DeadEvent}, it will be wrapped in a DeadEvent and reposted. * * @param event event to post. */ public void post(Object event) {
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Wed Aug 25 16:37:57 UTC 2021 - 12.8K bytes - Viewed (0) -
pilot/pkg/networking/core/cluster.go
subsetClusters := make(map[string]sets.String) for _, cluster := range watched.ResourceNames { // WatchedResources.ResourceNames will contain the names of the clusters it is subscribed to. We can // check with the name of our service (cluster names are in the format outbound|<port>|<subset>|<hostname>). dir, subset, svcHost, port := model.ParseSubsetKey(cluster)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 13 01:56:28 UTC 2024 - 33K bytes - Viewed (0) -
architecture/networking/pilot.md
At a high level, each client job will find the correct generator for the request, generate the required configuration, and send it. #### Optimizations A naive implementation would simply regenerate all resources, of all subscribed types, for each client, on any configuration change. However, this scales poorly. As a result, we have many levels of optimizations to avoid doing this work.
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Feb 07 17:53:24 UTC 2024 - 19.1K bytes - Viewed (0)