disk

type Config struct {
	Folder               string                 `yaml:"folder" json:"folder"`
	ConcurrentWriteFiles int                    `yaml:"concurrentWriteFiles" json:"concurrentWriteFiles"`
	SingleFileSize       int                    `yaml:"singleFileSize" json:"singleFileSize"`
	FileBufferSize       int                    `yaml:"fileBufferSize" json:"file_buffer_size"`
	Encoding             map[string]string      `yaml:"encoding" json:"encoding"`
	XXX                  map[string]interface{} `yaml:",inline"`
}

type DataFileIndexWriter interface {
	// TODO: we need to record information like int/double, precision, min, max time etc.
	Add(series common.Series, offset uint64, size uint32, minTime int64, maxTime int64) error
	SortedID() []common.SeriesID
	Len() int
	// NOTE: use must means we will panic if use non exist ID
	MustEntries(id common.SeriesID) *IndexEntries
	WriteAll(io.Writer) (length uint32, indexOffset uint32, errs error)
}

type DataFileReader interface {
	ReadIndexOfIndexes() error
	ReadAllIndexEntries() error
	SeriesCount() int
	Close() error
	PrintAll()
}

type DataFileWriter interface {
	// WriteHeader writes the magic number and version, it will be called by WriteSeries automatically for once
	WriteHeader() error
	WriteSeries(series common.Series) error
	// Finalized returns if the index is written and the file can be closed
	Finalized() bool
	// WriteIndex writes index data and trailing magic number into the end of the file (buffer). You can only call it once
	WriteIndex() error
	// Flush flushes data in the buffer to disk
	Flush() error
	// Close closes the underlying file, the file must be finalized, otherwise it can't be read
	Close() error
}

type EncodingOption struct {
	TimeCodec        byte
	IntValueCodec    byte
	DoubleValueCodec byte
}

type IndexEntries struct {
	// TODO: index entries may have the overall aggregation of all the index entries, like min, max, time
	common.SeriesMeta `protobuf:"bytes,1,opt,name=Meta,embedded=Meta" json:"Meta"`
	Entries           []IndexEntry `protobuf:"bytes,2,rep,name=Entries" json:"Entries"`
}

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

type IndexEntry struct {
	Offset    uint64 `protobuf:"varint,1,opt,name=Offset,proto3" json:"Offset,omitempty"`
	BlockSize uint32 `protobuf:"varint,2,opt,name=BlockSize,proto3" json:"BlockSize,omitempty"`
	MinTime   int64  `protobuf:"varint,3,opt,name=minTime,proto3" json:"minTime,omitempty"`
	MaxTime   int64  `protobuf:"varint,4,opt,name=maxTime,proto3" json:"maxTime,omitempty"`
}

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

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

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

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

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