Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

refactor: replace builtin package with fluxinit/static (#3304) #19909

Merged
merged 1 commit into from Nov 6, 2020
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Jump to
Jump to file
Failed to load files.
Diff view
Diff view
2 changes: 1 addition & 1 deletion authorizer/task_test.go
Expand Up @@ -13,7 +13,7 @@ import (
"github.com/influxdata/influxdb/v2/kv"
"github.com/influxdata/influxdb/v2/kv/migration/all"
"github.com/influxdata/influxdb/v2/mock"
_ "github.com/influxdata/influxdb/v2/query/builtin"
_ "github.com/influxdata/influxdb/v2/fluxinit/static"
"github.com/pkg/errors"
"go.uber.org/zap/zaptest"
)
Expand Down
2 changes: 1 addition & 1 deletion checks/service_test.go
Expand Up @@ -8,7 +8,7 @@ import (
"github.com/influxdata/influxdb/v2/inmem"
"github.com/influxdata/influxdb/v2/kv"
"github.com/influxdata/influxdb/v2/kv/migration/all"
_ "github.com/influxdata/influxdb/v2/query/builtin"
_ "github.com/influxdata/influxdb/v2/fluxinit/static"
"github.com/influxdata/influxdb/v2/query/fluxlang"
"go.uber.org/zap/zaptest"
)
Expand Down
2 changes: 1 addition & 1 deletion cmd/influxd/launcher/launcher_test.go
Expand Up @@ -10,7 +10,7 @@ import (
platform "github.com/influxdata/influxdb/v2"
"github.com/influxdata/influxdb/v2/cmd/influxd/launcher"
"github.com/influxdata/influxdb/v2/http"
_ "github.com/influxdata/influxdb/v2/query/builtin"
_ "github.com/influxdata/influxdb/v2/fluxinit/static"
)

// Default context.
Expand Down
17 changes: 9 additions & 8 deletions fluxinit/init.go
@@ -1,3 +1,9 @@
// This package imports all the influxdb-specific query builtins. From influxdb
// we must use this package and not the init package provided by flux.
//
// This package is used for initializing with a function call. As a
// convenience, the fluxinit/static package can be imported for use cases where
// static initialization is okay, such as tests.
package fluxinit

import (
Expand All @@ -7,14 +13,9 @@ import (
_ "github.com/influxdata/influxdb/v2/query/stdlib" // Import the stdlib
)

// FluxInit() prepares the runtime for compilation and execution of flux. This
// is a costly step and should only be performed if the intention is to compile
// and execute flux code.
//
// Importing this package and calling FluxInit is equivalent to importing the
// "builtin" package. It draws in the standard library functions, which
// register themselves in init() functions, then performs the final steps
// necessary to prepare for executing flux.
// The FluxInit() function prepares the runtime for compilation and execution
// of Flux. This is a costly step and should only be performed if the intention
// is to compile and execute flux code.
func FluxInit() {
runtime.FinalizeBuiltIns()
}
11 changes: 11 additions & 0 deletions fluxinit/static/static.go
@@ -0,0 +1,11 @@
// The fluxinit/static package can be imported in test cases and other uses
// cases where it is okay to always initialize flux.
package static

import (
"github.com/influxdata/influxdb/v2/fluxinit"
)

func init() {
fluxinit.FluxInit()
}
2 changes: 1 addition & 1 deletion http/query_test.go
Expand Up @@ -20,7 +20,7 @@ import (
platform "github.com/influxdata/influxdb/v2"
"github.com/influxdata/influxdb/v2/mock"
"github.com/influxdata/influxdb/v2/query"
_ "github.com/influxdata/influxdb/v2/query/builtin"
_ "github.com/influxdata/influxdb/v2/fluxinit/static"
)

var cmpOptions = cmp.Options{
Expand Down
2 changes: 1 addition & 1 deletion http/task_service_test.go
Expand Up @@ -21,7 +21,7 @@ import (
"github.com/influxdata/influxdb/v2/kv"
"github.com/influxdata/influxdb/v2/label"
"github.com/influxdata/influxdb/v2/mock"
_ "github.com/influxdata/influxdb/v2/query/builtin"
_ "github.com/influxdata/influxdb/v2/fluxinit/static"
"github.com/influxdata/influxdb/v2/tenant"
influxdbtesting "github.com/influxdata/influxdb/v2/testing"
"go.uber.org/zap"
Expand Down
2 changes: 1 addition & 1 deletion kv/task_test.go
Expand Up @@ -15,7 +15,7 @@ import (
"github.com/influxdata/influxdb/v2/kit/feature"
"github.com/influxdata/influxdb/v2/kv"
"github.com/influxdata/influxdb/v2/mock"
_ "github.com/influxdata/influxdb/v2/query/builtin"
_ "github.com/influxdata/influxdb/v2/fluxinit/static"
"github.com/influxdata/influxdb/v2/query/fluxlang"
"github.com/influxdata/influxdb/v2/task/options"
"github.com/influxdata/influxdb/v2/task/servicetest"
Expand Down
2 changes: 1 addition & 1 deletion notification/rule/service/service_test.go
Expand Up @@ -14,7 +14,7 @@ import (
"github.com/influxdata/influxdb/v2/kv/migration/all"
"github.com/influxdata/influxdb/v2/mock"
endpointservice "github.com/influxdata/influxdb/v2/notification/endpoint/service"
_ "github.com/influxdata/influxdb/v2/query/builtin"
_ "github.com/influxdata/influxdb/v2/fluxinit/static"
"github.com/influxdata/influxdb/v2/query/fluxlang"
"github.com/influxdata/influxdb/v2/tenant"
"go.uber.org/zap/zaptest"
Expand Down
15 changes: 0 additions & 15 deletions query/builtin/builtin.go

This file was deleted.

2 changes: 1 addition & 1 deletion query/control/controller_test.go
Expand Up @@ -23,7 +23,7 @@ import (
"github.com/influxdata/influxdb/v2/kit/feature"
pmock "github.com/influxdata/influxdb/v2/mock"
"github.com/influxdata/influxdb/v2/query"
_ "github.com/influxdata/influxdb/v2/query/builtin"
_ "github.com/influxdata/influxdb/v2/fluxinit/static"
"github.com/influxdata/influxdb/v2/query/control"
"github.com/influxdata/influxdb/v2/query/stdlib/influxdata/influxdb"
"github.com/opentracing/opentracing-go"
Expand Down
2 changes: 1 addition & 1 deletion query/influxql/end_to_end_test.go
Expand Up @@ -19,7 +19,7 @@ import (
platform "github.com/influxdata/influxdb/v2"
"github.com/influxdata/influxdb/v2/mock"
"github.com/influxdata/influxdb/v2/query"
_ "github.com/influxdata/influxdb/v2/query/builtin"
_ "github.com/influxdata/influxdb/v2/fluxinit/static"
"github.com/influxdata/influxdb/v2/query/influxql"
"github.com/influxdata/influxdb/v2/query/querytest"
platformtesting "github.com/influxdata/influxdb/v2/testing"
Expand Down
2 changes: 1 addition & 1 deletion query/promql/internal/promqltests/end_to_end_test.go
Expand Up @@ -3,7 +3,7 @@ package promqltests
import (
"testing"

_ "github.com/influxdata/influxdb/v2/query/builtin"
_ "github.com/influxdata/influxdb/v2/fluxinit/static"
)

func TestPromQLEndToEnd(t *testing.T) {
Expand Down
2 changes: 1 addition & 1 deletion query/stdlib/experimental/to_test.go
Expand Up @@ -15,7 +15,7 @@ import (
platform "github.com/influxdata/influxdb/v2"
"github.com/influxdata/influxdb/v2/mock"
"github.com/influxdata/influxdb/v2/models"
_ "github.com/influxdata/influxdb/v2/query/builtin"
_ "github.com/influxdata/influxdb/v2/fluxinit/static"
"github.com/influxdata/influxdb/v2/query/stdlib/experimental"
"github.com/influxdata/influxdb/v2/query/stdlib/influxdata/influxdb"
)
Expand Down
2 changes: 1 addition & 1 deletion query/stdlib/influxdata/influxdb/to_test.go
Expand Up @@ -14,7 +14,7 @@ import (
"github.com/influxdata/flux/values/valuestest"
"github.com/influxdata/influxdb/v2/mock"
"github.com/influxdata/influxdb/v2/models"
_ "github.com/influxdata/influxdb/v2/query/builtin"
_ "github.com/influxdata/influxdb/v2/fluxinit/static"
"github.com/influxdata/influxdb/v2/query/stdlib/influxdata/influxdb"
)

Expand Down
2 changes: 1 addition & 1 deletion task/backend/analytical_storage_test.go
Expand Up @@ -17,7 +17,7 @@ import (
"github.com/influxdata/influxdb/v2/kv/migration/all"
"github.com/influxdata/influxdb/v2/mock"
"github.com/influxdata/influxdb/v2/query"
_ "github.com/influxdata/influxdb/v2/query/builtin"
_ "github.com/influxdata/influxdb/v2/fluxinit/static"
"github.com/influxdata/influxdb/v2/query/control"
"github.com/influxdata/influxdb/v2/query/fluxlang"
stdlib "github.com/influxdata/influxdb/v2/query/stdlib/influxdata/influxdb"
Expand Down
2 changes: 1 addition & 1 deletion task/backend/executor/support_test.go
Expand Up @@ -17,7 +17,7 @@ import (
"github.com/influxdata/influxdb/v2"
"github.com/influxdata/influxdb/v2/kv"
"github.com/influxdata/influxdb/v2/query"
_ "github.com/influxdata/influxdb/v2/query/builtin"
_ "github.com/influxdata/influxdb/v2/fluxinit/static"
)

type fakeQueryService struct {
Expand Down
2 changes: 1 addition & 1 deletion task/backend/middleware/middleware_test.go
Expand Up @@ -9,7 +9,7 @@ import (

"github.com/influxdata/influxdb/v2"
pmock "github.com/influxdata/influxdb/v2/mock"
_ "github.com/influxdata/influxdb/v2/query/builtin"
_ "github.com/influxdata/influxdb/v2/fluxinit/static"
"github.com/influxdata/influxdb/v2/snowflake"
"github.com/influxdata/influxdb/v2/task/backend"
"github.com/influxdata/influxdb/v2/task/backend/coordinator"
Expand Down
2 changes: 1 addition & 1 deletion task/options/options_test.go
Expand Up @@ -11,7 +11,7 @@ import (
"github.com/google/go-cmp/cmp/cmpopts"
"github.com/influxdata/flux/ast"
"github.com/influxdata/influxdb/v2/pkg/pointer"
_ "github.com/influxdata/influxdb/v2/query/builtin"
_ "github.com/influxdata/influxdb/v2/fluxinit/static"
"github.com/influxdata/influxdb/v2/query/fluxlang"
"github.com/influxdata/influxdb/v2/task/options"
)
Expand Down
2 changes: 1 addition & 1 deletion task_test.go
Expand Up @@ -9,7 +9,7 @@ import (
platform "github.com/influxdata/influxdb/v2"
"github.com/influxdata/influxdb/v2/kit/feature"
"github.com/influxdata/influxdb/v2/mock"
_ "github.com/influxdata/influxdb/v2/query/builtin"
_ "github.com/influxdata/influxdb/v2/fluxinit/static"
"github.com/influxdata/influxdb/v2/query/fluxlang"
"github.com/influxdata/influxdb/v2/task/options"
)
Expand Down