Versions in this module Expand all Collapse all v1 v1.0.2 Mar 17, 2021 Changes in this version + type PReader struct + func NewPReader(readCloser io.ReadCloser, args *ReaderArgs) *PReader + func (r *PReader) Close() error + func (r *PReader) Read(dst sql.Record) (sql.Record, error) + type RawJSON []byte + func (b RawJSON) MarshalJSON() ([]byte, error) + type Reader struct + func NewReader(readCloser io.ReadCloser, args *ReaderArgs) *Reader + func (r *Reader) Close() error + func (r *Reader) Read(dst sql.Record) (sql.Record, error) + type ReaderArgs struct + ContentType string + func (args *ReaderArgs) IsEmpty() bool + func (args *ReaderArgs) UnmarshalXML(d *xml.Decoder, start xml.StartElement) error + type Record struct + KVS jstream.KVS + SelectFormat sql.SelectObjectFormat + func NewRecord(f sql.SelectObjectFormat) *Record + func (r *Record) Clone(dst sql.Record) sql.Record + func (r *Record) Get(name string) (*sql.Value, error) + func (r *Record) Raw() (sql.SelectObjectFormat, interface{}) + func (r *Record) Replace(k interface{}) error + func (r *Record) Reset() + func (r *Record) Set(name string, value *sql.Value) (sql.Record, error) + func (r *Record) WriteCSV(writer io.Writer, opts sql.WriteCSVOpts) error + func (r *Record) WriteJSON(writer io.Writer) error + type WriterArgs struct + RecordDelimiter string + func (args *WriterArgs) IsEmpty() bool + func (args *WriterArgs) UnmarshalXML(d *xml.Decoder, start xml.StartElement) error