Method StopContext

server/querylog.go:75–75 · view source on GitHub ↗

(context.Context)

Source from the content-addressed store, hash-verified

73	return newPostgresQueryLogSink(ctx, cfg)
74	}
75
76	// Log sends an entry to the query log. Non-blocking; drops if channel is full.
77	func (ql *QueryLogger) Log(entry QueryLogEntry) {
78	if ql == nil \|\| ql.ch == nil {

TestKafkaQueryLogSinkStopContextBoundsTotalDrainFunction · 0.65

StopQueryLoggingMethod · 0.65

fakeControlPlaneQueryLogSinkcontrolplane/control_test.go

captureQueryLogSinkserver/querylog_kafka_test.go

QueryLoggerserver/querylog.go

KafkaQueryLogSinkserver/querylog_kafka.go

no outgoing calls

TestKafkaQueryLogSinkStopContextBoundsTotalDrainFunction · 0.52