32 lines
986 B
Go
32 lines
986 B
Go
package mock
|
|
|
|
import (
|
|
"context"
|
|
|
|
"github.com/influxdata/influxdb/v2/kit/platform"
|
|
|
|
"github.com/influxdata/influxdb/v2"
|
|
)
|
|
|
|
var _ influxdb.DeleteService = &DeleteService{}
|
|
|
|
// DeleteService is a mock delete server.
|
|
type DeleteService struct {
|
|
DeleteBucketRangePredicateF func(tx context.Context, orgID, bucketID platform.ID, min, max int64, pred influxdb.Predicate) error
|
|
}
|
|
|
|
// NewDeleteService returns a mock DeleteService where its methods will return
|
|
// zero values.
|
|
func NewDeleteService() DeleteService {
|
|
return DeleteService{
|
|
DeleteBucketRangePredicateF: func(tx context.Context, orgID, bucketID platform.ID, min, max int64, pred influxdb.Predicate) error {
|
|
return nil
|
|
},
|
|
}
|
|
}
|
|
|
|
//DeleteBucketRangePredicate calls DeleteBucketRangePredicateF.
|
|
func (s DeleteService) DeleteBucketRangePredicate(ctx context.Context, orgID, bucketID platform.ID, min, max int64, pred influxdb.Predicate) error {
|
|
return s.DeleteBucketRangePredicateF(ctx, orgID, bucketID, min, max, pred)
|
|
}
|