broadcastwriter

package
v0.0.0-...-0904200 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Apr 18, 2017 License: Apache-2.0 Imports: 7 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

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.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL