Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
View Source
var ForsedShutdown = errors.New("Forsed Shutdown")
Functions ¶
func BorderMessage ¶
func NewDuplexPipe ¶
func NewDuplexPipe() (*DuplexPipe, *DuplexPipe)
func ProxyReadWriter ¶
func ProxyReadWriter(proxied io.ReadWriter) io.ReadWriteCloser
Types ¶
type CopyMonitor ¶
type CopyMonitor struct {
Close context.CancelFunc
Done func() <-chan struct{}
// contains filtered or unexported fields
}
func NewCopyMonitor ¶
func NewCopyMonitor(ctx context.Context, opts ...Option) (cm *CopyMonitor, err error)
func (*CopyMonitor) Status ¶
func (cm *CopyMonitor) Status() (done, isCorrect bool, err error)
type DuplexPipe ¶
type DuplexPipe struct {
io.ReadWriteCloser
// contains filtered or unexported fields
}
func (*DuplexPipe) Close ¶
func (dp *DuplexPipe) Close() error
Source Files
Click to show internal directories.
Click to hide internal directories.