Documentation ¶
Overview ¶
broadcast package some code from dotcloud/docker
Index ¶
- Variables
- func Debugf(format string, a ...interface{})
- func Dump(a interface{})
- func GoTimeout(f func() error, timeout time.Duration) (err error)
- func NewBufReader(r io.Reader) *bufReader
- func NopWriteCloser(w io.Writer) io.WriteCloser
- func TempFile(dir, prefix, suffix string) (name string, err error)
- type NameLock
- type NopWriter
- type SafeMap
- type StreamWriter
- type WriteBroadcaster
- func (w *WriteBroadcaster) AddWriter(writer io.WriteCloser, stream string)
- func (wb *WriteBroadcaster) Bytes() []byte
- func (w *WriteBroadcaster) CloseWriters() error
- func (wb *WriteBroadcaster) Closed() bool
- func (wb *WriteBroadcaster) NewReader(name string) ([]byte, *io.PipeReader)
- func (w *WriteBroadcaster) Write(p []byte) (n int, err error)
Constants ¶
This section is empty.
Variables ¶
View Source
var ErrTimeout = errors.New("timeout")
Functions ¶
func NewBufReader ¶
func NopWriteCloser ¶
func NopWriteCloser(w io.Writer) io.WriteCloser
Types ¶
type NameLock ¶
type NameLock struct {
// contains filtered or unexported fields
}
func NewNameLock ¶
type SafeMap ¶
func NewSafeMap ¶
func NewSafeMap() *SafeMap
type StreamWriter ¶
type StreamWriter struct {
// contains filtered or unexported fields
}
type WriteBroadcaster ¶
func NewWriteBroadcaster ¶
func NewWriteBroadcaster() *WriteBroadcaster
func (*WriteBroadcaster) AddWriter ¶
func (w *WriteBroadcaster) AddWriter(writer io.WriteCloser, stream string)
func (*WriteBroadcaster) Bytes ¶
func (wb *WriteBroadcaster) Bytes() []byte
func (*WriteBroadcaster) CloseWriters ¶
func (w *WriteBroadcaster) CloseWriters() error
func (*WriteBroadcaster) Closed ¶
func (wb *WriteBroadcaster) Closed() bool
func (*WriteBroadcaster) NewReader ¶
func (wb *WriteBroadcaster) NewReader(name string) ([]byte, *io.PipeReader)
Click to show internal directories.
Click to hide internal directories.