Versions in this module Expand all Collapse all v1 v1.0.0 Aug 17, 2016 Changes in this version + const CompressionDeflate + const CompressionNull + const CompressionSnappy + const DefaultWriterBlockSize + var MaxDecodeSize = int64(math.MaxInt32) + func IsCompressionCodecSupported(someCodec string) bool + type ByteWriter interface + Grow func(int) + WriteByte func(byte) error + type Codec interface + NewWriter func(...WriterSetter) (*Writer, error) + Schema func() string + func NewCodec(someJSONSchema string, setters ...CodecSetter) (Codec, error) + type CodecSetter func(Codec) error + type Datum struct + Err error + Value interface{} + type Decoder interface + Decode func(io.Reader) (interface{}, error) + type Encoder interface + Encode func(io.Writer, interface{}) error + type Enum struct + Name string + Value string + type ErrCodecBuild struct + Err error + Message string + func (e ErrCodecBuild) Error() string + type ErrDecoder struct + Err error + Message string + func (e ErrDecoder) Error() string + type ErrEncoder struct + Err error + Message string + func (e ErrEncoder) Error() string + type ErrInvalidName struct + Message string + func (e ErrInvalidName) Error() string + type ErrNoSuchField struct + func (e ErrNoSuchField) Error() string + type ErrNotRecord struct + func (e ErrNotRecord) Error() string + type ErrReader struct + Err error + Message string + func (e ErrReader) Error() string + type ErrReaderBlockCount struct + Err error + func (e *ErrReaderBlockCount) Error() string + type ErrReaderInit struct + Err error + Message string + func (e ErrReaderInit) Error() string + type ErrSchemaParse struct + Err error + Message string + func (e ErrSchemaParse) Error() string + type ErrWriterInit struct + Err error + Message string + func (e *ErrWriterInit) Error() string + type Fixed struct + Name string + Value []byte + type Reader struct + CompressionCodec string + DataSchema string + Sync []byte + func NewReader(setters ...ReaderSetter) (*Reader, error) + func (fr *Reader) Close() error + func (fr *Reader) Read() (interface{}, error) + func (fr *Reader) Scan() bool + type ReaderSetter func(*Reader) error + func BufferFromReader(r io.Reader) ReaderSetter + func FromReader(r io.Reader) ReaderSetter + type Record struct + Fields []*recordField + Name string + func NewRecord(setters ...RecordSetter) (*Record, error) + func (r Record) Get(fieldName string) (interface{}, error) + func (r Record) GetFieldSchema(fieldName string) (interface{}, error) + func (r Record) GetQualified(qualifiedName string) (interface{}, error) + func (r Record) Set(fieldName string, value interface{}) error + func (r Record) SetQualified(qualifiedName string, value interface{}) error + func (r Record) String() string + type RecordCache struct + func NewRecordCache(record *Record, delim byte) (*RecordCache, error) + func (rc *RecordCache) Get(name string) (interface{}, error) + type RecordSetter func(*Record) error + func RecordEnclosingNamespace(someNamespace string) RecordSetter + func RecordPedantic() RecordSetter + func RecordSchema(recordSchemaJSON string) RecordSetter + type StringWriter interface + WriteString func(string) (int, error) + type Writer struct + CompressionCodec string + Sync []byte + func NewWriter(setters ...WriterSetter) (*Writer, error) + func (fw *Writer) Close() error + func (fw *Writer) Write(datum interface{}) + type WriterSetter func(*Writer) error + func BlockSize(blockSize int64) WriterSetter + func BlockTick(blockTick time.Duration) WriterSetter + func BufferToWriter(w io.Writer) WriterSetter + func Compression(someCompressionCodec string) WriterSetter + func Sync(someSync []byte) WriterSetter + func ToWriter(w io.Writer) WriterSetter + func UseCodec(codec Codec) WriterSetter + func WriterSchema(someSchema string) WriterSetter
Go to main page