migration

Aug 22, 2014

Changes in this version

+ const MIGRATED_MARKER

+ const OLD_SHARD_DIR

+ const POINT_COUNT_TO_PAUSE

+ type DataMigrator struct

+ func NewDataMigrator(coord *coordinator.CoordinatorImpl, ...) *DataMigrator

+ func (dm *DataMigrator) Migrate()

+ type Field struct

+ Id []byte

+ Name string

+ type LevelDbShard struct

+ func NewLevelDbShard(db *levigo.DB, pointBatchSize, writeBatchSize int) (*LevelDbShard, error)

+ func (self *LevelDbShard) Close()

+ func (self *LevelDbShard) DropDatabase(database string) error

+ func (self *LevelDbShard) GetSeriesForDatabase(database string) []string

+ func (self *LevelDbShard) IsClosed() bool

+ func (self *LevelDbShard) Query(querySpec *parser.QuerySpec, processor cluster.QueryProcessor) error

+ func (self *LevelDbShard) Write(database string, series []*protocol.Series) error