stream

Documentation

Index

• Variables
• type IStream
• type Stream
  • func NewStream() *Stream
  • func (s *Stream) AddHttpBackend(w io.Writer) *Stream
  • func (s *Stream) AddSocketBackend(endpoint string) *Stream
  • func (s *Stream) Close()
  • func (s *Stream) Done()
  • func (s *Stream) Flush()
  • func (s *Stream) Pipe()
  • func (s *Stream) Write(p []byte) (n int, err error)

Variables

var ErrWrotePastMaxLogLength = errors.New("wrote past max length")

Types

type IStream

type IStream interface {
	Write(p []byte) (n int, err error)
	Pipe()
	Flush()
	Close()
	Done()
	AddSocketBackend(endpoint string) *Stream
	AddHttpBackend(w io.Writer) *Stream
	AddStdoutBackend(w io.Writer) *Stream
	AddFileBackend(dir, file string) *Stream
}

type Stream

type Stream struct {
	io.Writer
	// contains filtered or unexported fields
}

func NewStream

func NewStream() *Stream

func (*Stream) AddHttpBackend

func (s *Stream) AddHttpBackend(w io.Writer) *Stream

func (*Stream) AddSocketBackend

func (s *Stream) AddSocketBackend(endpoint string) *Stream

func (*Stream) Close

func (s *Stream) Close()

func (*Stream) Done

func (s *Stream) Done()

func (*Stream) Flush

func (s *Stream) Flush()

func (*Stream) Pipe

func (s *Stream) Pipe()

func (*Stream) Write

func (s *Stream) Write(p []byte) (n int, err error)