Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 36 for flowschema (0.22 sec)

  1. pkg/registry/flowcontrol/ensurer/flowschema_test.go

    		strategy  func() EnsureStrategy[*flowcontrolv1.FlowSchema]
    		current   *flowcontrolv1.FlowSchema
    		bootstrap *flowcontrolv1.FlowSchema
    		expected  *flowcontrolv1.FlowSchema
    	}{
    		// for suggested configurations
    		{
    			name:      "suggested flow schema does not exist - the object should always be re-created",
    			strategy:  NewSuggestedEnsureStrategy[*flowcontrolv1.FlowSchema],
    			bootstrap: newFlowSchema("fs1", "pl1", 100).Object(),
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Oct 30 12:18:35 UTC 2023
    - 15.2K bytes
    - Viewed (0)
  2. staging/src/k8s.io/apiserver/pkg/util/flowcontrol/metrics/metrics.go

    	apiserverCurrentInqueueSeats.WithLabelValues(priorityLevel, flowSchema).Add(float64(delta))
    }
    
    // AddRequestsExecuting adds the given delta to the gauge of executing requests of the given flowSchema and priorityLevel
    func AddRequestsExecuting(ctx context.Context, priorityLevel, flowSchema string, delta int) {
    	apiserverCurrentExecutingRequests.WithLabelValues(priorityLevel, flowSchema).Add(float64(delta))
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Jul 24 19:40:05 UTC 2023
    - 25.6K bytes
    - Viewed (0)
  3. staging/src/k8s.io/apiserver/pkg/util/flowcontrol/apf_controller.go

    				// and nothing more needs to be done here.
    				klog.V(5).Infof("%s at %s: attempted update of concurrently deleted FlowSchema %s; nothing more needs to be done", cfgCtlr.name, cfgCtlr.clock.Now().Format(timeFmt), fsu.flowSchema.Name)
    			} else {
    				errs = append(errs, fmt.Errorf("failed to set a status.condition for FlowSchema %s: %w", fsu.flowSchema.Name, err))
    			}
    		}
    	}
    	cfgCtlr.addUpdateResult(currResult)
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 48.8K bytes
    - Viewed (0)
  4. common-protos/k8s.io/api/flowcontrol/v1beta3/generated.proto

      // Required.
      optional string type = 1;
    }
    
    // FlowSchema defines the schema of a group of flows. Note that a flow is made up of a set of inbound API requests with
    // similar attributes and is identified by a pair of strings: the name of the FlowSchema and a "flow distinguisher".
    message FlowSchema {
      // `metadata` is the standard object's metadata.
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Mon Mar 11 18:43:24 UTC 2024
    - 19.5K bytes
    - Viewed (0)
  5. staging/src/k8s.io/apiserver/pkg/util/flowcontrol/controller_test.go

    	newFTRs = map[string]*fsTestingRecord{}
    	catchAlls = map[bool]*flowcontrol.FlowSchema{
    		false: fcboot.MandatoryFlowSchemaCatchAll,
    		true:  fcboot.MandatoryFlowSchemaCatchAll}
    	newFSMap = map[string]*flowcontrol.FlowSchema{}
    	add := func(ftr *fsTestingRecord) {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Oct 30 12:18:40 UTC 2023
    - 18.4K bytes
    - Viewed (0)
  6. common-protos/k8s.io/api/flowcontrol/v1alpha1/generated.proto

      // Required.
      optional string type = 1;
    }
    
    // FlowSchema defines the schema of a group of flows. Note that a flow is made up of a set of inbound API requests with
    // similar attributes and is identified by a pair of strings: the name of the FlowSchema and a "flow distinguisher".
    message FlowSchema {
      // `metadata` is the standard object's metadata.
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Mon Mar 11 18:43:24 UTC 2024
    - 19.4K bytes
    - Viewed (0)
  7. common-protos/k8s.io/api/flowcontrol/v1beta2/generated.proto

      // Required.
      optional string type = 1;
    }
    
    // FlowSchema defines the schema of a group of flows. Note that a flow is made up of a set of inbound API requests with
    // similar attributes and is identified by a pair of strings: the name of the FlowSchema and a "flow distinguisher".
    message FlowSchema {
      // `metadata` is the standard object's metadata.
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Mon Mar 11 18:43:24 UTC 2024
    - 19.4K bytes
    - Viewed (0)
  8. common-protos/k8s.io/api/flowcontrol/v1beta1/generated.proto

      // Required.
      optional string type = 1;
    }
    
    // FlowSchema defines the schema of a group of flows. Note that a flow is made up of a set of inbound API requests with
    // similar attributes and is identified by a pair of strings: the name of the FlowSchema and a "flow distinguisher".
    message FlowSchema {
      // `metadata` is the standard object's metadata.
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Mon Mar 11 18:43:24 UTC 2024
    - 19.4K bytes
    - Viewed (0)
  9. staging/src/k8s.io/api/flowcontrol/v1beta3/generated.proto

      // Required.
      optional string type = 1;
    }
    
    // FlowSchema defines the schema of a group of flows. Note that a flow is made up of a set of inbound API requests with
    // similar attributes and is identified by a pair of strings: the name of the FlowSchema and a "flow distinguisher".
    message FlowSchema {
      // `metadata` is the standard object's metadata.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Mar 28 15:34:11 UTC 2024
    - 21.5K bytes
    - Viewed (0)
  10. staging/src/k8s.io/api/flowcontrol/v1beta2/generated.proto

      // Required.
      optional string type = 1;
    }
    
    // FlowSchema defines the schema of a group of flows. Note that a flow is made up of a set of inbound API requests with
    // similar attributes and is identified by a pair of strings: the name of the FlowSchema and a "flow distinguisher".
    message FlowSchema {
      // `metadata` is the standard object's metadata.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Mar 28 15:34:11 UTC 2024
    - 21.4K bytes
    - Viewed (0)
Back to top