Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func ChunkStream ¶
func ChunkStream(in <-chan interface{}, out chan<- interface{}, errs chan<- error)
ChunkStream reads out multiple json blocks from a stream of json blocks turning each block into it's own downstream message.
func From ¶
func From(msg interface{}) (interface{}, error)
From converts the json message to a map string interface
Types ¶
type StreamChunk ¶
StreamChunk is a struct that has the block found in the stream as well as the position in the stream
func (StreamChunk) String ¶
func (s StreamChunk) String() string
String makes this struct a fmt.Stringer
Click to show internal directories.
Click to hide internal directories.