Influxdata
/
influxdb
mirror of https://github.com/influxdata/influxdb.git
1
0
Fork 0
Code Issues Projects Releases Wiki Activity

fix: Return ENotFound for BackupShard()

pull/19864/head
Ben Johnson 2020-11-02 08:37:46 -07:00
parent 6e1097c625
commit ea1a3dbe60
1 changed files with 8 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
tsdb/store.go
View File

@ -1192,7 +1192,10 @@ func (s *Store) MeasurementsSketches(database string) (estimator.Sketch, estimat
func (s *Store) BackupShard(id uint64, since time.Time, w io.Writer) error { func (s *Store) BackupShard(id uint64, since time.Time, w io.Writer) error {
shard := s.Shard(id) shard := s.Shard(id)
if shard == nil { if shard == nil {
return fmt.Errorf("shard %d doesn't exist on this server", id) return &influxdb.Error{
Code: influxdb.ENotFound,
Msg: fmt.Sprintf("shard %d not found", id),
}
} }
path, err := relativePath(s.path, shard.path) path, err := relativePath(s.path, shard.path)
@ -1206,7 +1209,10 @@ func (s *Store) BackupShard(id uint64, since time.Time, w io.Writer) error {
func (s *Store) ExportShard(id uint64, start time.Time, end time.Time, w io.Writer) error { func (s *Store) ExportShard(id uint64, start time.Time, end time.Time, w io.Writer) error {
shard := s.Shard(id) shard := s.Shard(id)
if shard == nil { if shard == nil {
return fmt.Errorf("shard %d doesn't exist on this server", id) return &influxdb.Error{
Code: influxdb.ENotFound,
Msg: fmt.Sprintf("shard %d not found", id),
}
} }
path, err := relativePath(s.path, shard.path) path, err := relativePath(s.path, shard.path)