MCPcopy
hub / github.com/containerd/containerd / Recv

Method Recv

core/streaming/streaming.go:43–43  ·  view source on GitHub ↗

Recv receives an object on the stream

()

Source from the content-addressed store, hash-verified

41
42 // Recv receives an object on the stream
43 Recv() (typeurl.Any, error)
44
45 // Close closes the stream
46 Close() error

Callers 15

SubscribeMethod · 0.65
streamMethod · 0.65
listenToEventChannelFunction · 0.65
TestNewRuntimeClientConnGetContainerEventsUnixFunction · 0.65
ListMethod · 0.65
WalkMethod · 0.65
CreateMethod · 0.65
RecvMethod · 0.65
MarshalAnyMethod · 0.65
GetCredentialsMethod · 0.65
TransferMethod · 0.65
SendStreamFunction · 0.65

Implementers 3

clientStreamcore/streaming/proxy/streaming.go
testStreamcore/transfer/streaming/stream_test.go
serviceStreamplugins/services/streaming/service.go

Calls

no outgoing calls

Tested by 2

listenToEventChannelFunction · 0.52
TestNewRuntimeClientConnGetContainerEventsUnixFunction · 0.52