package broadcastwriter

import "github.com/docker/docker/pkg/broadcastwriter"

Index ¶

• type BroadcastWriter
• func New() *BroadcastWriter
• func (w *BroadcastWriter) AddWriter(writer io.WriteCloser, stream string)
• func (w *BroadcastWriter) Clean() error
• func (w *BroadcastWriter) Write(p []byte) (n int, err error)

Types ¶

type BroadcastWriter ¶

type BroadcastWriter struct {
	sync.Mutex
	// contains filtered or unexported fields
}

BroadcastWriter accumulate multiple io.WriteCloser by stream.

func New ¶

func New() *BroadcastWriter

func (*BroadcastWriter) AddWriter ¶

func (w *BroadcastWriter) AddWriter(writer io.WriteCloser, stream string)

AddWriter adds new io.WriteCloser for stream. If stream is "", then all writes proceed as is. Otherwise every line from input will be packed to serialized jsonlog.JSONLog.

func (*BroadcastWriter) Clean ¶

func (w *BroadcastWriter) Clean() error

Clean closes and removes all writers. Last non-eol-terminated part of data will be saved.

func (*BroadcastWriter) Write ¶

func (w *BroadcastWriter) Write(p []byte) (n int, err error)

Write writes bytes to all writers. Failed writers will be evicted during this call.

Source Files ¶

broadcastwriter.go