- Sort Score
- Result 10 results
- Languages All
Results 1 - 5 of 5 for writeStatus (0.64 sec)
-
staging/src/k8s.io/apiserver/pkg/util/proxy/streamtranslator.go
if err != nil { websocketStreams.writeStatus(apierrors.NewInternalError(err)) //nolint:errcheck metrics.IncStreamTranslatorRequest(req.Context(), strconv.Itoa(http.StatusInternalServerError)) return } spdyExecutor, err := remotecommand.NewSPDYExecutorRejectRedirects(spdyRoundTripper, spdyRoundTripper, "POST", h.Location) if err != nil { websocketStreams.writeStatus(apierrors.NewInternalError(err)) //nolint:errcheck
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Feb 27 23:21:55 UTC 2024 - 6.7K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/util/proxy/websocket.go
stderrStream: streams[constants.StreamStdErr], tty: opts.Tty, resizeStream: streams[constants.StreamResize], } // writeStatus returns a WriteStatusFunc that marshals a given api Status // as json in the error channel. ctx.writeStatus = func(status *apierrors.StatusError) error { bs, err := json.Marshal(status.Status()) if err != nil { return err }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Mar 26 16:28:45 UTC 2024 - 6.2K bytes - Viewed (0) -
pilot/pkg/bootstrap/configcontroller.go
if err != nil { return } cont.Run(leaderStop) }).Run(stop) return nil }) return nil } func (s *Server) initStatusController(args *PilotArgs, writeStatus bool) { if s.statusManager == nil && writeStatus { s.initStatusManager(args) } if features.EnableDistributionTracking { s.statusReporter = &distribution.Reporter{ UpdateInterval: features.StatusUpdateInterval,
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Feb 28 16:41:38 UTC 2024 - 14.1K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/util/proxy/streamtranslator_test.go
_, err = io.Copy(io.Discard, ctx.stdinStream) if err != nil { t.Fatalf("error copying STDIN to DISCARD: %v", err) } // Force an non-zero exit code error returned on the error stream. err = ctx.writeStatus(&apierrors.StatusError{ErrStatus: metav1.Status{ Status: metav1.StatusFailure, Reason: rcconstants.NonZeroExitCodeReason, Details: &metav1.StatusDetails{ Causes: []metav1.StatusCause{ {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Feb 27 23:21:55 UTC 2024 - 36.4K bytes - Viewed (0) -
tensorflow/compiler/mlir/quantization/stablehlo/cc/io_test.cc
} TEST(IoTest, WriteStringToFile) { const std::string dst_file_path = absl::StrCat(testing::TempDir(), "/tmp_file"); const absl::Status write_status = WriteStringToFile(dst_file_path, "test_string"); ASSERT_THAT(write_status, IsOk()); auto* const env = tsl::Env::Default(); ASSERT_THAT(env->FileExists(dst_file_path), IsOk()); std::string data{};
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Wed Apr 24 03:28:15 UTC 2024 - 6.7K bytes - Viewed (0)