Versions in this module Expand all Collapse all v1 v1.7.9 Oct 27, 2019 Changes in this version + func WalkPlan(v Visitor, node Node) + type Node interface + type SchemaPlan struct + PointsPerSeriesPerShard int + StoragePlan *StoragePlan + Tags TagCardinalities + func (p *SchemaPlan) PrintPlan(w io.Writer) + func (p *SchemaPlan) String() string + type SchemaSpec struct + PointsPerSeriesPerShard int + Tags TagCardinalities + func (s *SchemaSpec) AddFlags(fs *flag.FlagSet) + func (s *SchemaSpec) Plan(sp *StoragePlan) (*SchemaPlan, error) + type StoragePlan struct + Database string + DatabasePath string + ReplicaN int + Retention string + ShardCount int + ShardDuration time.Duration + StartTime time.Time + func (p *StoragePlan) EndTime() time.Time + func (p *StoragePlan) InitFileSystem(client server.MetaClient) error + func (p *StoragePlan) InitMetadata(client server.MetaClient) (err error) + func (p *StoragePlan) NodeShardGroups() []meta.ShardGroupInfo + func (p *StoragePlan) PrintPlan(w io.Writer) + func (p *StoragePlan) ShardGroups() []meta.ShardGroupInfo + func (p *StoragePlan) ShardPath() string + func (p *StoragePlan) String() string + func (p *StoragePlan) TimeRange() (start, end time.Time) + func (p *StoragePlan) TimeSpan() time.Duration + func (p *StoragePlan) Validate() error + type StorageSpec struct + Database string + ReplicaN int + Retention string + ShardCount int + ShardDuration time.Duration + StartTime string + func (a *StorageSpec) AddFlags(fs *flag.FlagSet) + func (a *StorageSpec) Plan(server server.Interface) (*StoragePlan, error) + type TagCardinalities []int + func (t *TagCardinalities) Set(tags string) error + func (t TagCardinalities) Cardinality() int + func (t TagCardinalities) String() string + type Visitor interface + Visit func(node Node) Visitor