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

Struct fileSink

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

this is only for testing purposes. Ideally client wouldn't want file based sink

Source from the content-addressed store, hash-verified

174
175// this is only for testing purposes. Ideally client wouldn't want file based sink
176type fileSink struct {
177 // log writer is buffered. Do take care of that while testing
178 fileWriter *x.LogWriter
179}
180
181func (f *fileSink) Send(messages []SinkMessage) error {
182 for _, m := range messages {

Callers

nothing calls this directly

Calls

no outgoing calls

Tested by

no test coverage detected