out <- grid.NewBytesWithCopyOf(buf.Bytes())
		case <-ctx.Done():
			return grid.NewRemoteErr(ctx.Err())
		}
	}
}

func (s *peerRESTServer) writeErrorResponse(w http.ResponseWriter, err error) {
	w.WriteHeader(http.StatusForbidden)
	w.Write([]byte(err.Error()))
}

// IsValid - To authenticate and verify the time difference.
func (s *peerRESTServer) IsValid(w http.ResponseWriter, r *http.Request) bool {

			headerMatcher.inspect(t, w, fsName, plName)

			if r.URL.Path == rquestTimesOutPath {

				// inner handler writes header and then let the request time out.
				w.WriteHeader(http.StatusBadRequest)
				<-callerRoundTripDoneCh

				// we expect the timeout handler to have timed out this request by now and any attempt
				// to write to the response should return a http.ErrHandlerTimeout error.

	return nil
}

func (w *testResponseWriter) Write(p []byte) (int, error) {
	w.response = append(w.response, p...)
	return len(p), nil
}

func (w *testResponseWriter) WriteHeader(statusCode int) {
	w.statusCode = statusCode
}

func (w *testResponseWriter) Flush() {
}

func TestJSONQueries(t *testing.T) {

			}
			token, err := jws.CompactSerialize()
			if err != nil {
				t.Errorf("while serializing response token: %v", err)
			}
			w.Write([]byte(token))
		default:
			w.WriteHeader(http.StatusNotFound)
			fmt.Fprintf(w, "unexpected URL: %v", r.URL)
		}
	}))
	klog.V(4).Infof("Serving OIDC at: %v", ts.URL)
	return ts
}

func toKeySet(keys []*jose.JSONWebKey) jose.JSONWebKeySet {

		if !ok {
			fakeResponse.statusCode = 200
			fakeResponse.content = []byte(`{"apiVersion": "v1", "kind": "List"}`)
		}
		response.Header().Set("Content-Type", "application/json")
		response.WriteHeader(fakeResponse.statusCode)
		response.Write(fakeResponse.content)
	}()

	// This is to allow the fakeActionHandler to simulate a watch being opened
	if strings.Contains(request.URL.RawQuery, "watch=true") {

		{"(*Reader).Next", Method, 0},
		{"(*Reader).Read", Method, 0},
		{"(*Writer).AddFS", Method, 22},
		{"(*Writer).Close", Method, 0},
		{"(*Writer).Flush", Method, 0},
		{"(*Writer).Write", Method, 0},
		{"(*Writer).WriteHeader", Method, 0},
		{"(Format).String", Method, 10},
		{"ErrFieldTooLong", Var, 0},
		{"ErrHeader", Var, 0},
		{"ErrInsecurePath", Var, 20},
		{"ErrWriteAfterClose", Var, 0},
		{"ErrWriteTooLong", Var, 0},

pkg net/http, type Response struct, TransferEncoding []string
pkg net/http, type ResponseWriter interface { Header, Write, WriteHeader }
pkg net/http, type ResponseWriter interface, Header() Header
pkg net/http, type ResponseWriter interface, Write([]uint8) (int, error)
pkg net/http, type ResponseWriter interface, WriteHeader(int)
pkg net/http, type RoundTripper interface { RoundTrip }