- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 21 for apirequest (0.19 sec)
-
staging/src/k8s.io/apiserver/pkg/endpoints/handlers/helpers.go
limitations under the License. */ package handlers import ( "net/http" utilnet "k8s.io/apimachinery/pkg/util/net" "k8s.io/apiserver/pkg/audit" "k8s.io/apiserver/pkg/endpoints/metrics" apirequest "k8s.io/apiserver/pkg/endpoints/request" ) const ( maxUserAgentLength = 1024 userAgentTruncateSuffix = "...TRUNCATED" ) // lazyTruncatedUserAgent implements String() string and it will
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sun Sep 03 15:25:35 UTC 2023 - 4.9K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/server/filters/watch_termination_test.go
import ( "fmt" "net/http" "net/http/httptest" "testing" "k8s.io/apimachinery/pkg/runtime" apirequest "k8s.io/apiserver/pkg/endpoints/request" ) func TestWithWatchTerminationDuringShutdown(t *testing.T) { tests := []struct { name string requestInfo *apirequest.RequestInfo signal *fakeServerShutdownSignal wg *fakeRequestWaitGroup
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Feb 27 15:49:49 UTC 2023 - 5.2K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/server/filters/watch_termination.go
*/ package filters import ( "errors" "net/http" "k8s.io/apiserver/pkg/endpoints/handlers/responsewriters" apirequest "k8s.io/apiserver/pkg/endpoints/request" "k8s.io/klog/v2" ) func WithWatchTerminationDuringShutdown(handler http.Handler, termination apirequest.ServerShutdownSignal, wg RequestWaitGroup) http.Handler { if termination == nil || wg == nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Feb 27 15:49:49 UTC 2023 - 2K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/server/filters/waitgroup.go
} func withWaitGroup(handler http.Handler, longRunning apirequest.LongRunningRequestCheck, wg RequestWaitGroup, isRequestExemptFn isRequestExemptFunc) http.Handler { return http.HandlerFunc(func(w http.ResponseWriter, req *http.Request) { ctx := req.Context() requestInfo, ok := apirequest.RequestInfoFrom(ctx) if !ok {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jan 10 21:18:55 UTC 2023 - 3.7K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/server/filters/maxinflight.go
import ( "fmt" "net/http" "sync" "time" "k8s.io/apimachinery/pkg/util/sets" "k8s.io/apimachinery/pkg/util/wait" "k8s.io/apiserver/pkg/authentication/user" "k8s.io/apiserver/pkg/endpoints/metrics" apirequest "k8s.io/apiserver/pkg/endpoints/request" fcmetrics "k8s.io/apiserver/pkg/util/flowcontrol/metrics" "k8s.io/klog/v2" ) const ( // Constant for the retry-after interval on rate limiting. retryAfter = "1"
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon May 08 11:34:15 UTC 2023 - 6.9K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/util/flowcontrol/request/width.go
See the License for the specific language governing permissions and limitations under the License. */ package request import ( "fmt" "net/http" "time" apirequest "k8s.io/apiserver/pkg/endpoints/request" "k8s.io/apiserver/pkg/features" utilfeature "k8s.io/apiserver/pkg/util/feature" "k8s.io/klog/v2" )
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Jul 17 19:26:52 UTC 2023 - 5K bytes - Viewed (0) -
pkg/registry/networking/ingress/strategy_test.go
}, }, }, } } func TestIngressStrategy(t *testing.T) { ctx := genericapirequest.NewDefaultContext() apiRequest := genericapirequest.RequestInfo{APIGroup: "networking.k8s.io", APIVersion: "v1", Resource: "ingresses", } ctx = genericapirequest.WithRequestInfo(ctx, &apiRequest) if !Strategy.NamespaceScoped() { t.Errorf("Ingress must be namespace scoped") } if Strategy.AllowCreateOnUpdate() {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Nov 02 23:13:31 UTC 2022 - 4.1K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/util/flowcontrol/request/mutating_work_estimator.go
See the License for the specific language governing permissions and limitations under the License. */ package request import ( "math" "net/http" "time" apirequest "k8s.io/apiserver/pkg/endpoints/request" "k8s.io/apiserver/pkg/util/flowcontrol/metrics" ) func newMutatingWorkEstimator(countFn watchCountGetterFunc, config *WorkEstimatorConfig, maxSeatsFn maxSeatsFunc) WorkEstimatorFunc {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Jul 17 19:26:52 UTC 2023 - 6K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/util/flowcontrol/request/list_work_estimator.go
limitations under the License. */ package request import ( "math" "net/http" "net/url" metav1 "k8s.io/apimachinery/pkg/apis/meta/v1" "k8s.io/apimachinery/pkg/runtime/schema" apirequest "k8s.io/apiserver/pkg/endpoints/request" "k8s.io/apiserver/pkg/features" "k8s.io/apiserver/pkg/storage" etcdfeature "k8s.io/apiserver/pkg/storage/feature" utilfeature "k8s.io/apiserver/pkg/util/feature"
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 10 11:56:42 UTC 2024 - 7K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/endpoints/filterlatency/filterlatency.go
limitations under the License. */ package filterlatency import ( "context" "fmt" "net/http" "time" "go.opentelemetry.io/otel/trace" "k8s.io/apiserver/pkg/endpoints/metrics" apirequest "k8s.io/apiserver/pkg/endpoints/request" "k8s.io/apiserver/pkg/server/httplog" "k8s.io/klog/v2" "k8s.io/utils/clock" ) type requestFilterRecordKeyType int
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Nov 04 01:19:55 UTC 2022 - 3.7K bytes - Viewed (0)