MCPcopy Create free account
hub / github.com/cloudnative-pg/cloudnative-pg / safeWriterFrom

Function safeWriterFrom

pkg/podlogs/cluster_writer.go:113–117  ·  view source on GitHub ↗
(w io.Writer)

Source from the content-addressed store, hash-verified

111}
112
113func safeWriterFrom(w io.Writer) *safeWriter {
114 return &safeWriter{
115 Writer: w,
116 }
117}
118
119// activeSet is a goroutine-safe store of active processes. It is similar
120// in idea to a WaitGroup, but does not block when we check for zero, and it

Callers 1

SingleStreamMethod · 0.85

Calls

no outgoing calls

Tested by

no test coverage detected