fix(cmd): switch default port from 9999 to 8086

cmd/flux/cmd/execute.go

@@ -25,7 +25,7 @@ func init() {
 	rootCmd.AddCommand(executeCmd)
 }
 
-const DefaultInfluxDBHost = "http://localhost:9999"
+const DefaultInfluxDBHost = "http://localhost:8086"
 
 func injectDependencies(ctx context.Context) (context.Context, flux.Dependencies) {
 	deps := flux.NewDefaultDependencies()

colm/influxql/run

@@ -43,7 +43,7 @@ cat $FLUX
 curl -s \
 	-H "Authorization: Token $TOKEN" \
 	-H "Content-Type: application/vnd.flux" \
-	"http://localhost:9999/api/v2/query?org=$ORG" \
+	"http://localhost:8086/api/v2/query?org=$ORG" \
 	--data-binary "@$FLUX"
 echo
 

colm/tableflux/run

@@ -68,7 +68,7 @@ case "$1" in
 		curl -s \
 			-H "Authorization: Token $TOKEN" \
 			-H "Content-Type: application/vnd.flux" \
-			"http://localhost:9999/api/v2/query?org=$ORG" \
+			"http://localhost:8086/api/v2/query?org=$ORG" \
 			--data-binary "@$QUERY" > $RESPONSE
 		if head -1 $RESPONSE | grep -q '^{'; then
 			cat $RESPONSE

docs/SPEC.md

@@ -345,7 +345,7 @@ Regular expression literals support only the following escape sequences:
 Examples:
 
     /.*/
-    /http:\/\/localhost:9999/
+    /http:\/\/localhost:8086/
     /^\xe6\x97\xa5\xe6\x9c\xac\xe8\xaa\x9e(ZZ)?$/
     /^日本語(ZZ)?$/ // the above two lines are equivalent
     /\\xZZ/ // this becomes the literal pattern "\xZZ"

lang/compiler_test.go

@@ -38,7 +38,7 @@ func init() {
 	plan.RegisterLogicalRules(
 		influxdb.DefaultFromAttributes{
 			Org:  &influxdb.NameOrID{Name: "influxdata"},
-			Host: func(v string) *string { return &v }("http://localhost:9999"),
+			Host: func(v string) *string { return &v }("http://localhost:8086"),
 		},
 	)
 }

plan/logical_test.go

@@ -58,7 +58,7 @@ func TestPlan_LogicalPlanFromSpec(t *testing.T) {
 		fromSpec = &influxdb.FromProcedureSpec{
 			Org:    &influxdb.NameOrID{Name: "influxdata"},
 			Bucket: influxdb.NameOrID{Name: "my-bucket"},
-			Host:   func(v string) *string { return &v }("http://localhost:9999"),
+			Host:   func(v string) *string { return &v }("http://localhost:8086"),
 		}
 		rangeSpec = &universe.RangeProcedureSpec{
 			Bounds: flux.Bounds{

plan/rules_test.go

@@ -22,7 +22,7 @@ func init() {
 	plan.RegisterLogicalRules(
 		influxdb.DefaultFromAttributes{
 			Org:  &influxdb.NameOrID{Name: "influxdata"},
-			Host: func(v string) *string { return &v }("http://localhost:9999"),
+			Host: func(v string) *string { return &v }("http://localhost:8086"),
 		},
 	)
 }
@@ -38,7 +38,7 @@ func TestRuleRegistration(t *testing.T) {
 
 	now := time.Now().UTC()
 	fluxSpec, err := spec.FromScript(dependenciestest.Default().Inject(context.Background()), runtime.Default, now,
-		`from(host: "http://localhost:9999", bucket: "telegraf") |> range(start: -5m)`)
+		`from(host: "http://localhost:8086", bucket: "telegraf") |> range(start: -5m)`)
 	if err != nil {
 		t.Fatalf("could not compile very simple Flux query: %v", err)
 	}
@@ -99,7 +99,7 @@ func TestRewriteWithContext(t *testing.T) {
 
 	now := time.Now().UTC()
 	fluxSpec, err := spec.FromScript(dependenciestest.Default().Inject(ctx), runtime.Default, now,
-		`from(host: "http://localhost:9999", bucket: "telegraf") |> range(start: -5m)`)
+		`from(host: "http://localhost:8086", bucket: "telegraf") |> range(start: -5m)`)
 	if err != nil {
 		t.Fatalf("could not compile very simple Flux query: %v", err)
 	}
@@ -164,7 +164,7 @@ func TestRewriteWithContext_TableObjectCompiler(t *testing.T) {
 	prelude := runtime.Prelude()
 	buckets, _ := prelude.Lookup("buckets")
 	args := values.NewObjectWithValues(map[string]values.Value{
-		"host": values.NewString("http://localhost:9999"),
+		"host": values.NewString("http://localhost:8086"),
 	})
 	res, err := buckets.Function().Call(ctx, args)
 	if err != nil {
@@ -196,7 +196,7 @@ func TestMultiRootMatch(t *testing.T) {
 
 	now := time.Now().UTC()
 	fluxSpec, err := spec.FromScript(dependenciestest.Default().Inject(context.Background()), runtime.Default, now,
-		`from(host: "http://localhost:9999", bucket: "telegraf") |> range(start: -5m) |> min() |> max() |> mean()`)
+		`from(host: "http://localhost:8086", bucket: "telegraf") |> range(start: -5m) |> min() |> max() |> mean()`)
 	if err != nil {
 		t.Fatalf("could not compile very simple Flux query: %v", err)
 	}
@@ -234,7 +234,7 @@ func TestExpectPlannerRule(t *testing.T) {
 
 	now := time.Now().UTC()
 	fluxSpec, err := spec.FromScript(dependenciestest.Default().Inject(context.Background()), runtime.Default, now,
-		`from(host: "http://localhost:9999", bucket: "telegraf") |> range(start: -5m) |> min() |> max() |> mean()`)
+		`from(host: "http://localhost:8086", bucket: "telegraf") |> range(start: -5m) |> min() |> max() |> mean()`)
 	if err != nil {
 		t.Fatalf("could not compile very simple Flux query: %v", err)
 	}

stdlib/contrib/RohanSreerama5/naiveBayesClassifier/README.md

@@ -8,7 +8,7 @@ Steps:
 Prerequesites: InfluxDB 2.0 (local or Cloud instance), this repo (includes zoo-data.csv, script.py and naiveBayesClassifier.flux) 
 InfluxDB: https://github.com/influxdata/influxdb
 
-1) Ensure you have InfluxDB 2.0 set up by either going to localhost:9999 (if you `make` InfluxDB from source) or going to your Cloud instance on AWS, Azure, etc. Keep the instance running throughout this demo.  
+1) Ensure you have InfluxDB 2.0 set up by either going to localhost:8086 (if you `make` InfluxDB from source) or going to your Cloud instance on AWS, Azure, etc. Keep the instance running throughout this demo.  
 2) Choose a binary dataset (fields can only take on 2 unique values) or visit https://archive.ics.uci.edu/ml/datasets.php for some wonderful datasets you can get started with. 
 
 [Animal dataset](zoo_data.csv)

stdlib/contrib/RohanSreerama5/naiveBayesClassifier/script.py

@@ -52,7 +52,7 @@
 from influxdb_client import InfluxDBClient, Point, WriteOptions
 from influxdb_client.client.write_api import SYNCHRONOUS
 
-client = InfluxDBClient(url="http://localhost:9999", token=token, org=org, debug=False)
+client = InfluxDBClient(url="http://localhost:8086", token=token, org=org, debug=False)
 write_client = client.write_api(write_options=SYNCHRONOUS)
 
 write_client.write(bucket, record=mydata, data_frame_measurement_name='zoo-data',

stdlib/influxdata/influxdb/buckets_test.go

@@ -32,13 +32,13 @@ func TestBuckets_NewQuery(t *testing.T) {
 		},
 		{
 			Name: "buckets with host and token",
-			Raw:  `buckets(host: "http://localhost:9999", token: "mytoken")`,
+			Raw:  `buckets(host: "http://localhost:8086", token: "mytoken")`,
 			Want: &flux.Spec{
 				Operations: []*flux.Operation{
 					{
 						ID: "buckets0",
 						Spec: &influxdb.BucketsOpSpec{
-							Host:  stringPtr("http://localhost:9999"),
+							Host:  stringPtr("http://localhost:8086"),
 							Token: stringPtr("mytoken"),
 						},
 					},

stdlib/influxdata/influxdb/cardinality_test.go

@@ -65,15 +65,15 @@ func TestCardinality_NewQuery(t *testing.T) {
 		},
 		{
 			Name: "cardinality with host and token",
-			Raw:  `influxdb.cardinality(bucket:"mybucket", host: "http://localhost:9999", token: "mytoken", start: -2h)`,
+			Raw:  `influxdb.cardinality(bucket:"mybucket", host: "http://localhost:8086", token: "mytoken", start: -2h)`,
 			Want: &flux.Spec{
 				Operations: []*flux.Operation{
 					{
 						ID: "influxdata/influxdb.cardinality0",
 						Spec: &influxdb.CardinalityOpSpec{
 							Config: influxdb.Config{
 								Bucket: influxdb.NameOrID{Name: "mybucket"},
-								Host:   "http://localhost:9999",
+								Host:   "http://localhost:8086",
 								Token:  "mytoken",
 							},
 							Start: flux.Time{

stdlib/influxdata/influxdb/from_test.go

@@ -72,14 +72,14 @@ func TestFrom_NewQuery(t *testing.T) {
 		},
 		{
 			Name: "from with host and token",
-			Raw:  `from(bucket:"mybucket", host: "http://localhost:9999", token: "mytoken")`,
+			Raw:  `from(bucket:"mybucket", host: "http://localhost:8086", token: "mytoken")`,
 			Want: &flux.Spec{
 				Operations: []*flux.Operation{
 					{
 						ID: "from0",
 						Spec: &influxdb.FromOpSpec{
 							Bucket: influxdb.NameOrID{Name: "mybucket"},
-							Host:   stringPtr("http://localhost:9999"),
+							Host:   stringPtr("http://localhost:8086"),
 							Token:  stringPtr("mytoken"),
 						},
 					},

stdlib/influxdata/influxdb/rules_test.go

@@ -99,7 +99,7 @@ func TestFromRemoteRule_WithHost(t *testing.T) {
 	fromSpec := influxdb.FromProcedureSpec{
 		Org:    &influxdb.NameOrID{Name: "influxdata"},
 		Bucket: influxdb.NameOrID{Name: "telegraf"},
-		Host:   stringPtr("http://localhost:9999"),
+		Host:   stringPtr("http://localhost:8086"),
 	}
 	rangeSpec := universe.RangeProcedureSpec{
 		Bounds: flux.Bounds{
@@ -212,7 +212,7 @@ func TestFromRemoteRule_WithoutRangeValidation(t *testing.T) {
 	fromSpec := influxdb.FromProcedureSpec{
 		Org:    &influxdb.NameOrID{Name: "influxdata"},
 		Bucket: influxdb.NameOrID{Name: "telegraf"},
-		Host:   stringPtr("http://localhost:9999"),
+		Host:   stringPtr("http://localhost:8086"),
 	}
 
 	tc := plantest.RuleTestCase{
@@ -239,7 +239,7 @@ func TestMergeRemoteRangeRule(t *testing.T) {
 
 	fromSpec := influxdb.FromProcedureSpec{
 		Bucket: influxdb.NameOrID{Name: "telegraf"},
-		Host:   stringPtr("http://localhost:9999"),
+		Host:   stringPtr("http://localhost:8086"),
 	}
 	rangeSpec := universe.RangeProcedureSpec{
 		Bounds: flux.Bounds{
@@ -291,7 +291,7 @@ func TestMergeRemoteFilterRule(t *testing.T) {
 
 	fromSpec := influxdb.FromProcedureSpec{
 		Bucket: influxdb.NameOrID{Name: "telegraf"},
-		Host:   stringPtr("http://localhost:9999"),
+		Host:   stringPtr("http://localhost:8086"),
 	}
 	rangeSpec := universe.RangeProcedureSpec{
 		Bounds: flux.Bounds{
@@ -356,7 +356,7 @@ func TestDefaultFromAttributes(t *testing.T) {
 			Rules: []plan.Rule{
 				influxdb.DefaultFromAttributes{
 					Org:   &influxdb.NameOrID{Name: "influxdata"},
-					Host:  stringPtr("http://localhost:9999"),
+					Host:  stringPtr("http://localhost:8086"),
 					Token: stringPtr("mytoken"),
 				},
 			},
@@ -372,7 +372,7 @@ func TestDefaultFromAttributes(t *testing.T) {
 					plan.CreateLogicalNode("from", &influxdb.FromProcedureSpec{
 						Org:    &influxdb.NameOrID{Name: "influxdata"},
 						Bucket: influxdb.NameOrID{Name: "telegraf"},
-						Host:   stringPtr("http://localhost:9999"),
+						Host:   stringPtr("http://localhost:8086"),
 						Token:  stringPtr("mytoken"),
 					}),
 				},
@@ -383,7 +383,7 @@ func TestDefaultFromAttributes(t *testing.T) {
 			Rules: []plan.Rule{
 				influxdb.DefaultFromAttributes{
 					Org:   &influxdb.NameOrID{Name: "influxdata"},
-					Host:  stringPtr("http://localhost:9999"),
+					Host:  stringPtr("http://localhost:8086"),
 					Token: stringPtr("mytoken"),
 				},
 			},
@@ -392,7 +392,7 @@ func TestDefaultFromAttributes(t *testing.T) {
 					plan.CreateLogicalNode("from", &influxdb.FromProcedureSpec{
 						Org:    &influxdb.NameOrID{Name: "alternate_org"},
 						Bucket: influxdb.NameOrID{Name: "telegraf"},
-						Host:   stringPtr("http://mysupersecretserver:9999"),
+						Host:   stringPtr("http://mysupersecretserver:8086"),
 						Token:  stringPtr("differenttoken"),
 					}),
 				},
@@ -402,7 +402,7 @@ func TestDefaultFromAttributes(t *testing.T) {
 					plan.CreateLogicalNode("from", &influxdb.FromProcedureSpec{
 						Org:    &influxdb.NameOrID{Name: "alternate_org"},
 						Bucket: influxdb.NameOrID{Name: "telegraf"},
-						Host:   stringPtr("http://mysupersecretserver:9999"),
+						Host:   stringPtr("http://mysupersecretserver:8086"),
 						Token:  stringPtr("differenttoken"),
 					}),
 				},
@@ -413,7 +413,7 @@ func TestDefaultFromAttributes(t *testing.T) {
 			Rules: []plan.Rule{
 				influxdb.FromRemoteRule{},
 				influxdb.DefaultFromAttributes{
-					Host: stringPtr("http://localhost:9999"),
+					Host: stringPtr("http://localhost:8086"),
 				},
 			},
 			Before: &plantest.PlanSpec{
@@ -428,7 +428,7 @@ func TestDefaultFromAttributes(t *testing.T) {
 					plan.CreatePhysicalNode("fromRemote", &influxdb.FromRemoteProcedureSpec{
 						Config: influxdb.Config{
 							Bucket: influxdb.NameOrID{Name: "telegraf"},
-							Host:   "http://localhost:9999",
+							Host:   "http://localhost:8086",
 						},
 					}),
 				},

stdlib/influxdata/influxdb/v1/databases_test.go

@@ -36,13 +36,13 @@ v1.databases(chicken:"what is this?")`,
 		{
 			Name: "databases with host and token",
 			Raw: `import "influxdata/influxdb/v1"
-v1.databases(host: "http://localhost:9999", token: "mytoken")`,
+v1.databases(host: "http://localhost:8086", token: "mytoken")`,
 			Want: &flux.Spec{
 				Operations: []*flux.Operation{
 					{
 						ID: "databases0",
 						Spec: &v1.DatabasesOpSpec{
-							Host:  stringPtr("http://localhost:9999"),
+							Host:  stringPtr("http://localhost:8086"),
 							Token: stringPtr("mytoken"),
 						},
 					},