- Sort Score
- Result 10 results
- Languages All
Results 61 - 70 of 135 for Queuing (0.09 sec)
-
staging/src/k8s.io/apiserver/pkg/util/flowcontrol/fairqueuing/queueset/queueset.go
seatDemandIntegrator metrics.Gauge promiseFactory promiseFactory lock sync.Mutex // qCfg holds the current queuing configuration. Its // DesiredNumQueues may be less than the current number of queues. // If its DesiredNumQueues is zero then its other queuing // parameters retain the settings they had when DesiredNumQueues // was last non-zero (if ever). qCfg fq.QueuingConfig
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Jan 04 16:59:21 UTC 2024 - 42.4K bytes - Viewed (0) -
staging/src/k8s.io/api/flowcontrol/v1beta3/zz_generated.deepcopy.go
// DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil. func (in *LimitResponse) DeepCopyInto(out *LimitResponse) { *out = *in if in.Queuing != nil { in, out := &in.Queuing, &out.Queuing *out = new(QueuingConfiguration) **out = **in } return } // DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new LimitResponse.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jul 14 01:00:06 UTC 2023 - 17.1K bytes - Viewed (0) -
staging/src/k8s.io/api/flowcontrol/v1beta1/zz_generated.deepcopy.go
// DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil. func (in *LimitResponse) DeepCopyInto(out *LimitResponse) { *out = *in if in.Queuing != nil { in, out := &in.Queuing, &out.Queuing *out = new(QueuingConfiguration) **out = **in } return } // DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new LimitResponse.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jul 14 01:00:06 UTC 2023 - 17.1K bytes - Viewed (0) -
staging/src/k8s.io/api/flowcontrol/v1/zz_generated.deepcopy.go
// DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil. func (in *LimitResponse) DeepCopyInto(out *LimitResponse) { *out = *in if in.Queuing != nil { in, out := &in.Queuing, &out.Queuing *out = new(QueuingConfiguration) **out = **in } return } // DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new LimitResponse.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Oct 30 12:18:41 UTC 2023 - 17.3K bytes - Viewed (0) -
pkg/apis/flowcontrol/zz_generated.deepcopy.go
// DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil. func (in *LimitResponse) DeepCopyInto(out *LimitResponse) { *out = *in if in.Queuing != nil { in, out := &in.Queuing, &out.Queuing *out = new(QueuingConfiguration) **out = **in } return } // DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new LimitResponse.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jul 14 01:00:06 UTC 2023 - 17.1K bytes - Viewed (0) -
staging/src/k8s.io/api/flowcontrol/v1beta2/zz_generated.deepcopy.go
// DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil. func (in *LimitResponse) DeepCopyInto(out *LimitResponse) { *out = *in if in.Queuing != nil { in, out := &in.Queuing, &out.Queuing *out = new(QueuingConfiguration) **out = **in } return } // DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new LimitResponse.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jul 14 01:00:06 UTC 2023 - 17.1K bytes - Viewed (0) -
pkg/apis/flowcontrol/v1beta3/zz_generated.conversion.go
out.Type = flowcontrol.LimitResponseType(in.Type) out.Queuing = (*flowcontrol.QueuingConfiguration)(unsafe.Pointer(in.Queuing)) return nil } // Convert_v1beta3_LimitResponse_To_flowcontrol_LimitResponse is an autogenerated conversion function.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Oct 30 12:18:41 UTC 2023 - 53.1K bytes - Viewed (0) -
pkg/apis/flowcontrol/v1/zz_generated.conversion.go
func autoConvert_v1_LimitResponse_To_flowcontrol_LimitResponse(in *v1.LimitResponse, out *flowcontrol.LimitResponse, s conversion.Scope) error { out.Type = flowcontrol.LimitResponseType(in.Type) out.Queuing = (*flowcontrol.QueuingConfiguration)(unsafe.Pointer(in.Queuing)) return nil } // Convert_v1_LimitResponse_To_flowcontrol_LimitResponse is an autogenerated conversion function.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Oct 30 12:18:41 UTC 2023 - 52.4K bytes - Viewed (0) -
pilot/pkg/serviceregistry/kube/controller/namespacecontroller.go
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Feb 28 16:41:38 UTC 2024 - 5.4K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/util/flowcontrol/dropped_requests_tracker.go
// retryAfter // - if there were at least 3*`retryAfter` dropped requests, it increases // retryAfter // // The rationale behind these numbers being fairly low is that APF is queuing // requests and rejecting (dropping) them is a last resort, which is not expected // unless a given priority level is actually overloaded. // // Additionally, we rate-limit the increases of retryAfter to wait at least
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 26 13:50:25 UTC 2023 - 6.5K bytes - Viewed (0)