- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 10 for WriteObjectNegotiated (0.31 sec)
-
staging/src/k8s.io/apiserver/pkg/endpoints/handlers/responsewriters/writers.go
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 07 18:21:43 UTC 2023 - 10.6K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/endpoints/discovery/version.go
s.ServeHTTP(resp.ResponseWriter, req.Request) } func (s *APIVersionHandler) ServeHTTP(w http.ResponseWriter, req *http.Request) { responsewriters.WriteObjectNegotiated(s.serializer, negotiation.DefaultEndpointRestrictions, schema.GroupVersion{}, w, req, http.StatusOK, &metav1.APIResourceList{GroupVersion: s.groupVersion.String(), APIResources: s.apiResourceLister.ListAPIResources()}, false)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Nov 08 20:38:08 UTC 2022 - 2.9K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/endpoints/discovery/legacy.go
apiVersions := &metav1.APIVersions{ ServerAddressByClientCIDRs: s.addresses.ServerAddressByClientCIDRs(clientIP), Versions: []string{"v1"}, } responsewriters.WriteObjectNegotiated(s.serializer, negotiation.DefaultEndpointRestrictions, schema.GroupVersion{}, resp, req, http.StatusOK, apiVersions, false)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Nov 08 22:44:49 UTC 2022 - 2.7K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/endpoints/discovery/aggregated/etag.go
if clientCachedHash := req.Header.Get("If-None-Match"); quotedHash == clientCachedHash { w.WriteHeader(http.StatusNotModified) return } responsewriters.WriteObjectNegotiated( serializer, DiscoveryEndpointRestrictions, targetGV, w, req, http.StatusOK, object, true, ) } func calculateETag(resources interface{}) (string, error) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Mar 01 18:15:22 UTC 2024 - 2.5K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/endpoints/discovery/group.go
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Nov 08 20:38:08 UTC 2022 - 2.5K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/endpoints/discovery/root.go
groups := make([]metav1.APIGroup, len(orderedGroups)) for i := range orderedGroups { groups[i] = orderedGroups[i] groups[i].ServerAddressByClientCIDRs = serverCIDR } responsewriters.WriteObjectNegotiated(s.serializer, negotiation.DefaultEndpointRestrictions, schema.GroupVersion{}, resp, req, http.StatusOK, &metav1.APIGroupList{Groups: groups}, false) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Nov 08 22:44:49 UTC 2022 - 4.3K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/endpoints/discovery/aggregated/handler.go
etag, targetGV, rdm.serializer, resp, req, ) } else { // Default to normal response in rare case etag is // not cached with the object for some reason. responsewriters.WriteObjectNegotiated( rdm.serializer, DiscoveryEndpointRestrictions, targetGV, resp, req, http.StatusOK, &response, true, ) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Mar 02 00:29:39 UTC 2024 - 16.1K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/endpoints/handlers/response.go
if err != nil { scope.err(err, w, req) return } kind, serializer, _ := targetEncodingForTransform(scope, mediaType, req) responsewriters.WriteObjectNegotiated(serializer, scope, kind.GroupVersion(), w, req, statusCode, obj, false) } // errNotAcceptable indicates Accept negotiation has failed type errNotAcceptable struct { message string }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Oct 18 09:07:03 UTC 2023 - 16.5K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/endpoints/handlers/rest.go
type responder struct { scope *RequestScope req *http.Request w http.ResponseWriter } func (r *responder) Object(statusCode int, obj runtime.Object) { responsewriters.WriteObjectNegotiated(r.scope.Serializer, r.scope, r.scope.Kind.GroupVersion(), r.w, r.req, statusCode, obj, false) } func (r *responder) Error(err error) { r.scope.err(err, r.w, r.req) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Mar 08 21:44:00 UTC 2023 - 17K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/endpoints/apiserver_test.go
} clone := *obj return &clone } func TestWriteJSONDecodeError(t *testing.T) { server := httptest.NewServer(http.HandlerFunc(func(w http.ResponseWriter, req *http.Request) { responsewriters.WriteObjectNegotiated(codecs, negotiation.DefaultEndpointRestrictions, newGroupVersion, w, req, http.StatusOK, &UnregisteredAPIObject{"Undecodable"}, false) })) defer server.Close() // Decode error response behavior is dictated by
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon May 01 20:15:22 UTC 2023 - 158.7K bytes - Viewed (0)