diff --git a/web/api/v2/api.go b/web/api/v2/api.go index 2e58ea862..52dad72cd 100644 --- a/web/api/v2/api.go +++ b/web/api/v2/api.go @@ -111,6 +111,11 @@ var ( maxTime = time.Unix(math.MaxInt64/1000-62135596801, 999999999) ) +var ( + errAdminDisabled = status.Error(codes.Unavailable, "Admin APIs are disabled") + errTSDBNotReady = status.Error(codes.Unavailable, "TSDB not ready") +) + // AdminDisabled implements the administration interface that informs // that the API endpoints are disabled. type AdminDisabled struct { @@ -118,17 +123,17 @@ type AdminDisabled struct { // TSDBSnapshot implements pb.AdminServer. func (s *AdminDisabled) TSDBSnapshot(_ old_ctx.Context, _ *pb.TSDBSnapshotRequest) (*pb.TSDBSnapshotResponse, error) { - return nil, status.Error(codes.Unavailable, "Admin APIs are disabled") + return nil, errAdminDisabled } // TSDBCleanTombstones implements pb.AdminServer. func (s *AdminDisabled) TSDBCleanTombstones(_ old_ctx.Context, _ *pb.TSDBCleanTombstonesRequest) (*pb.TSDBCleanTombstonesResponse, error) { - return nil, status.Error(codes.Unavailable, "Admin APIs are disabled") + return nil, errAdminDisabled } // DeleteSeries implements pb.AdminServer. func (s *AdminDisabled) DeleteSeries(_ old_ctx.Context, r *pb.SeriesDeleteRequest) (*pb.SeriesDeleteResponse, error) { - return nil, status.Error(codes.Unavailable, "Admin APIs are disabled") + return nil, errAdminDisabled } // Admin provides an administration interface to Prometheus. @@ -147,7 +152,7 @@ func NewAdmin(db func() *tsdb.DB) *Admin { func (s *Admin) TSDBSnapshot(_ old_ctx.Context, req *pb.TSDBSnapshotRequest) (*pb.TSDBSnapshotResponse, error) { db := s.db() if db == nil { - return nil, status.Errorf(codes.Unavailable, "TSDB not ready") + return nil, errTSDBNotReady } var ( snapdir = filepath.Join(db.Dir(), "snapshots") @@ -169,7 +174,7 @@ func (s *Admin) TSDBSnapshot(_ old_ctx.Context, req *pb.TSDBSnapshotRequest) (*p func (s *Admin) TSDBCleanTombstones(_ old_ctx.Context, _ *pb.TSDBCleanTombstonesRequest) (*pb.TSDBCleanTombstonesResponse, error) { db := s.db() if db == nil { - return nil, status.Errorf(codes.Unavailable, "TSDB not ready") + return nil, errTSDBNotReady } if err := db.CleanTombstones(); err != nil { @@ -215,7 +220,7 @@ func (s *Admin) DeleteSeries(_ old_ctx.Context, r *pb.SeriesDeleteRequest) (*pb. } db := s.db() if db == nil { - return nil, status.Errorf(codes.Unavailable, "TSDB not ready") + return nil, errTSDBNotReady } if err := db.Delete(timestamp.FromTime(mint), timestamp.FromTime(maxt), matchers...); err != nil { return nil, status.Error(codes.Internal, err.Error())