feat: plumbing through TimeRange

Author: devanbenz

tsdb/engine.go

@@ -83,6 +83,8 @@ type Engine interface {
 	DiskSize() int64
 	IsIdle() (bool, string)
 	Free() error
+	// TimeRange will return the min/max time range of shard
+	TimeRange() (int64, int64)
 
 	io.WriterTo
 }

tsdb/engine/tsm1/engine.go

@@ -677,6 +677,11 @@ func (e *Engine) LastModified() time.Time {
 	return fsTime
 }
 
+// TimeRange returns the min and max time range for this shard
+func (e *Engine) TimeRange() (int64, int64) {
+	return e.FileStore.TimeRange()
+}
+
 // EngineStatistics maintains statistics for the engine.
 type EngineStatistics struct {
 	CacheCompactions        int64 // Counter of cache compactions that have ever run.

tsdb/shard.go

@@ -474,6 +474,16 @@ func (s *Shard) LastModifiedWithErr() (time.Time, error) {
 	return engine.LastModified(), nil
 }
 
+func (s *Shard) TimeRange() (int64, int64, error) {
+	engine, err := s.Engine()
+	if err != nil {
+		return int64(0), int64(0), err
+	}
+
+	minT, maxT := engine.TimeRange()
+	return minT, maxT, nil
+}
+
 // Index returns a reference to the underlying index. It returns an error if
 // the index is nil.
 func (s *Shard) Index() (Index, error) {