Search Options

Results per page
Sort
Preferred Languages
Advance

Results 41 - 50 of 145 for Implementation (0.23 sec)

  1. pkg/controller/controller_utils.go

    //		controller1: expects  2 adds in 2 minutes
    //		controller2: expects  2 dels in 2 minutes
    //		controller3: expects -1 adds in 2 minutes => controller3's expectations have already been met
    //	}
    //
    // Implementation:
    //	ControlleeExpectation = pair of atomic counters to track controllee's creation/deletion
    //	ControllerExpectationsStore = TTLStore + a ControlleeExpectation per controller
    //
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jan 12 15:34:44 UTC 2024
    - 47.6K bytes
    - Viewed (0)
  2. pkg/apis/core/v1/defaults.go

    // SetDefaults_Namespace adds a default label for all namespaces
    func SetDefaults_Namespace(obj *v1.Namespace) {
    	// we can't SetDefaults for nameless namespaces (generateName).
    	// This code needs to be kept in sync with the implementation that exists
    	// in Namespace Canonicalize strategy (pkg/registry/core/namespace)
    
    	// note that this can result in many calls to feature enablement in some cases, but
    	// we assume that there's no real cost there.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Apr 19 22:24:15 UTC 2024
    - 14.8K bytes
    - Viewed (0)
  3. staging/src/k8s.io/apiserver/pkg/admission/plugin/policy/validating/typechecking.go

    	}
    	return opts
    }
    
    type typeCheckingCompiler struct {
    	compositionEnv *plugincel.CompositionEnv
    	typeOverwrite  typeOverwrite
    }
    
    // CompileCELExpression compiles the given expression.
    // The implementation is the same as that of staging/src/k8s.io/apiserver/pkg/admission/plugin/cel/compile.go
    // except that:
    // - object, oldObject, and params are typed instead of Dyn
    // - compiler does not enforce the output type
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri May 10 22:07:40 UTC 2024
    - 15.3K bytes
    - Viewed (0)
  4. staging/src/k8s.io/apiserver/pkg/cel/library/cost.go

    				// Dont have access to underlying regex, estimate a long regexp
    				regexSize := format.MaxRegexSize
    
    				// Copied from CEL implementation for regex cost
    				//
    				// https://swtch.com/~rsc/regexp/regexp1.html applies to RE2 implementation supported by CEL
    				// Add one to string length for purposes of cost calculation to prevent product of string and regex to be 0
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Apr 23 17:22:44 UTC 2024
    - 20.6K bytes
    - Viewed (0)
  5. staging/src/k8s.io/apiserver/pkg/storage/etcd3/store_test.go

    	ctx, store, _ := testSetup(t)
    	storagetesting.RunTestCount(ctx, t, store)
    }
    
    // =======================================================================
    // Implementation-specific tests are following.
    // The following tests are exercising the details of the implementation
    // not the actual user-facing contract of storage interface.
    // As such, they may focus e.g. on non-functional aspects like performance
    // impact.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 11 12:45:33 UTC 2024
    - 26.5K bytes
    - Viewed (0)
  6. pkg/scheduler/util/assumecache/assume_cache.go

    		return -1, err
    	}
    
    	objResourceVersion, err := strconv.ParseInt(objAccessor.GetResourceVersion(), 10, 64)
    	if err != nil {
    		//nolint:errorlint // Intentionally not wrapping the error, the underlying error is an implementation detail.
    		return -1, fmt.Errorf("error parsing ResourceVersion %q for %v %q: %v", objAccessor.GetResourceVersion(), c.description, name, err)
    	}
    	return objResourceVersion, nil
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Apr 25 09:46:58 UTC 2024
    - 10.6K bytes
    - Viewed (0)
  7. pkg/volume/util/nestedpendingoperations/nestedpendingoperations.go

    WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
    See the License for the specific language governing permissions and
    limitations under the License.
    */
    
    /*
    Package nestedpendingoperations is a modified implementation of
    pkg/util/goroutinemap. It implements a data structure for managing go routines
    by volume/pod name. It prevents the creation of new go routines if an existing
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Aug 26 01:29:17 UTC 2022
    - 12.6K bytes
    - Viewed (0)
  8. staging/src/k8s.io/apiextensions-apiserver/pkg/apiserver/schema/validation.go

    		return nil
    	}
    
    	allErrs := field.ErrorList{}
    
    	// We still unconditionally forbid XValidations in quantifiers, the only
    	// quantifier that is allowed to have right now is AllOf. This is due to
    	// implementation constraints - the SchemaValidator would need to become
    	// aware of CEL to properly implement the other quantifiers.
    	optsWithCELDisabled := opts
    	optsWithCELDisabled.AllowNestedXValidations = false
    
    	if !skipAnyOf {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon May 20 18:21:31 UTC 2024
    - 14.9K bytes
    - Viewed (0)
  9. cmd/kube-proxy/app/server_linux_test.go

    			logger, _ := ktesting.NewTestContext(t)
    			r := getLocalDetectors(logger, c.primaryIPFamily, c.config, c.nodePodCIDRs)
    			if !reflect.DeepEqual(r, c.expected) {
    				t.Errorf("Unexpected detect-local implementation, expected: %q, got: %q", c.expected, r)
    			}
    		})
    	}
    }
    
    func makeNodeWithPodCIDRs(cidrs ...string) *v1.Node {
    	if len(cidrs) == 0 {
    		return &v1.Node{}
    	}
    	return &v1.Node{
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sun Apr 28 15:51:23 UTC 2024
    - 21.9K bytes
    - Viewed (0)
  10. cmd/kubeadm/app/cmd/token.go

    }
    
    // tokenTextPrinter prints bootstrap token in a text form
    type tokenTextPrinter struct {
    	output.TextPrinter
    	columns         []string
    	headerIsPrinted bool
    }
    
    // PrintObj is an implementation of ResourcePrinter.PrintObj for plain text output
    func (ttp *tokenTextPrinter) PrintObj(obj runtime.Object, writer io.Writer) error {
    	tabw := tabwriter.NewWriter(writer, 10, 4, 3, ' ', 0)
    
    	// Print header
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Apr 23 05:47:48 UTC 2024
    - 15.9K bytes
    - Viewed (0)
Back to top