115 lines
2.8 KiB
Go
115 lines
2.8 KiB
Go
package tsm1
|
|
|
|
import (
|
|
"github.com/influxdata/influxdb/v2/tsdb"
|
|
)
|
|
|
|
var TestMmapInitFailOption = func(err error) tsmReaderOption {
|
|
return func(r *TSMReader) {
|
|
r.accessor = &badBlockAccessor{error: err}
|
|
}
|
|
}
|
|
|
|
type badBlockAccessor struct {
|
|
error
|
|
initCalled bool
|
|
}
|
|
|
|
func (b *badBlockAccessor) init() (*indirectIndex, error) {
|
|
b.initCalled = true
|
|
return nil, b.error
|
|
}
|
|
|
|
func (b *badBlockAccessor) read(key []byte, timestamp int64) ([]Value, error) {
|
|
//TODO implement me
|
|
panic("implement me")
|
|
}
|
|
|
|
func (b *badBlockAccessor) readAll(key []byte) ([]Value, error) {
|
|
//TODO implement me
|
|
panic("implement me")
|
|
}
|
|
|
|
func (b *badBlockAccessor) readBlock(entry *IndexEntry, values []Value) ([]Value, error) {
|
|
//TODO implement me
|
|
panic("implement me")
|
|
}
|
|
|
|
func (b *badBlockAccessor) readFloatBlock(entry *IndexEntry, values *[]FloatValue) ([]FloatValue, error) {
|
|
//TODO implement me
|
|
panic("implement me")
|
|
}
|
|
|
|
func (b *badBlockAccessor) readFloatArrayBlock(entry *IndexEntry, values *tsdb.FloatArray) error {
|
|
//TODO implement me
|
|
panic("implement me")
|
|
}
|
|
|
|
func (b *badBlockAccessor) readIntegerBlock(entry *IndexEntry, values *[]IntegerValue) ([]IntegerValue, error) {
|
|
//TODO implement me
|
|
panic("implement me")
|
|
}
|
|
|
|
func (b *badBlockAccessor) readIntegerArrayBlock(entry *IndexEntry, values *tsdb.IntegerArray) error {
|
|
//TODO implement me
|
|
panic("implement me")
|
|
}
|
|
|
|
func (b *badBlockAccessor) readUnsignedBlock(entry *IndexEntry, values *[]UnsignedValue) ([]UnsignedValue, error) {
|
|
//TODO implement me
|
|
panic("implement me")
|
|
}
|
|
|
|
func (b *badBlockAccessor) readUnsignedArrayBlock(entry *IndexEntry, values *tsdb.UnsignedArray) error {
|
|
//TODO implement me
|
|
panic("implement me")
|
|
}
|
|
|
|
func (b *badBlockAccessor) readStringBlock(entry *IndexEntry, values *[]StringValue) ([]StringValue, error) {
|
|
//TODO implement me
|
|
panic("implement me")
|
|
}
|
|
|
|
func (b *badBlockAccessor) readStringArrayBlock(entry *IndexEntry, values *tsdb.StringArray) error {
|
|
//TODO implement me
|
|
panic("implement me")
|
|
}
|
|
|
|
func (b *badBlockAccessor) readBooleanBlock(entry *IndexEntry, values *[]BooleanValue) ([]BooleanValue, error) {
|
|
//TODO implement me
|
|
panic("implement me")
|
|
}
|
|
|
|
func (b *badBlockAccessor) readBooleanArrayBlock(entry *IndexEntry, values *tsdb.BooleanArray) error {
|
|
//TODO implement me
|
|
panic("implement me")
|
|
}
|
|
|
|
func (b *badBlockAccessor) readBytes(entry *IndexEntry, buf []byte) (uint32, []byte, error) {
|
|
//TODO implement me
|
|
panic("implement me")
|
|
}
|
|
|
|
func (b *badBlockAccessor) rename(path string) error {
|
|
//TODO implement me
|
|
panic("implement me")
|
|
}
|
|
|
|
func (b *badBlockAccessor) path() string {
|
|
//TODO implement me
|
|
panic("implement me")
|
|
}
|
|
|
|
func (b *badBlockAccessor) close() error {
|
|
if !b.initCalled {
|
|
panic("close called without an init call")
|
|
}
|
|
b.initCalled = false
|
|
return nil
|
|
}
|
|
|
|
func (b *badBlockAccessor) free() error {
|
|
//TODO implement me
|
|
panic("implement me")
|
|
}
|