file

Documentation

Index

• Constants
• func DupFile(f *os.File) (*os.File, error)
• func GetRegistry(name string) *codec.Registry
• func RegisterFileFormat(name, signature string, headers ...data.IDataRecord)
• type BaseDataRecord
  • func (*BaseDataRecord) GetEncodingCode() string
  • func (*BaseDataRecord) GetError() error
  • func (*BaseDataRecord) GetIndex() int
  • func (*BaseDataRecord) GetLabel() string
  • func (*BaseDataRecord) GetName() string
  • func (*BaseDataRecord) GetParent() data.FileRef
  • func (*BaseDataRecord) GetPosition() int64
  • func (*BaseDataRecord) HasName() bool
  • func (*BaseDataRecord) IsNull() bool
  • func (*BaseDataRecord) SetIndex(int)
  • func (*BaseDataRecord) SetName(string)
  • func (*BaseDataRecord) String() string
• type DataModifier
  • func MakeDataModifier(file *os.File, format_name string) (*DataModifier, error)
  • func OpenDataModifier(filename, format_name string) (*DataModifier, error)
  • func (self *DataModifier) Close() (err error)
  • func (self *DataModifier) DelRecordAt(index int) error
  • func (self *DataModifier) GetCount() int
  • func (self *DataModifier) GetCounts() map[data.IDataRecord]int
  • func (self *DataModifier) GetFormatName() string
  • func (self *DataModifier) GetIndexCount() int
  • func (self *DataModifier) GetRecordAt(index int) (data.IDataRecord, error)
  • func (self *DataModifier) InitStream(stream data.IDataStream) error
  • func (self *DataModifier) InitStreamFrom(stream data.IDataStream, index int64) error
  • func (self *DataModifier) IsClosed() bool
  • func (self *DataModifier) Offsets() []int64
  • func (self *DataModifier) ReadRecord(position int64) (data.IDataRecord, error)
  • func (self *DataModifier) SetRecordAt(index int, rec data.IDataRecord) (err error)
  • func (self *DataModifier) Write(rec data.IDataRecord) (err error)
• type DataReader
  • func MakeDataReader(file *os.File, format_name string) (*DataReader, error)
  • func OpenDataReader(filename, format_name string) (*DataReader, error)
  • func (self *DataReader) Close() error
  • func (self *DataReader) GetCount() int
  • func (self *DataReader) GetCounts() map[data.IDataRecord]int
  • func (self *DataReader) GetFormatName() string
  • func (self *DataReader) GetIndexCount() int
  • func (self *DataReader) GetRecordAt(index int) (data.IDataRecord, error)
  • func (self *DataReader) InitStream(stream data.IDataStream) error
  • func (self *DataReader) InitStreamFrom(stream data.IDataStream, index int64) error
  • func (self *DataReader) IsClosed() bool
  • func (self *DataReader) MakeStream() (RecordStream, error)
  • func (self *DataReader) MakeStreamFrom(from int64) (RecordStream, error)
  • func (self *DataReader) Offsets() []int64
  • func (self *DataReader) ReadRecord(position int64) (data.IDataRecord, error)
• type DataWriter
  • func MakeDataWriter(file *os.File, format_name string) (*DataWriter, error)
  • func OpenDataWriter(filename, format_name string) (*DataWriter, error)
  • func (self *DataWriter) Close() (err error)
  • func (self *DataWriter) GetCount() int
  • func (self *DataWriter) GetCounts() map[data.IDataRecord]int
  • func (self *DataWriter) GetFormatName() string
  • func (self *DataWriter) GetIndexCount() int
  • func (self *DataWriter) IsClosed() bool
  • func (self *DataWriter) Offsets() []int64
  • func (self *DataWriter) Write(rec data.IDataRecord) (err error)
• type IStreamItem
• type RecordStream
  • func (self RecordStream) Close() error

Constants

const (
	ANY_FILEFORMAT   = "<All>"
	SIGNATURE_LENGTH = 16
)

Functions

func DupFile

func DupFile(f *os.File) (*os.File, error)

func GetRegistry

func GetRegistry(name string) *codec.Registry

func RegisterFileFormat

func RegisterFileFormat(name, signature string, headers ...data.IDataRecord)

Types

type BaseDataRecord

type BaseDataRecord struct{}

func (*BaseDataRecord) GetEncodingCode

func (*BaseDataRecord) GetEncodingCode() string

func (*BaseDataRecord) GetError

func (*BaseDataRecord) GetError() error

func (*BaseDataRecord) GetIndex

func (*BaseDataRecord) GetIndex() int

func (*BaseDataRecord) GetLabel

func (*BaseDataRecord) GetLabel() string

func (*BaseDataRecord) GetName

func (*BaseDataRecord) GetName() string

func (*BaseDataRecord) GetParent

func (*BaseDataRecord) GetParent() data.FileRef

func (*BaseDataRecord) GetPosition

func (*BaseDataRecord) GetPosition() int64

func (*BaseDataRecord) HasName

func (*BaseDataRecord) HasName() bool

func (*BaseDataRecord) IsNull

func (*BaseDataRecord) IsNull() bool

func (*BaseDataRecord) SetIndex

func (*BaseDataRecord) SetIndex(int)

func (*BaseDataRecord) SetName

func (*BaseDataRecord) SetName(string)

func (*BaseDataRecord) String

func (*BaseDataRecord) String() string

type DataModifier

type DataModifier struct {
	// contains filtered or unexported fields
}

func MakeDataModifier

func MakeDataModifier(file *os.File, format_name string) (*DataModifier, error)

func OpenDataModifier

func OpenDataModifier(filename, format_name string) (*DataModifier, error)

func (*DataModifier) Close

func (self *DataModifier) Close() (err error)

func (*DataModifier) DelRecordAt

func (self *DataModifier) DelRecordAt(index int) error

func (*DataModifier) GetCount

func (self *DataModifier) GetCount() int

func (*DataModifier) GetCounts

func (self *DataModifier) GetCounts() map[data.IDataRecord]int

func (*DataModifier) GetFormatName

func (self *DataModifier) GetFormatName() string

func (*DataModifier) GetIndexCount

func (self *DataModifier) GetIndexCount() int

func (*DataModifier) GetRecordAt

func (self *DataModifier) GetRecordAt(index int) (data.IDataRecord, error)

func (*DataModifier) InitStream

func (self *DataModifier) InitStream(stream data.IDataStream) error

func (*DataModifier) InitStreamFrom

func (self *DataModifier) InitStreamFrom(stream data.IDataStream, index int64) error

func (*DataModifier) IsClosed

func (self *DataModifier) IsClosed() bool

func (*DataModifier) Offsets

func (self *DataModifier) Offsets() []int64

func (*DataModifier) ReadRecord

func (self *DataModifier) ReadRecord(position int64) (data.IDataRecord, error)

func (*DataModifier) SetRecordAt

func (self *DataModifier) SetRecordAt(index int, rec data.IDataRecord) (err error)

func (*DataModifier) Write

func (self *DataModifier) Write(rec data.IDataRecord) (err error)

type DataReader

type DataReader struct {
	// contains filtered or unexported fields
}

func MakeDataReader

func MakeDataReader(file *os.File, format_name string) (*DataReader, error)

func OpenDataReader

func OpenDataReader(filename, format_name string) (*DataReader, error)

func (*DataReader) Close

func (self *DataReader) Close() error

func (*DataReader) GetCount

func (self *DataReader) GetCount() int

func (*DataReader) GetCounts

func (self *DataReader) GetCounts() map[data.IDataRecord]int

func (*DataReader) GetFormatName

func (self *DataReader) GetFormatName() string

func (*DataReader) GetIndexCount

func (self *DataReader) GetIndexCount() int

func (*DataReader) GetRecordAt

func (self *DataReader) GetRecordAt(index int) (data.IDataRecord, error)

func (*DataReader) InitStream

func (self *DataReader) InitStream(stream data.IDataStream) error

func (*DataReader) InitStreamFrom

func (self *DataReader) InitStreamFrom(stream data.IDataStream, index int64) error

func (*DataReader) IsClosed

func (self *DataReader) IsClosed() bool

func (*DataReader) MakeStream

func (self *DataReader) MakeStream() (RecordStream, error)

func (*DataReader) MakeStreamFrom

func (self *DataReader) MakeStreamFrom(from int64) (RecordStream, error)

func (*DataReader) Offsets

func (self *DataReader) Offsets() []int64

func (*DataReader) ReadRecord

func (self *DataReader) ReadRecord(position int64) (data.IDataRecord, error)

type DataWriter

type DataWriter struct {
	// contains filtered or unexported fields
}

func MakeDataWriter

func MakeDataWriter(file *os.File, format_name string) (*DataWriter, error)

func OpenDataWriter

func OpenDataWriter(filename, format_name string) (*DataWriter, error)

func (*DataWriter) Close

func (self *DataWriter) Close() (err error)

func (*DataWriter) GetCount

func (self *DataWriter) GetCount() int

func (*DataWriter) GetCounts

func (self *DataWriter) GetCounts() map[data.IDataRecord]int

func (*DataWriter) GetFormatName

func (self *DataWriter) GetFormatName() string

func (*DataWriter) GetIndexCount

func (self *DataWriter) GetIndexCount() int

func (*DataWriter) IsClosed

func (self *DataWriter) IsClosed() bool

func (*DataWriter) Offsets

func (self *DataWriter) Offsets() []int64

func (*DataWriter) Write

func (self *DataWriter) Write(rec data.IDataRecord) (err error)

type IStreamItem

type IStreamItem interface {
	Index() int
	Offset() int64
	Record() data.IDataRecord
}

type RecordStream

type RecordStream <-chan IStreamItem

func (RecordStream) Close

func (self RecordStream) Close() error