Documentation
¶
Index ¶
- func MarshalRecords(records []*Record) ([]byte, error)
- func RecordCount(b []byte) int
- type Appender
- type BlockMeta
- type CompactedBlockMeta
- type Finder
- type ID
- type Iterator
- func NewBackendIterator(tenantID string, blockID uuid.UUID, chunkSizeBytes uint32, reader Reader) (Iterator, error)
- func NewDedupingIterator(iter Iterator, combiner ObjectCombiner) (Iterator, error)
- func NewIterator(reader io.Reader) Iterator
- func NewRecordIterator(r []*Record, ra io.ReaderAt) Iterator
- type ObjectCombiner
- type Reader
- type Record
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func MarshalRecords ¶
todo: move encoding/decoding to a separate util area? is the index too large? need an io.Reader?
func RecordCount ¶
Types ¶
type Appender ¶
func NewAppender ¶
type BlockMeta ¶
type BlockMeta struct { Version string `json:"format"` BlockID uuid.UUID `json:"blockID"` MinID ID `json:"minID"` MaxID ID `json:"maxID"` TenantID string `json:"tenantID"` StartTime time.Time `json:"startTime"` EndTime time.Time `json:"endTime"` TotalObjects int `json:"totalObjects"` CompactionLevel uint8 `json:"compactionLevel"` }
func (*BlockMeta) ObjectAdded ¶
type CompactedBlockMeta ¶
type Finder ¶
func NewDedupingFinder ¶
func NewDedupingFinder(sortedRecords []*Record, ra io.ReaderAt, combiner ObjectCombiner) Finder
type Iterator ¶
func NewBackendIterator ¶
func NewDedupingIterator ¶
func NewDedupingIterator(iter Iterator, combiner ObjectCombiner) (Iterator, error)
func NewIterator ¶
type ObjectCombiner ¶
Source Files
¶
Click to show internal directories.
Click to hide internal directories.