本文整理汇总了Golang中github.com/influxdata/influxdb/tsdb.Shard类的典型用法代码示例。如果您正苦于以下问题:Golang Shard类的具体用法?Golang Shard怎么用?Golang Shard使用的例子?那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。
在下文中一共展示了Shard类的2个代码示例,这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞,您的评价将有助于我们的系统推荐出更棒的Golang代码示例。
示例1: chunkedWrite
func chunkedWrite(shard *tsdb.Shard, points []models.Point) {
nPts := len(points)
chunkSz := 10000
start := 0
end := chunkSz
for {
if end > nPts {
end = nPts
}
if end-start == 0 {
break
}
shard.WritePoints(points[start:end])
start = end
end += chunkSz
}
}
开发者ID:Vidhuran,项目名称:influxdb,代码行数:19,代码来源:shard_test.go
示例2: LoadMetadataIndex
// LoadMetadataIndex loads the shard metadata into memory.
func (e *Engine) LoadMetadataIndex(sh *tsdb.Shard, index *tsdb.DatabaseIndex) error {
// Save reference to index for iterator creation.
e.index = index
start := time.Now()
if err := e.FileStore.WalkKeys(func(key string, typ byte) error {
fieldType, err := tsmFieldTypeToInfluxQLDataType(typ)
if err != nil {
return err
}
if err := e.addToIndexFromKey(key, fieldType, index); err != nil {
return err
}
return nil
}); err != nil {
return err
}
// load metadata from the Cache
e.Cache.RLock() // shouldn't need the lock, but just to be safe
defer e.Cache.RUnlock()
for key, entry := range e.Cache.Store() {
fieldType, err := entry.values.InfluxQLType()
if err != nil {
e.logger.Printf("error getting the data type of values for key %s: %s", key, err.Error())
continue
}
if err := e.addToIndexFromKey(key, fieldType, index); err != nil {
return err
}
}
// sh may be nil in tests
if sh != nil {
e.logger.Printf("%s database index loaded in %s", sh.Path(), time.Now().Sub(start))
}
return nil
}
开发者ID:carosio,项目名称:influxdb-dist,代码行数:44,代码来源:engine.go
注:本文中的github.com/influxdata/influxdb/tsdb.Shard类示例整理自Github/MSDocs等源码及文档管理平台,相关代码片段筛选自各路编程大神贡献的开源项目,源码版权归原作者所有,传播和使用请参考对应项目的License;未经允许,请勿转载。 |
请发表评论