Documentation
¶
Index ¶
- func WalkPlan(v Visitor, node Node)
- type Node
- type SchemaPlan
- type SchemaSpec
- type StoragePlan
- 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
- type TagCardinalities
- type Visitor
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
Types ¶
type SchemaPlan ¶
type SchemaPlan struct {
StoragePlan *StoragePlan
Tags TagCardinalities
PointsPerSeriesPerShard int
}
func (*SchemaPlan) PrintPlan ¶
func (p *SchemaPlan) PrintPlan(w io.Writer)
func (*SchemaPlan) String ¶
func (p *SchemaPlan) String() string
type SchemaSpec ¶
type SchemaSpec struct {
Tags TagCardinalities
PointsPerSeriesPerShard int
}
func (*SchemaSpec) AddFlags ¶
func (s *SchemaSpec) AddFlags(fs *flag.FlagSet)
func (*SchemaSpec) Plan ¶
func (s *SchemaSpec) Plan(sp *StoragePlan) (*SchemaPlan, error)
type StoragePlan ¶
type StoragePlan struct {
Database string
Retention string
ReplicaN int
StartTime time.Time
ShardCount int
ShardDuration time.Duration
DatabasePath string
// contains filtered or unexported fields
}
func (*StoragePlan) EndTime ¶
func (p *StoragePlan) EndTime() time.Time
func (*StoragePlan) InitFileSystem ¶
func (p *StoragePlan) InitFileSystem(client server.MetaClient) error
InitFileSystem initializes the file system structure, cleaning up existing files and re-creating the appropriate shard directories.
func (*StoragePlan) InitMetadata ¶
func (p *StoragePlan) InitMetadata(client server.MetaClient) (err error)
func (*StoragePlan) NodeShardGroups ¶
func (p *StoragePlan) NodeShardGroups() []meta.ShardGroupInfo
NodeShardGroups returns ShardGroupInfo with Shards limited to the current node
func (*StoragePlan) PrintPlan ¶
func (p *StoragePlan) PrintPlan(w io.Writer)
func (*StoragePlan) ShardGroups ¶
func (p *StoragePlan) ShardGroups() []meta.ShardGroupInfo
func (*StoragePlan) ShardPath ¶
func (p *StoragePlan) ShardPath() string
func (*StoragePlan) String ¶
func (p *StoragePlan) String() string
func (*StoragePlan) TimeRange ¶
func (p *StoragePlan) TimeRange() (start, end time.Time)
func (*StoragePlan) TimeSpan ¶
func (p *StoragePlan) TimeSpan() time.Duration
TimeSpan returns the total duration for which the data set.
func (*StoragePlan) Validate ¶
func (p *StoragePlan) Validate() error
type StorageSpec ¶
type StorageSpec struct {
StartTime string
Database string
Retention string
ReplicaN int
ShardCount int
ShardDuration time.Duration
}
func (*StorageSpec) AddFlags ¶
func (a *StorageSpec) AddFlags(fs *flag.FlagSet)
func (*StorageSpec) Plan ¶
func (a *StorageSpec) Plan(server server.Interface) (*StoragePlan, error)
type TagCardinalities ¶
type TagCardinalities []int
func (TagCardinalities) Cardinality ¶
func (t TagCardinalities) Cardinality() int
func (*TagCardinalities) Set ¶
func (t *TagCardinalities) Set(tags string) error
func (TagCardinalities) String ¶
func (t TagCardinalities) String() string
Source Files
Directories
Click to show internal directories.
Click to hide internal directories.