- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 10 for NOOP (0.09 sec)
-
pkg/controlplane/apiserver/options/options_test.go
package options import ( "reflect" "testing" "time" "github.com/google/go-cmp/cmp" "github.com/google/go-cmp/cmp/cmpopts" "github.com/spf13/pflag" noopoteltrace "go.opentelemetry.io/otel/trace/noop" "k8s.io/apiserver/pkg/admission" apiserveroptions "k8s.io/apiserver/pkg/server/options" "k8s.io/apiserver/pkg/storage/etcd3" "k8s.io/apiserver/pkg/storage/storagebackend"
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jun 07 17:57:37 UTC 2024 - 10.7K bytes - Viewed (0) -
subprojects/core/src/main/java/org/gradle/internal/service/scopes/GlobalScopeServices.java
return new DefaultDomainObjectCollectionFactory(instantiatorFactory, services, CollectionCallbackActionDecorator.NOOP, MutationGuards.identity()); } @Provides @Override PatternSpecFactory createPatternSpecFactory(ListenerManager listenerManager) {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Jun 11 09:51:15 UTC 2024 - 15.4K bytes - Viewed (0) -
cmd/kube-apiserver/app/options/options_test.go
package options import ( "net" "reflect" "testing" "time" "github.com/google/go-cmp/cmp" "github.com/google/go-cmp/cmp/cmpopts" "github.com/spf13/pflag" noopoteltrace "go.opentelemetry.io/otel/trace/noop" "k8s.io/apiserver/pkg/admission" apiserveroptions "k8s.io/apiserver/pkg/server/options" "k8s.io/apiserver/pkg/storage/etcd3" "k8s.io/apiserver/pkg/storage/storagebackend"
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jun 07 17:57:37 UTC 2024 - 12.7K bytes - Viewed (0) -
pkg/kubelet/util/manager/cache_based_manager_test.go
{envVarNames: []string{"s7"}}, {envFromNames: []string{"s70"}}, }, } // Check the no-op update scenario manager.RegisterPod(podWithSecrets("ns1", "noop-pod", s5)) manager.RegisterPod(podWithSecrets("ns1", "noop-pod", s5)) // Now we have: 3 pods with s1, 2 pods with s2 and 2 pods with s3, 0 pods with s4. refs := func(ns, name string) int { store.lock.Lock() defer store.lock.Unlock()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:25:43 UTC 2024 - 19.6K bytes - Viewed (0) -
pkg/controlplane/apiserver/config.go
limitations under the License. */ package apiserver import ( "context" "crypto/tls" "fmt" "net/http" "time" noopoteltrace "go.opentelemetry.io/otel/trace/noop" "k8s.io/apimachinery/pkg/runtime" utilnet "k8s.io/apimachinery/pkg/util/net" "k8s.io/apimachinery/pkg/util/sets" "k8s.io/apimachinery/pkg/util/wait" "k8s.io/apiserver/pkg/admission"
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jun 07 17:57:37 UTC 2024 - 14.9K bytes - Viewed (0) -
cmd/storage-rest-client.go
// - this change attempts to avoid stale information if the underlying // transport is already down. return info, errDiskNotFound } // if 'NoOp' we do not cache the value. if opts.NoOp { ctx, cancel := context.WithTimeout(ctx, 5*time.Second) defer cancel() opts.DiskID = *client.diskID.Load() infop, err := storageDiskInfoRPC.Call(ctx, client.gridConn, &opts)
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Mon Jun 10 15:51:27 UTC 2024 - 27.4K bytes - Viewed (0) -
platforms/core-configuration/dependency-management-serialization-codecs/src/main/kotlin/org/gradle/internal/serialize/codecs/dm/LocalFileDependencyBackedArtifactSetCodec.kt
val artifactTypeRegistry = decodePreservingSharedIdentity { val registry = DefaultArtifactTypeRegistry(instantiator, attributesFactory, CollectionCallbackActionDecorator.NOOP, EmptyVariantTransformRegistry) val mappings = registry.create()!! readCollection { val name = readString() val attributes = readNonNull<AttributeContainer>()
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Jun 04 18:56:44 UTC 2024 - 17.5K bytes - Viewed (0) -
cmd/storage-datatypes.go
type RenameOptions struct { BaseOptions } // DiskInfoOptions options for requesting custom results. type DiskInfoOptions struct { DiskID string `msg:"id"` Metrics bool `msg:"m"` NoOp bool `msg:"np"` } // DiskInfo is an extended type which returns current // disk usage per path. // The above means that any added/deleted fields are incompatible. //
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Mon Jun 10 15:51:27 UTC 2024 - 15.7K bytes - Viewed (0) -
pkg/volume/plugins.go
volumePlugin, err := pm.FindPluginBySpec(spec) if err != nil { if spec.IsKubeletExpandable() { // for kubelet expandable volumes, return a noop plugin that // returns success for expand on the controller klog.V(4).InfoS("FindExpandablePluginBySpec -> returning noopExpandableVolumePluginInstance", "specName", spec.Name())
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Jun 06 16:13:15 UTC 2024 - 38.2K bytes - Viewed (0) -
cmd/xl-storage-disk-id-check.go
if contextCanceled(ctx) { return DiskInfo{}, ctx.Err() } si := p.updateStorageMetrics(storageMetricDiskInfo) defer si(0, &err) if opts.NoOp { if opts.Metrics { info.Metrics = p.getMetrics() } info.Metrics.TotalWrites = p.totalWrites.Load() info.Metrics.TotalDeletes = p.totalDeletes.Load()
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Mon Jun 10 15:51:27 UTC 2024 - 33.4K bytes - Viewed (0)