Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 10 for WriteObjectNegotiated (0.31 sec)

  1. staging/src/k8s.io/apiserver/pkg/endpoints/handlers/responsewriters/writers.go

    	}
    	var err error
    	switch t := w.w.(type) {
    	case *gzip.Writer:
    		err = t.Close()
    		t.Reset(nil)
    		gzipPool.Put(t)
    	}
    	return err
    }
    
    // WriteObjectNegotiated renders an object in the content type negotiated by the client.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jun 07 18:21:43 UTC 2023
    - 10.6K bytes
    - Viewed (0)
  2. 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)
  3. 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)
  4. 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)
  5. staging/src/k8s.io/apiserver/pkg/endpoints/discovery/group.go

    	s.ServeHTTP(resp.ResponseWriter, req.Request)
    }
    
    func (s *APIGroupHandler) ServeHTTP(w http.ResponseWriter, req *http.Request) {
    	responsewriters.WriteObjectNegotiated(s.serializer, negotiation.DefaultEndpointRestrictions, schema.GroupVersion{}, w, req, http.StatusOK, &s.group, false)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Nov 08 20:38:08 UTC 2022
    - 2.5K bytes
    - Viewed (0)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to top