Documentation ¶ Index ¶ func NewSourceFromRawSource(rs pdk.RawSource) pdk.Source type Source func NewSource(r io.Reader) *Source func (s *Source) Record() (rec interface{}, err error) Constants ¶ This section is empty. Variables ¶ This section is empty. Functions ¶ func NewSourceFromRawSource ¶ func NewSourceFromRawSource(rs pdk.RawSource) pdk.Source Types ¶ type Source ¶ type Source struct { // contains filtered or unexported fields } Source is a pdk.Source for reading json data. func NewSource ¶ func NewSource(r io.Reader) *Source NewSource gets a new json source which will decode from the given reader. func (*Source) Record ¶ func (s *Source) Record() (rec interface{}, err error) Record implements pdk.Source. It returns the next json object that can be decoded from the reader. It is guaranteed to return a map[string]interface{} if there is no error. Source Files ¶ View all Source files source.go Click to show internal directories. Click to hide internal directories.
Documentation
¶
Source Files