stream

Documentation

Overview

Package stream provides utility functions to consume Entry streams.

Index

• func ReadEntries(r io.Reader) <-chan *spb.Entry
• func ReadJSONEntries(r io.Reader) <-chan *spb.Entry
• type EntryReader
  • func NewJSONReader(r io.Reader) EntryReader
  • func NewReader(r io.Reader) EntryReader

Functions

func ReadEntries

func ReadEntries(r io.Reader) <-chan *spb.Entry

ReadEntries reads a stream of Entry protobufs from r.

func ReadJSONEntries

func ReadJSONEntries(r io.Reader) <-chan *spb.Entry

ReadJSONEntries reads a JSON stream of Entry protobufs from r.

Types

type EntryReader

type EntryReader func(func(*spb.Entry) error) error

EntryReader functions read a stream of entries, passing each to a handler function.

func NewJSONReader

func NewJSONReader(r io.Reader) EntryReader

NewJSONReader reads a JSON stream of Entry protobufs from r.

func NewReader

func NewReader(r io.Reader) EntryReader

NewReader reads a stream of Entry protobufs from r.