Code
Hub
Workspaces
Following
Trending
Connect
MCP
copy
Create free account
hub
/
github.com/cortexproject/cortex
/ Read
Method
Read
pkg/util/grpcencoding/snappy/snappy.go:87–94 ·
view source on GitHub ↗
(p []byte)
Source
from the content-addressed store, hash-verified
85
}
86
87
func
(r reader) Read(p []byte) (n int, err error) {
88
n, err = r.reader.Read(p)
89
if
err == io.EOF {
90
r.reader.Reset(nil)
91
r.pool.Put(r.reader)
92
}
93
return
n, err
94
}
Callers
8
TestNoopBufferWhenNotReleasableMessage
Function · 0.45
TestTCPTransport_PacketReadTimeout
Function · 0.45
TestTCPTransport_MaxConcurrentConnections
Function · 0.45
generateRandomSuffix
Function · 0.45
Benchmark_Compression
Function · 0.45
newHeapScanner
Function · 0.45
scan
Method · 0.45
logUnfinishedRequests
Function · 0.45
Calls
2
Put
Method · 0.65
Reset
Method · 0.45
Tested by
4
TestNoopBufferWhenNotReleasableMessage
Function · 0.36
TestTCPTransport_PacketReadTimeout
Function · 0.36
TestTCPTransport_MaxConcurrentConnections
Function · 0.36
Benchmark_Compression
Function · 0.36