io

Documentation

Index

• Variables
• func NewStreamWriter(w io.Writer, formatter Formatter) *streamWriter
• type FlushingWriter
  • func (w *FlushingWriter) Hijack() (net.Conn, *bufio.ReadWriter, error)
  • func (w *FlushingWriter) Write(data []byte) (written int, err error)
  • func (w *FlushingWriter) WriteHeader(code int)
  • func (w *FlushingWriter) Wrote() bool
• type Formatter
• type NoErrorWriter
  • func (w *NoErrorWriter) Write(data []byte) (int, error)
• type SimpleJsonMessage
• type SimpleJsonMessageEncoderWriter
  • func (w *SimpleJsonMessageEncoderWriter) Write(msg []byte) (int, error)
• type SimpleJsonMessageFormatter
  • func (SimpleJsonMessageFormatter) Format(out io.Writer, data []byte) error

Variables

var ErrInvalidStreamChunk = errors.New("invalid stream chunk")

Functions

func NewStreamWriter

func NewStreamWriter(w io.Writer, formatter Formatter) *streamWriter

Types

type FlushingWriter

type FlushingWriter struct {
	http.ResponseWriter
	// contains filtered or unexported fields
}

FlushingWriter is a custom writer that flushes after writing, if the underlying ResponseWriter is also an http.Flusher.

func (*FlushingWriter) Hijack

func (w *FlushingWriter) Hijack() (net.Conn, *bufio.ReadWriter, error)

Hijack will hijack the underlying TCP connection, if available in the ResponseWriter.

func (*FlushingWriter) Write

func (w *FlushingWriter) Write(data []byte) (written int, err error)

Write writes and flushes the data.

func (*FlushingWriter) WriteHeader

func (w *FlushingWriter) WriteHeader(code int)

func (*FlushingWriter) Wrote

func (w *FlushingWriter) Wrote() bool

Wrote returns whether the method WriteHeader has been called or not.

type Formatter

type Formatter interface {
	Format(out io.Writer, data []byte) error
}

type NoErrorWriter

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

func (*NoErrorWriter) Write

func (w *NoErrorWriter) Write(data []byte) (int, error)

type SimpleJsonMessage

type SimpleJsonMessage struct {
	Message string
	Error   string `json:",omitempty"`
}

type SimpleJsonMessageEncoderWriter

type SimpleJsonMessageEncoderWriter struct {
	*json.Encoder
}

func (*SimpleJsonMessageEncoderWriter) Write

func (w *SimpleJsonMessageEncoderWriter) Write(msg []byte) (int, error)

type SimpleJsonMessageFormatter

type SimpleJsonMessageFormatter struct{}

func (SimpleJsonMessageFormatter) Format

func (SimpleJsonMessageFormatter) Format(out io.Writer, data []byte) error