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

Method RegisterSink

connection/observer.go:45–47  ·  view source on GitHub ↗
(sink EventSink)

Source from the content-addressed store, hash-verified

43}
44
45func (o *Observer) RegisterSink(sink EventSink) {
46 o.addSinkChan <- sink
47}
48
49func (o *Observer) logConnecting(connIndex uint8, address net.IP, protocol Protocol) {
50 o.log.Debug().

Callers 4

TestObserverEventsDontBlockFunction · 0.95
TestGracefulShutdownHTTP2Function · 0.95
StartServerFunction · 0.95
NewConnAwareLoggerFunction · 0.80

Calls

no outgoing calls

Tested by 2

TestObserverEventsDontBlockFunction · 0.76
TestGracefulShutdownHTTP2Function · 0.76