migration

Documentation

Index

• Constants
• type DataMigrator
  • func NewDataMigrator(coord *coordinator.CoordinatorImpl, ...) *DataMigrator
  • func (dm *DataMigrator) Migrate()
• type Field
• type LevelDbShard
  • 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

Constants

const (
	MIGRATED_MARKER = "MIGRATED"
	OLD_SHARD_DIR   = "shard_db"
)

Types

type DataMigrator

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

Used for migrating data from old versions of influx.

func NewDataMigrator

func NewDataMigrator(coord *coordinator.CoordinatorImpl, clusterConfig *cluster.ClusterConfiguration, config *configuration.Configuration, baseDbDir, newSubDir string, metaStore *metastore.Store) *DataMigrator

func (*DataMigrator) Migrate

func (dm *DataMigrator) Migrate()

type Field

type Field struct {
	Id   []byte
	Name string
}

type LevelDbShard

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

func NewLevelDbShard

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

func (*LevelDbShard) Close

func (self *LevelDbShard) Close()

func (*LevelDbShard) DropDatabase

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

func (*LevelDbShard) GetSeriesForDatabase

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

func (*LevelDbShard) IsClosed

func (self *LevelDbShard) IsClosed() bool

func (*LevelDbShard) Query

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

func (*LevelDbShard) Write

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