MCPcopy
hub / github.com/zalando/skipper / Write

Method Write

proxy/proxy.go:576–582  ·  view source on GitHub ↗
(p []byte)

Source from the content-addressed store, hash-verified

574)
575
576func (f *flusher) Write(p []byte) (n int, err error) {
577 n, err = f.w.Write(p)
578 if err == nil {
579 f.w.Flush()
580 }
581 return
582}
583
584var bufPool = sync.Pool{
585 New: func() any {

Callers 15

TestRedisAddrUpdaterFunction · 0.45
TestFifoChangesFunction · 0.45
TestValidatesDocumentFunction · 0.45
TestRequestWithOauthTokenFunction · 0.45
TestRequestWithBasicAuthFunction · 0.45
TestRemoteLoadAllFailFunction · 0.45
ServeHTTPMethod · 0.45
TestGetKubeNodeInfoFunction · 0.45
backendNotifyingCanceledRequestsFunction · 0.45
testCancelDuringStreamingRequestBodyFunction · 0.45
TestTracingProxySpanWithTeeLoopbackFilterFunction · 0.45
TestTracingProxySpanWithLoopbackIfStatusFilterFunction · 0.45

Calls 1

FlushMethod · 0.65

Tested by 15

TestRedisAddrUpdaterFunction · 0.36
TestFifoChangesFunction · 0.36
TestValidatesDocumentFunction · 0.36
TestRequestWithOauthTokenFunction · 0.36
TestRequestWithBasicAuthFunction · 0.36
TestRemoteLoadAllFailFunction · 0.36
TestGetKubeNodeInfoFunction · 0.36
backendNotifyingCanceledRequestsFunction · 0.36
testCancelDuringStreamingRequestBodyFunction · 0.36
TestTracingProxySpanWithTeeLoopbackFilterFunction · 0.36
TestTracingProxySpanWithLoopbackIfStatusFilterFunction · 0.36
testBackendFunction · 0.36