parser

Documentation

Index

• type JSONEventParser
  • func (p *JSONEventParser) Parse(input io.Reader) ([]events.CloudEvent, error)

Types

type JSONEventParser

type JSONEventParser struct {
}

JSONEventParser implements events.StreamParser assuming JSON input.

func (*JSONEventParser) Parse

func (p *JSONEventParser) Parse(input io.Reader) ([]events.CloudEvent, error)

Parse takes io.Reader, and returns slice of CloudEvent. input can be a JSON list, single object, or list of JSON objects separated by new line characters