MCPcopy
hub / github.com/wal-g/wal-g / channelWriter

Struct channelWriter

internal/splitmerge/channelwriter.go:14–17  ·  view source on GitHub ↗

channelWriter provider io.WriteCloser interface on top of `ch` chan []byte i.e. it sends all data written by Write(data) to `ch` channel and waits for response: bytes written & errors

Source from the content-addressed store, hash-verified

12// channelWriter provider io.WriteCloser interface on top of `ch` chan []byte
13// i.e. it sends all data written by Write(data) to `ch` channel and waits for response: bytes written & errors
14type channelWriter struct {
15 ch chan<- []byte
16 resultCh <-chan writeResult
17}
18
19var _ io.WriteCloser = &channelWriter{}
20

Callers

nothing calls this directly

Calls

no outgoing calls

Tested by

no test coverage detected