Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 1,408 for noteFn (0.21 sec)

  1. staging/src/k8s.io/apiserver/pkg/util/flowcontrol/apf_filter.go

    type Interface interface {
    	// Handle takes care of queuing and dispatching a request
    	// characterized by the given digest.  The given `noteFn` will be
    	// invoked with the results of request classification.
    	// The given `workEstimator` is called, if at all, after noteFn.
    	// `workEstimator` will be invoked only when the request
    	//  is classified as non 'exempt'.
    	// 'workEstimator', when invoked, must return the
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Oct 30 12:18:35 UTC 2023
    - 8K bytes
    - Viewed (0)
  2. staging/src/k8s.io/apiserver/pkg/util/flowcontrol/apf_filter_test.go

    	}
    
    	reqInfo := &request.RequestInfo{
    		IsResourceRequest: false,
    		Path:              "/foobar",
    		Verb:              "GET",
    	}
    	noteFn := func(fs *flowcontrol.FlowSchema, plc *flowcontrol.PriorityLevelConfiguration, fd string) {}
    	workEstr := func() fcrequest.WorkEstimate { return fcrequest.WorkEstimate{InitialSeats: 1} }
    
    	flowUser := testUser{name: "test-user"}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Oct 30 12:18:40 UTC 2023
    - 5.6K bytes
    - Viewed (0)
  3. staging/src/k8s.io/apiserver/pkg/server/filters/priority-and-fairness.go

    			// soon as the request is processed from the APF point of view.
    			//
    			// Note that we explicitly do NOT call the actuall handler using that context
    			// to avoid cancelling request too early.
    			handleCtx, handleCtxCancel := h.newReqWaitCtxFn(ctx)
    			defer handleCtxCancel()
    
    			// Note that Handle will return irrespective of whether the request
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Oct 30 12:18:35 UTC 2023
    - 15.3K bytes
    - Viewed (0)
  4. staging/src/k8s.io/apiserver/pkg/util/flowcontrol/borrowing_test.go

    			}
    
    			concIntegrators := make([]fq.Integrator, 2)
    			reqInfo := &request.RequestInfo{
    				IsResourceRequest: false,
    				Path:              "/foobar",
    				Verb:              "GET",
    			}
    			noteFn := func(fs *flowcontrol.FlowSchema, plc *flowcontrol.PriorityLevelConfiguration, fd string) {}
    			workEstr := func() fcrequest.WorkEstimate { return fcrequest.WorkEstimate{InitialSeats: 1} }
    			qnf := fq.QueueNoteFn(func(bool) {})
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Oct 30 12:18:40 UTC 2023
    - 9K bytes
    - Viewed (0)
  5. staging/src/k8s.io/apiserver/pkg/server/filters/priority-and-fairness_test.go

    	requestDigest utilflowcontrol.RequestDigest,
    	noteFn func(fs *flowcontrol.FlowSchema, pl *flowcontrol.PriorityLevelConfiguration, flowDistinguisher string),
    	workEstimator func() fcrequest.WorkEstimate,
    	queueNoteFn fq.QueueNoteFn,
    	execFn func(),
    ) {
    	if t.mockDecision == decisionSkipFilter {
    		panic("Handle should not be invoked")
    	}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Oct 30 12:18:40 UTC 2023
    - 52.6K bytes
    - Viewed (0)
  6. staging/src/k8s.io/apiserver/pkg/util/flowcontrol/apf_controller.go

    // limitation.  The startWaitingTime is when the request started
    // waiting in its queue, or `Time{}` if this did not happen.
    func (cfgCtlr *configController) startRequest(ctx context.Context, rd RequestDigest,
    	noteFn func(fs *flowcontrol.FlowSchema, pl *flowcontrol.PriorityLevelConfiguration, flowDistinguisher string),
    	workEstimator func() fcrequest.WorkEstimate,
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 48.8K bytes
    - Viewed (0)
  7. src/cmd/vendor/golang.org/x/mod/sumdb/note/note.go

    //		"then you don't know what your problem is.\n"
    //
    //	signer, err := note.NewSigner(skey)
    //	if err != nil {
    //		log.Fatal(err)
    //	}
    //
    //	msg, err := note.Sign(&note.Note{Text: text}, signer)
    //	if err != nil {
    //		log.Fatal(err)
    //	}
    //	os.Stdout.Write(msg)
    //
    // The note's text is two lines, including the final newline,
    // and the text is purportedly signed by a server named
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed Jul 12 20:38:21 UTC 2023
    - 20.1K bytes
    - Viewed (0)
  8. platforms/documentation/docs/src/docs/release/notes.md

    For Java, Groovy, Kotlin, and Android compatibility, see the [full compatibility notes](userguide/compatibility.html).   
    
    ## New features and usability improvements
    
    <!-- Do not add breaking changes or deprecations here! Add them to the upgrade guide instead. -->
    
    <!--
    
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Tue Jun 11 07:16:40 UTC 2024
    - 3.6K bytes
    - Viewed (0)
  9. src/cmd/internal/buildid/note.go

    			if align != 0 {
    				alignedOff := (off + align - 1) &^ (align - 1)
    				notesz += alignedOff - off
    				off = alignedOff
    			}
    			filesz -= notesz
    			note = note[notesz:]
    		}
    	}
    
    	// If we didn't find a Go note, use a GNU note if available.
    	// This is what gccgo uses.
    	if gnu != "" {
    		return gnu, nil
    	}
    
    	// No note. Treat as successful but build ID empty.
    	return "", nil
    }
    
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu Aug 17 20:40:42 UTC 2023
    - 6K bytes
    - Viewed (0)
  10. platforms/documentation/docs/src/docs/release/notes-template.md

    For Java, Groovy, Kotlin, and Android compatibility, see the [full compatibility notes](userguide/compatibility.html).   
    
    ## New features and usability improvements
    
    <!-- Do not add breaking changes or deprecations here! Add them to the upgrade guide instead. -->
    
    <!--
    
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Tue Jun 11 14:04:10 UTC 2024
    - 3.6K bytes
    - Viewed (0)
Back to top