- Sort Score
- Result 10 results
- Languages All
Results 131 - 140 of 153 for _encapsulate (0.2 sec)
-
cmd/bucket-lifecycle.go
} } } func initBackgroundExpiry(ctx context.Context, objectAPI ObjectLayer) { globalExpiryState = newExpiryState(ctx, objectAPI, globalILMConfig.getExpirationWorkers()) } // newerNoncurrentTask encapsulates arguments required by worker to expire objects // by NewerNoncurrentVersions type newerNoncurrentTask struct { bucket string versions []ObjectToDelete event lifecycle.Event }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Mon Jun 10 15:31:51 UTC 2024 - 33.3K bytes - Viewed (0) -
android/guava/src/com/google/common/collect/MinMaxPriorityQueue.java
for (int i = 1; i < size; i++) { if (!heapForIndex(i).verifyIndex(i)) { return false; } } return true; } /** * Each instance of MinMaxPriorityQueue encapsulates two instances of Heap: a min-heap and a * max-heap. Conceptually, these might each have their own array for storage, but for efficiency's
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Thu Feb 22 21:19:52 UTC 2024 - 34K bytes - Viewed (0) -
guava/src/com/google/common/util/concurrent/CycleDetectingLockFactory.java
* * @author Darick Tong * @since 13.0 */ @J2ktIncompatible @GwtIncompatible @ElementTypesAreNonnullByDefault public class CycleDetectingLockFactory { /** * Encapsulates the action to be taken when a potential deadlock is encountered. Clients can use * one of the predefined {@link Policies} or specify a custom implementation. Implementations must * be thread-safe. *
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Fri Dec 15 19:31:54 UTC 2023 - 35.9K bytes - Viewed (0) -
src/image/png/reader_test.go
// color model (in the IHDR chunk). The Go model is that the concrete // image.Image type returned by png.Decode, such as image.RGBA (with all pixels // having 100% alpha) or image.NRGBA, encapsulates whether or not the image has // transparency. This map is a hack to work around the fact that the Go model // can't otherwise discriminate PNG's "IHDR says color (with no alpha) but tRNS
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Aug 24 12:12:12 UTC 2022 - 28.5K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/util/proxy/streamtranslator_test.go
t.Fatal(err) } metrics.ResetForTest() // Clear metrics each loop } } // streamContext encapsulates the structures necessary to communicate through // a SPDY connection, including the Reader/Writer streams. type streamContext struct { conn io.Closer stdinStream io.ReadCloser stdoutStream io.WriteCloser
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Feb 27 23:21:55 UTC 2024 - 36.4K bytes - Viewed (0) -
pkg/registry/core/service/storage/alloc.go
"k8s.io/kubernetes/pkg/features" "k8s.io/kubernetes/pkg/registry/core/service/ipallocator" "k8s.io/kubernetes/pkg/registry/core/service/portallocator" netutils "k8s.io/utils/net" ) // Allocators encapsulates the various allocators (IPs, ports) used in // Services. type Allocators struct { serviceIPAllocatorsByFamily map[api.IPFamily]ipallocator.Interface defaultServiceIPFamily api.IPFamily // --service-cluster-ip-range[0]
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Oct 31 21:05:05 UTC 2023 - 37.3K bytes - Viewed (0) -
pilot/pkg/networking/core/gateway.go
// build adds the provided TCP and HTTP filters to the provided Listener and serializes them. // TODO: given how tightly tied listener.FilterChains, opts.filterChainOpts, and mutable.FilterChains // are to each other we should encapsulate them some way to ensure they remain consistent (mainly that // in each an index refers to the same chain). func (ml *MutableGatewayListener) build(builder *ListenerBuilder, opts gatewayListenerOpts) error {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon May 06 04:44:06 UTC 2024 - 46.4K bytes - Viewed (0) -
src/net/http/cookiejar/jar_test.go
func mustParseURL(s string) *url.URL { u, err := url.Parse(s) if err != nil || u.Scheme == "" || u.Host == "" { panic(fmt.Sprintf("Unable to parse URL %s.", s)) } return u } // jarTest encapsulates the following actions on a jar: // 1. Perform SetCookies with fromURL and the cookies from setCookies. // (Done at time tNow + 0 ms.) // 2. Check that the entries in the jar matches content.
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 23 01:00:11 UTC 2024 - 34K bytes - Viewed (0) -
platforms/documentation/docs/src/docs/userguide/authoring-builds/tasks/implementing_custom_tasks.adoc
- Instead of `List<T>`, use `ListProperty<T>`. - Instead of `Set<T>`, use `SetProperty<T>`. == Annotating inputs and outputs A good practice is to create a task class for your custom task. The class encapsulates the task action logic, but should also declare any inputs and outputs the task expects. To do this, we use annotations.
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Apr 26 05:34:54 UTC 2024 - 37.2K bytes - Viewed (0) -
cmd/erasure-sets.go
xioutil "github.com/minio/minio/internal/ioutil" "github.com/minio/minio/internal/logger" "github.com/minio/pkg/v3/console" "github.com/minio/pkg/v3/sync/errgroup" ) // setsDsyncLockers is encapsulated type for Close() type setsDsyncLockers [][]dsync.NetLocker // erasureSets implements ObjectLayer combining a static list of erasure coded // object sets. NOTE: There is no dynamic scaling allowed or intended in
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 37.7K bytes - Viewed (0)