broadcastwriter

Documentation

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 utils.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.