- Sort Score
- Result 10 results
- Languages All
Results 71 - 80 of 1,474 for tracks (0.18 sec)
-
platforms/core-configuration/input-tracking/src/main/java/org/gradle/internal/configuration/inputs/AccessTrackingSet.java
import javax.annotation.Nullable; import java.util.Collection; import java.util.Iterator; import java.util.Set; import java.util.function.Function; /** * The special-cased implementation of {@link Set} that tracks all accesses to its elements. * * @param <E> the type of elements */ class AccessTrackingSet<E> extends ForwardingSet<E> { public interface Listener { void onAccess(@Nullable Object o);
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Sat Nov 11 00:37:04 UTC 2023 - 5K bytes - Viewed (0) -
pkg/test/util/yml/cache.go
"os" "path" "strings" "sync" ) // Cache tracks the life-cycle of Yaml based resources. It stores single-part Yaml files on disk and updates the // files as needed, as the resources change. type Cache struct { mu sync.Mutex discriminator int64 resources map[CacheKey]*resourceState dir string } // CacheKey is a key representing a tracked Yaml based resource. type CacheKey struct { group string
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Aug 03 18:09:59 UTC 2021 - 4K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/Protocol.kt
*/ HTTP_1_0("http/1.0"), /** * A plaintext framing that includes persistent connections. * * This version of OkHttp implements [RFC 7230][rfc_7230], and tracks revisions to that spec. * * [rfc_7230]: https://tools.ietf.org/html/rfc7230 */ HTTP_1_1("http/1.1"), /** * Chromium's binary-framed protocol that includes header compression, multiplexing multiple
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Sat Apr 06 04:17:33 UTC 2024 - 4.4K bytes - Viewed (0) -
pkg/controller/job/tracking_utils.go
// uidTrackingExpectations to remember which UID it has seen/still waiting for. type uidSet struct { sync.RWMutex set sets.Set[string] key string } // uidTrackingExpectations tracks the UIDs of Pods the controller is waiting to // observe tracking finalizer deletions. type uidTrackingExpectations struct { store cache.Store }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 14 05:40:02 UTC 2023 - 4.3K bytes - Viewed (0) -
pilot/pkg/xds/statusgen.go
Server *DiscoveryServer // TODO: track last N Nacks and connection events, with 'version' based on timestamp. // On new connect, use version to send recent events since last update. } func NewStatusGen(s *DiscoveryServer) *StatusGen { return &StatusGen{ Server: s, } } // Generate XDS responses about internal events: // - connection status // - NACKs // We can also expose ACKS.
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Jan 10 23:30:28 UTC 2024 - 5.6K bytes - Viewed (0) -
pilot/pkg/config/memory/controller.go
type Controller struct { monitor Monitor configStore model.ConfigStore hasSynced func() bool // If meshConfig.DiscoverySelectors are specified, the namespacesFilter tracks the namespaces this controller watches. namespacesFilter func(obj interface{}) bool } // NewController return an implementation of ConfigStoreController
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Jun 26 13:54:32 UTC 2023 - 4.7K bytes - Viewed (0) -
pkg/controller/endpointslicemirroring/reconciler.go
) // reconciler is responsible for transforming current EndpointSlice state into // desired state type reconciler struct { client clientset.Interface // endpointSliceTracker tracks the list of EndpointSlices and associated // resource versions expected for each Endpoints resource. It can help // determine if a cached EndpointSlice is out of date. endpointSliceTracker *endpointsliceutil.EndpointSliceTracker
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jul 11 18:08:12 UTC 2023 - 13.1K bytes - Viewed (0) -
subprojects/core-api/src/main/java/org/gradle/api/provider/HasConfigurableValue.java
* * <p>To calculate the final value of this object any source for the value is queried and the result used as the final value for this object. The source is discarded * so that this object no longer tracks the value of the source.</p> * * <p>Subsequent attempts to change the value of this object or to replace the source from which the value is derived will fail with an exception. *
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Jan 05 16:10:02 UTC 2021 - 4.2K bytes - Viewed (0) -
pkg/controller/nodeipam/node_ipam_controller.go
go nc.legacyIPAM.Run(ctx) } else { go nc.cidrAllocator.Run(ctx) } <-ctx.Done() } // RunWithMetrics is a wrapper for Run that also tracks starting and stopping of the nodeipam controller with additional metric func (nc *Controller) RunWithMetrics(ctx context.Context, controllerManagerMetrics *controllersmetrics.ControllerManagerMetrics) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Jun 06 16:18:38 UTC 2024 - 5.4K bytes - Viewed (0) -
pkg/xds/server.go
for _, rr := range r { a = append(a, rr.Resource) } return a } // WatchedResource tracks an active DiscoveryRequest subscription. type WatchedResource struct { // TypeUrl is copied from the DiscoveryRequest.TypeUrl that initiated watching this resource. // nolint TypeUrl string // ResourceNames tracks the list of resources that are actively watched.
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon May 13 20:55:20 UTC 2024 - 16.3K bytes - Viewed (0)