io

Documentation

Index

• func NewStream(fn string) (io.WriteCloser, error)
• type JSONStream
  • func NewJSONStream(fn string) (*JSONStream, error)
  • func (s *JSONStream) Close() error
  • func (s *JSONStream) Name() string
  • func (s *JSONStream) Write(obj interface{}) error

Functions

func NewStream

func NewStream(fn string) (io.WriteCloser, error)

NewStream returns a new output stream. If the filename extension ends with .gz, it will return a gzip output stream

Types

type JSONStream

type JSONStream struct {
	// contains filtered or unexported fields
}

JSONStream is a convenience class for streaming json objects to a file (one JSON per line)

func NewJSONStream

func NewJSONStream(fn string) (*JSONStream, error)

NewJSONStream will return a JSON stream encoder

func (*JSONStream) Close

func (s *JSONStream) Close() error

Close will close the stream

func (*JSONStream) Name

func (s *JSONStream) Name() string

Name returns the underlying filename for the stream

func (*JSONStream) Write

func (s *JSONStream) Write(obj interface{}) error

Write will stream a JSON line to the output stream