json

Documentation

Index

• func Decode(reader io.Reader, stream chan<- *proto.Payload) error
• func Encode(writer io.Writer, stream <-chan *proto.Payload) error

Functions

func Decode

func Decode(reader io.Reader, stream chan<- *proto.Payload) error

Decode JSON input from io.Reader sending entities one by one to the stream channel.

func Encode

func Encode(writer io.Writer, stream <-chan *proto.Payload) error

Encode entities from the stream channel writing to the provided io.Writer.