- Sort Score
- Result 10 results
- Languages All
Results 101 - 110 of 151 for gStates (0.16 sec)
-
pkg/kubeapiserver/default_storage_factory_builder.go
ResourceEncodingOverrides []schema.GroupVersionResource EtcdServersOverrides []string } // Complete completes the StorageFactoryConfig with provided etcdOptions returning completedStorageFactoryConfig. // This method mutates the receiver (StorageFactoryConfig). It must never mutate the inputs. func (c *StorageFactoryConfig) Complete(etcdOptions *serveroptions.EtcdOptions) *completedStorageFactoryConfig { c.StorageConfig = etcdOptions.StorageConfig
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed May 29 20:14:51 UTC 2024 - 6.6K bytes - Viewed (0) -
staging/src/k8s.io/apiextensions-apiserver/pkg/apiserver/schema/defaulting/surroundingobject.go
} return obj, func(root map[string]interface{}) (interface{}, bool, error) { return root, true, nil }, nil } } // WithTypeMeta returns a closure with the TypeMeta fields set if they are defined. // This mutates f(x). func (f SurroundingObjectFunc) WithTypeMeta(meta metav1.TypeMeta) SurroundingObjectFunc { return func(x interface{}) (map[string]interface{}, AccessorFunc, error) { obj, acc, err := f(x) if err != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jul 26 17:14:05 UTC 2022 - 4.9K bytes - Viewed (0) -
pkg/kubelet/volumemanager/metrics/metrics_test.go
// Check if getVolumeCount returns correct data count := metricCollector.getVolumeCount() if len(count) != 2 { t.Errorf("getVolumeCount failed. Expected <2> states, got <%d>", len(count)) } dswCount, ok := count["desired_state_of_world"] if !ok { t.Errorf("getVolumeCount failed. Expected <desired_state_of_world>, got nothing") }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Mar 14 00:37:30 UTC 2023 - 4K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/util/flowcontrol/rule.go
"k8s.io/apiserver/pkg/authentication/serviceaccount" "k8s.io/apiserver/pkg/authentication/user" "k8s.io/apiserver/pkg/endpoints/request" ) // Tests whether a given request and FlowSchema match. Nobody mutates // either input. func matchesFlowSchema(digest RequestDigest, flowSchema *flowcontrol.FlowSchema) bool { for _, policyRule := range flowSchema.Spec.Rules { if matchesPolicyRule(digest, &policyRule) { return true }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Oct 30 12:18:35 UTC 2023 - 6.3K bytes - Viewed (0) -
pkg/security/apparmor/validate.go
func (v *validator) ValidateHost() error { return v.validateHostErr } // validateHost verifies that the host and runtime is capable of enforcing AppArmor profiles. func validateHost() error { // Check feature-gates if !utilfeature.DefaultFeatureGate.Enabled(features.AppArmor) { return errors.New("AppArmor disabled by feature-gate") } // Check build support. if isDisabledBuild {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Mar 05 20:22:50 UTC 2024 - 3.1K bytes - Viewed (0) -
src/html/template/context.go
return true } return false } // isInScriptLiteral returns true if s is one of the literal states within a // <script> tag, and as such occurrences of "<!--", "<script", and "</script" // need to be treated specially. func isInScriptLiteral(s state) bool { // Ignore the comment states (stateJSBlockCmt, stateJSLineCmt, // stateJSHTMLOpenCmt, stateJSHTMLCloseCmt) because their content is already
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Oct 16 03:29:27 UTC 2023 - 9.4K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/cacher/ready.go
select { case <-ctx.Done(): return 0, ctx.Err() case <-r.done(): } r.lock.RLock() switch r.state { case Pending: // since we allow to switch between the states Pending and Ready // if there is a quick transition from Pending -> Ready -> Pending // a process that was waiting can get unblocked and see a Pending // state again. If the state is Pending we have to wait again to
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Mar 16 13:32:11 UTC 2023 - 4.1K bytes - Viewed (0) -
staging/src/k8s.io/apimachinery/pkg/util/proxy/dial_test.go
ts.TLS = &tls.Config{Certificates: []tls.Certificate{cert}, NextProtos: []string{"http2", "http/1.1"}} ts.StartTLS() // Make a copy of the config tlsConfigCopy := tc.TLSConfig.Clone() // Clone() mutates the receiver (!), so also call it on the copy tlsConfigCopy.Clone() transport := &http.Transport{ DialContext: tc.Dial, TLSClientConfig: tlsConfigCopy, }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Oct 23 22:33:38 UTC 2023 - 8.4K bytes - Viewed (0) -
tensorflow/compiler/mlir/tensorflow/analysis/resource_value_typed_analyzer.cc
PropagatePotentiallyWrittenUpFromCallee(batch_function.func().getRegion(), batch_function.getOperands()); return; } // For all other ops, we assume it mutates all resources it uses, so // this errs on the side of being conservative. We should improve // this by using either a property or a trait that clearly // identifies ops with resource mutating behavior.
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Wed May 15 09:04:13 UTC 2024 - 8K bytes - Viewed (0) -
cmd/metacache.go
if len(b) > 0 && !strings.HasSuffix(b, slashSeparator) { b += slashSeparator } return b } // update cache with new status. // The updates are conditional so multiple callers can update with different states. func (m *metacache) update(update metacache) { m.lastUpdate = UTCNow() if m.lastHandout.After(m.lastHandout) { m.lastHandout = UTCNow() }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Thu Apr 04 12:04:40 UTC 2024 - 5K bytes - Viewed (0)