本文整理汇总了Golang中github.com/influxdata/influxdb/influxql.ErrDatabaseNotFound函数的典型用法代码示例。如果您正苦于以下问题:Golang ErrDatabaseNotFound函数的具体用法?Golang ErrDatabaseNotFound怎么用?Golang ErrDatabaseNotFound使用的例子?那么恭喜您, 这里精选的函数代码示例或许可以为您提供帮助。
在下文中一共展示了ErrDatabaseNotFound函数的9个代码示例,这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞,您的评价将有助于我们的系统推荐出更棒的Golang代码示例。
示例1: deleteSeries
func (s *Store) deleteSeries(database string, seriesKeys []string, min, max int64) error {
db := s.databaseIndexes[database]
if db == nil {
return influxql.ErrDatabaseNotFound(database)
}
for _, sh := range s.shards {
if sh.database != database {
continue
}
if err := sh.DeleteSeriesRange(seriesKeys, min, max); err != nil {
return err
}
// The keys we passed in may be fully deleted from the shard, if so,
// we need to remove the shard from all the meta data indexes
existing, err := sh.ContainsSeries(seriesKeys)
if err != nil {
return err
}
for k, exists := range existing {
if !exists {
db.UnassignShard(k, sh.id)
}
}
}
return nil
}
开发者ID:arussellsaw,项目名称:influxdb,代码行数:30,代码来源:store.go
示例2: deleteSeries
func (s *Store) deleteSeries(database string, seriesKeys []string, min, max int64) error {
db := s.databaseIndexes[database]
if db == nil {
return influxql.ErrDatabaseNotFound(database)
}
s.mu.RLock()
shards := s.filterShards(func(sh *Shard) bool {
return sh.database == database
})
s.mu.RUnlock()
return s.walkShards(shards, func(sh *Shard) error {
if sh.database != database {
return nil
}
if err := sh.DeleteSeriesRange(seriesKeys, min, max); err != nil {
return err
}
// The keys we passed in may be fully deleted from the shard, if so,
// we need to remove the shard from all the meta data indexes
existing, err := sh.ContainsSeries(seriesKeys)
if err != nil {
return err
}
for k, exists := range existing {
if !exists {
db.UnassignShard(k, sh.id)
}
}
return nil
})
}
开发者ID:oiooj,项目名称:influxdb,代码行数:35,代码来源:store.go
示例3: executeDropMeasurementStatement
func (e *StatementExecutor) executeDropMeasurementStatement(stmt *influxql.DropMeasurementStatement, database string) error {
if dbi := e.MetaClient.Database(database); dbi == nil {
return influxql.ErrDatabaseNotFound(database)
}
// Locally drop the measurement
return e.TSDBStore.DeleteMeasurement(database, stmt.Name)
}
开发者ID:li-ang,项目名称:influxdb,代码行数:8,代码来源:statement_executor.go
示例4: executeDeleteSeriesStatement
func (e *StatementExecutor) executeDeleteSeriesStatement(stmt *influxql.DeleteSeriesStatement, database string) error {
if dbi := e.MetaClient.Database(database); dbi == nil {
return influxql.ErrDatabaseNotFound(database)
}
// Convert "now()" to current time.
stmt.Condition = influxql.Reduce(stmt.Condition, &influxql.NowValuer{Now: time.Now().UTC()})
// Locally delete the series.
return e.TSDBStore.DeleteSeries(database, stmt.Sources, stmt.Condition)
}
开发者ID:li-ang,项目名称:influxdb,代码行数:11,代码来源:statement_executor.go
示例5: executeDropSeriesStatement
func (e *StatementExecutor) executeDropSeriesStatement(stmt *influxql.DropSeriesStatement, database string) error {
if dbi := e.MetaClient.Database(database); dbi == nil {
return influxql.ErrDatabaseNotFound(database)
}
// Check for time in WHERE clause (not supported).
if influxql.HasTimeExpr(stmt.Condition) {
return errors.New("DROP SERIES doesn't support time in WHERE clause")
}
// Locally drop the series.
return e.TSDBStore.DeleteSeries(database, stmt.Sources, stmt.Condition)
}
开发者ID:li-ang,项目名称:influxdb,代码行数:13,代码来源:statement_executor.go
示例6: deleteSeries
func (s *Store) deleteSeries(database string, seriesKeys []string) error {
if _, ok := s.databaseIndexes[database]; !ok {
return influxql.ErrDatabaseNotFound(database)
}
for _, sh := range s.shards {
if sh.database != database {
continue
}
if err := sh.DeleteSeries(seriesKeys); err != nil {
return err
}
}
return nil
}
开发者ID:SriramKeerthi,项目名称:influxdb,代码行数:15,代码来源:store.go
示例7: executeDropMeasurementStatement
func (e *QueryExecutor) executeDropMeasurementStatement(stmt *influxql.DropMeasurementStatement, database string) error {
if dbi, err := e.MetaClient.Database(database); err != nil {
return err
} else if dbi == nil {
return influxql.ErrDatabaseNotFound(database)
}
// Locally drop the measurement
if err := e.TSDBStore.DeleteMeasurement(database, stmt.Name); err != nil {
return err
}
// Execute the statement on the other data nodes in the cluster.
return e.MetaExecutor.ExecuteStatement(stmt, database)
}
开发者ID:hawson,项目名称:influxdb,代码行数:15,代码来源:query_executor.go
示例8: Run
// Run runs the specified continuous query, or all CQs if none is specified.
func (s *Service) Run(database, name string, t time.Time) error {
var dbs []meta.DatabaseInfo
if database != "" {
// Find the requested database.
db, err := s.MetaClient.Database(database)
if err != nil {
return err
} else if db == nil {
return influxql.ErrDatabaseNotFound(database)
}
dbs = append(dbs, *db)
} else {
// Get all databases.
var err error
dbs, err = s.MetaClient.Databases()
if err != nil {
return err
}
}
// Loop through databases.
s.mu.Lock()
defer s.mu.Unlock()
for _, db := range dbs {
// Loop through CQs in each DB executing the ones that match name.
for _, cq := range db.ContinuousQueries {
if name == "" || cq.Name == name {
// Remove the last run time for the CQ
id := fmt.Sprintf("%s:%s", db.Name, cq.Name)
if _, ok := s.lastRuns[id]; ok {
delete(s.lastRuns, id)
}
}
}
}
// Signal the background routine to run CQs.
s.RunCh <- &RunRequest{Now: t}
return nil
}
开发者ID:bg451,项目名称:appdash,代码行数:43,代码来源:service.go
示例9: executeDropSeriesStatement
func (e *QueryExecutor) executeDropSeriesStatement(stmt *influxql.DropSeriesStatement, database string) error {
if dbi, err := e.MetaClient.Database(database); err != nil {
return err
} else if dbi == nil {
return influxql.ErrDatabaseNotFound(database)
}
// Check for time in WHERE clause (not supported).
if influxql.HasTimeExpr(stmt.Condition) {
return errors.New("DROP SERIES doesn't support time in WHERE clause")
}
// Locally drop the series.
if err := e.TSDBStore.DeleteSeries(database, stmt.Sources, stmt.Condition); err != nil {
return err
}
// Execute the statement on the other data nodes in the cluster.
return e.MetaExecutor.ExecuteStatement(stmt, database)
}
开发者ID:hawson,项目名称:influxdb,代码行数:20,代码来源:query_executor.go
注:本文中的github.com/influxdata/influxdb/influxql.ErrDatabaseNotFound函数示例整理自Github/MSDocs等源码及文档管理平台,相关代码片段筛选自各路编程大神贡献的开源项目,源码版权归原作者所有,传播和使用请参考对应项目的License;未经允许,请勿转载。 |
请发表评论