package recordio

import "github.com/mesos/mesos-go/api/v1/lib/recordio"

Package recordio implements the Mesos variant of RecordIO framing, whereby each record is prefixed by a line that indicates the length of the record in decimal ASCII. The bytes of the record immediately follow the length-line. Zero-length records are allowed.

{
	r := NewReader(strings.NewReader("6\nhello 0\n6\nworld!"))
	records, err := ioutil.ReadAll(r)
	fmt.Println(string(records), err)
	// Output:
	// hello world! <nil>
}

hello world! <nil>

Index ¶

• func NewFrameReader(r io.Reader) framing.Reader
• func NewReader(r io.Reader) io.Reader

Examples ¶

• package

Functions ¶

func NewFrameReader ¶

func NewFrameReader(r io.Reader) framing.Reader

func NewReader ¶

func NewReader(r io.Reader) io.Reader

NewReader returns an io.Reader that unpacks the data read from r out of RecordIO framing before returning it.

Source Files ¶

doc.go reader.go