refactor: remove reference to flux.Spec in query tests (#23652)
It appears to be dead and not used anymore.pull/23665/head
parent
accce863db
commit
785a465e9a
|
@ -13,7 +13,6 @@ import (
|
||||||
|
|
||||||
"github.com/google/go-cmp/cmp"
|
"github.com/google/go-cmp/cmp"
|
||||||
"github.com/google/go-cmp/cmp/cmpopts"
|
"github.com/google/go-cmp/cmp/cmpopts"
|
||||||
"github.com/influxdata/flux"
|
|
||||||
"github.com/influxdata/flux/ast"
|
"github.com/influxdata/flux/ast"
|
||||||
"github.com/influxdata/flux/csv"
|
"github.com/influxdata/flux/csv"
|
||||||
"github.com/influxdata/flux/lang"
|
"github.com/influxdata/flux/lang"
|
||||||
|
@ -28,13 +27,11 @@ var cmpOptions = cmp.Options{
|
||||||
cmpopts.IgnoreTypes(ast.BaseNode{}),
|
cmpopts.IgnoreTypes(ast.BaseNode{}),
|
||||||
cmpopts.IgnoreUnexported(query.ProxyRequest{}),
|
cmpopts.IgnoreUnexported(query.ProxyRequest{}),
|
||||||
cmpopts.IgnoreUnexported(query.Request{}),
|
cmpopts.IgnoreUnexported(query.Request{}),
|
||||||
cmpopts.IgnoreUnexported(flux.Spec{}),
|
|
||||||
cmpopts.EquateEmpty(),
|
cmpopts.EquateEmpty(),
|
||||||
}
|
}
|
||||||
|
|
||||||
func TestQueryRequest_WithDefaults(t *testing.T) {
|
func TestQueryRequest_WithDefaults(t *testing.T) {
|
||||||
type fields struct {
|
type fields struct {
|
||||||
Spec *flux.Spec
|
|
||||||
AST json.RawMessage
|
AST json.RawMessage
|
||||||
Query string
|
Query string
|
||||||
Type string
|
Type string
|
||||||
|
@ -192,7 +189,6 @@ func TestQueryRequest_Validate(t *testing.T) {
|
||||||
func TestQueryRequest_proxyRequest(t *testing.T) {
|
func TestQueryRequest_proxyRequest(t *testing.T) {
|
||||||
type fields struct {
|
type fields struct {
|
||||||
Extern json.RawMessage
|
Extern json.RawMessage
|
||||||
Spec *flux.Spec
|
|
||||||
AST json.RawMessage
|
AST json.RawMessage
|
||||||
Query string
|
Query string
|
||||||
Type string
|
Type string
|
||||||
|
|
|
@ -7,7 +7,6 @@ import (
|
||||||
"net/http"
|
"net/http"
|
||||||
"time"
|
"time"
|
||||||
|
|
||||||
"github.com/influxdata/flux"
|
|
||||||
"github.com/influxdata/flux/csv"
|
"github.com/influxdata/flux/csv"
|
||||||
"github.com/influxdata/flux/lang"
|
"github.com/influxdata/flux/lang"
|
||||||
"github.com/influxdata/httprouter"
|
"github.com/influxdata/httprouter"
|
||||||
|
@ -143,7 +142,6 @@ func NewSourceHandler(log *zap.Logger, b *SourceBackend) *SourceHandler {
|
||||||
func decodeSourceQueryRequest(r *http.Request) (*query.ProxyRequest, error) {
|
func decodeSourceQueryRequest(r *http.Request) (*query.ProxyRequest, error) {
|
||||||
// starts here
|
// starts here
|
||||||
request := struct {
|
request := struct {
|
||||||
Spec *flux.Spec `json:"spec"`
|
|
||||||
Query string `json:"query"`
|
Query string `json:"query"`
|
||||||
Type string `json:"type"`
|
Type string `json:"type"`
|
||||||
DB string `json:"db"`
|
DB string `json:"db"`
|
||||||
|
|
Loading…
Reference in New Issue