MCPcopy
hub / github.com/cloudflare/cloudflared / Close

Method Close

ingress/origin_connection.go:22–22  ·  view source on GitHub ↗
()

Source from the content-addressed store, hash-verified

20 // Stream should generally be implemented as a bidirectional io.Copy.
21 Stream(ctx context.Context, tunnelConn io.ReadWriter, log *zerolog.Logger)
22 Close() error
23}
24
25type streamHandlerFunc func(originConn io.ReadWriter, remoteConn net.Conn, log *zerolog.Logger)

Callers 15

CloseMethod · 0.65
TestStaticHTTPStatusFunction · 0.65
ServeMethod · 0.65
TestStreamTCPConnectionFunction · 0.65
TestDefaultStreamWSOverTCPConnectionFunction · 0.65
TestSocksStreamWSOverTCPConnectionFunction · 0.65
TestWsConnReturnsBeforeStreamReturnsFunction · 0.65
echoWSEyeballFunction · 0.65
TestRawTCPServiceEstablishConnectionFunction · 0.65
TestTCPOverWSServiceEstablishConnectionFunction · 0.65
TestHTTPServiceHostHeaderOverrideFunction · 0.65
TestHTTPServiceUsesIngressRuleSchemeFunction · 0.65

Implementers 2

tcpOverWSConnectioningress/origin_connection.go
socksProxyOverWSConnectioningress/origin_connection.go

Calls

no outgoing calls

Tested by 11

TestStaticHTTPStatusFunction · 0.52
TestStreamTCPConnectionFunction · 0.52
TestDefaultStreamWSOverTCPConnectionFunction · 0.52
TestSocksStreamWSOverTCPConnectionFunction · 0.52
TestWsConnReturnsBeforeStreamReturnsFunction · 0.52
echoWSEyeballFunction · 0.52
TestRawTCPServiceEstablishConnectionFunction · 0.52
TestTCPOverWSServiceEstablishConnectionFunction · 0.52
TestHTTPServiceHostHeaderOverrideFunction · 0.52
TestHTTPServiceUsesIngressRuleSchemeFunction · 0.52
tcpListenRoutineFunction · 0.52