MCPcopy
hub / github.com/dgraph-io/dgraph / Close

Method Close

worker/sink_handler.go:41–41  ·  view source on GitHub ↗

close sink

()

Source from the content-addressed store, hash-verified

39 Send(messages []SinkMessage) error
40 // close sink
41 Close() error
42}
43
44const (

Callers 15

jepsenServeFunction · 0.65
loadPolygonFunction · 0.65
FuzzTestParserFunction · 0.65
shutdownMethod · 0.65
MonitorHealthMethod · 0.65
CloseMethod · 0.65
TestParseSchemaFromAlterOperationFunction · 0.65
initCmdsFunction · 0.65
parseTablesFunction · 0.65
showTablesFunction · 0.65
getFileWriterFunction · 0.65
runFunction · 0.65

Implementers 2

kafkaSinkClientworker/sink_handler.go
fileSinkworker/sink_handler.go

Calls

no outgoing calls

Tested by 15

loadPolygonFunction · 0.52
FuzzTestParserFunction · 0.52
TestParseSchemaFromAlterOperationFunction · 0.52
TestZeroHealthFunction · 0.52
TestDgraphVersionFunction · 0.52
TestMCPSSEFunction · 0.52
TestGrpcCompressionSupportFunction · 0.52
queryWithGzFunction · 0.52
runRequestFunction · 0.52
TestHealthFunction · 0.52
TestCmdlineEndpointsNotExposedFunction · 0.52
TestMutationsDisallowFunction · 0.52