Documentation
¶
Index ¶
- func CopyLoggingErrors(ctx context.Context, dst io.Writer, src io.Reader) error
- func CreateUnixConnProxy(ctx context.Context, conn net.Conn) (*net.UnixConn, error)
- func CreateUnixFileProxy(ctx context.Context) (string, *net.UnixConn, error)
- func DebugCopy(ctx context.Context, name string, w io.Writer, r io.Reader) (done chan error)
- func DebugCopyWithBuffer(ctx context.Context, name string, w io.Writer, r io.Reader, buffer []byte) (done chan error)
- func ListenAndAcceptSingleNetConn(ctx context.Context, ...) (net.Conn, error)
- func NewCountReader(r io.Reader) io.ReadCloser
- func NewCountWriter(w io.WriteCloser) io.WriteCloser
- func NewDebugReader(ctx context.Context, name string, r io.Reader) io.Reader
- func NewDebugWriter(ctx context.Context, name string, w io.Writer) io.Writer
- type FileReader
- type FileWriter
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func CopyLoggingErrors ¶
func CreateUnixConnProxy ¶
func CreateUnixFileProxy ¶
func DebugCopyWithBuffer ¶
func NewCountReader ¶
func NewCountReader(r io.Reader) io.ReadCloser
func NewCountWriter ¶
func NewCountWriter(w io.WriteCloser) io.WriteCloser
Types ¶
type FileReader ¶
type FileReader interface {
Fd() uintptr
io.ReadCloser
}
func OsPipeProxyReader ¶
func OsPipeProxyReader(ctx context.Context, name string, r io.ReadCloser) (FileReader, []io.Closer)
type FileWriter ¶
type FileWriter interface {
Fd() uintptr
io.WriteCloser
}
func OsPipeProxyWriter ¶
func OsPipeProxyWriter(ctx context.Context, name string, w io.WriteCloser) (FileWriter, []io.Closer)
Source Files
Click to show internal directories.
Click to hide internal directories.