stream

Documentation

Index

• Variables
• type Stream
  • func NewStream() *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 Stream

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

func NewStream

func NewStream() *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)