add license header (#7197)

alert/app/app.go

+/*
+ * Copyright (c) 2019 TAOS Data, Inc. <jhtao@taosdata.com>
+ *
+ * This program is free software: you can use, redistribute, and/or modify
+ * it under the terms of the GNU Affero General Public License, version 3
+ * or later ("AGPL"), as published by the Free Software Foundation.
+ *
+ * This program is distributed in the hope that it will be useful, but WITHOUT
+ * ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or
+ * FITNESS FOR A PARTICULAR PURPOSE.
+ *
+ * You should have received a copy of the GNU Affero General Public License
+ * along with this program. If not, see <http://www.gnu.org/licenses/>.
+ */
+
 package app
 
 import (

alert/app/expr/expr.go

+/*
+ * Copyright (c) 2019 TAOS Data, Inc. <jhtao@taosdata.com>
+ *
+ * This program is free software: you can use, redistribute, and/or modify
+ * it under the terms of the GNU Affero General Public License, version 3
+ * or later ("AGPL"), as published by the Free Software Foundation.
+ *
+ * This program is distributed in the hope that it will be useful, but WITHOUT
+ * ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or
+ * FITNESS FOR A PARTICULAR PURPOSE.
+ *
+ * You should have received a copy of the GNU Affero General Public License
+ * along with this program. If not, see <http://www.gnu.org/licenses/>.
+ */
+
 package expr
 
 import (

alert/app/expr/expr_test.go

+/*
+ * Copyright (c) 2019 TAOS Data, Inc. <jhtao@taosdata.com>
+ *
+ * This program is free software: you can use, redistribute, and/or modify
+ * it under the terms of the GNU Affero General Public License, version 3
+ * or later ("AGPL"), as published by the Free Software Foundation.
+ *
+ * This program is distributed in the hope that it will be useful, but WITHOUT
+ * ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or
+ * FITNESS FOR A PARTICULAR PURPOSE.
+ *
+ * You should have received a copy of the GNU Affero General Public License
+ * along with this program. If not, see <http://www.gnu.org/licenses/>.
+ */
+
 package expr
 
 import "testing"

alert/app/expr/funcs.go

+/*
+ * Copyright (c) 2019 TAOS Data, Inc. <jhtao@taosdata.com>
+ *
+ * This program is free software: you can use, redistribute, and/or modify
+ * it under the terms of the GNU Affero General Public License, version 3
+ * or later ("AGPL"), as published by the Free Software Foundation.
+ *
+ * This program is distributed in the hope that it will be useful, but WITHOUT
+ * ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or
+ * FITNESS FOR A PARTICULAR PURPOSE.
+ *
+ * You should have received a copy of the GNU Affero General Public License
+ * along with this program. If not, see <http://www.gnu.org/licenses/>.
+ */
+
 package expr
 
 import (

alert/app/expr/funcs_test.go

+/*
+ * Copyright (c) 2019 TAOS Data, Inc. <jhtao@taosdata.com>
+ *
+ * This program is free software: you can use, redistribute, and/or modify
+ * it under the terms of the GNU Affero General Public License, version 3
+ * or later ("AGPL"), as published by the Free Software Foundation.
+ *
+ * This program is distributed in the hope that it will be useful, but WITHOUT
+ * ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or
+ * FITNESS FOR A PARTICULAR PURPOSE.
+ *
+ * You should have received a copy of the GNU Affero General Public License
+ * along with this program. If not, see <http://www.gnu.org/licenses/>.
+ */
+
 package expr
 
 import (

alert/app/route.go

+/*
+ * Copyright (c) 2019 TAOS Data, Inc. <jhtao@taosdata.com>
+ *
+ * This program is free software: you can use, redistribute, and/or modify
+ * it under the terms of the GNU Affero General Public License, version 3
+ * or later ("AGPL"), as published by the Free Software Foundation.
+ *
+ * This program is distributed in the hope that it will be useful, but WITHOUT
+ * ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or
+ * FITNESS FOR A PARTICULAR PURPOSE.
+ *
+ * You should have received a copy of the GNU Affero General Public License
+ * along with this program. If not, see <http://www.gnu.org/licenses/>.
+ */
+
 package app
 
 import (

alert/app/rule.go

+/*
+ * Copyright (c) 2019 TAOS Data, Inc. <jhtao@taosdata.com>
+ *
+ * This program is free software: you can use, redistribute, and/or modify
+ * it under the terms of the GNU Affero General Public License, version 3
+ * or later ("AGPL"), as published by the Free Software Foundation.
+ *
+ * This program is distributed in the hope that it will be useful, but WITHOUT
+ * ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or
+ * FITNESS FOR A PARTICULAR PURPOSE.
+ *
+ * You should have received a copy of the GNU Affero General Public License
+ * along with this program. If not, see <http://www.gnu.org/licenses/>.
+ */
+
 package app
 
 import (

alert/app/rule_test.go

+/*
+ * Copyright (c) 2019 TAOS Data, Inc. <jhtao@taosdata.com>
+ *
+ * This program is free software: you can use, redistribute, and/or modify
+ * it under the terms of the GNU Affero General Public License, version 3
+ * or later ("AGPL"), as published by the Free Software Foundation.
+ *
+ * This program is distributed in the hope that it will be useful, but WITHOUT
+ * ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or
+ * FITNESS FOR A PARTICULAR PURPOSE.
+ *
+ * You should have received a copy of the GNU Affero General Public License
+ * along with this program. If not, see <http://www.gnu.org/licenses/>.
+ */
+
 package app
 
 import (

alert/cmd/alert/main.go

+/*
+ * Copyright (c) 2019 TAOS Data, Inc. <jhtao@taosdata.com>
+ *
+ * This program is free software: you can use, redistribute, and/or modify
+ * it under the terms of the GNU Affero General Public License, version 3
+ * or later ("AGPL"), as published by the Free Software Foundation.
+ *
+ * This program is distributed in the hope that it will be useful, but WITHOUT
+ * ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or
+ * FITNESS FOR A PARTICULAR PURPOSE.
+ *
+ * You should have received a copy of the GNU Affero General Public License
+ * along with this program. If not, see <http://www.gnu.org/licenses/>.
+ */
+
 package main
 
 import (

alert/models/models.go

+/*
+ * Copyright (c) 2019 TAOS Data, Inc. <jhtao@taosdata.com>
+ *
+ * This program is free software: you can use, redistribute, and/or modify
+ * it under the terms of the GNU Affero General Public License, version 3
+ * or later ("AGPL"), as published by the Free Software Foundation.
+ *
+ * This program is distributed in the hope that it will be useful, but WITHOUT
+ * ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or
+ * FITNESS FOR A PARTICULAR PURPOSE.
+ *
+ * You should have received a copy of the GNU Affero General Public License
+ * along with this program. If not, see <http://www.gnu.org/licenses/>.
+ */
+
 package models
 
 import (

alert/models/rule.go

+/*
+ * Copyright (c) 2019 TAOS Data, Inc. <jhtao@taosdata.com>
+ *
+ * This program is free software: you can use, redistribute, and/or modify
+ * it under the terms of the GNU Affero General Public License, version 3
+ * or later ("AGPL"), as published by the Free Software Foundation.
+ *
+ * This program is distributed in the hope that it will be useful, but WITHOUT
+ * ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or
+ * FITNESS FOR A PARTICULAR PURPOSE.
+ *
+ * You should have received a copy of the GNU Affero General Public License
+ * along with this program. If not, see <http://www.gnu.org/licenses/>.
+ */
+
 package models
 
 import "time"

alert/utils/config.go

+/*
+ * Copyright (c) 2019 TAOS Data, Inc. <jhtao@taosdata.com>
+ *
+ * This program is free software: you can use, redistribute, and/or modify
+ * it under the terms of the GNU Affero General Public License, version 3
+ * or later ("AGPL"), as published by the Free Software Foundation.
+ *
+ * This program is distributed in the hope that it will be useful, but WITHOUT
+ * ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or
+ * FITNESS FOR A PARTICULAR PURPOSE.
+ *
+ * You should have received a copy of the GNU Affero General Public License
+ * along with this program. If not, see <http://www.gnu.org/licenses/>.
+ */
+
 package utils
 
 import (

alert/utils/log/log.go

+/*
+ * Copyright (c) 2019 TAOS Data, Inc. <jhtao@taosdata.com>
+ *
+ * This program is free software: you can use, redistribute, and/or modify
+ * it under the terms of the GNU Affero General Public License, version 3
+ * or later ("AGPL"), as published by the Free Software Foundation.
+ *
+ * This program is distributed in the hope that it will be useful, but WITHOUT
+ * ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or
+ * FITNESS FOR A PARTICULAR PURPOSE.
+ *
+ * You should have received a copy of the GNU Affero General Public License
+ * along with this program. If not, see <http://www.gnu.org/licenses/>.
+ */
+
 package log
 
 import (

importSampleData/app/main.go

+/*
+ * Copyright (c) 2019 TAOS Data, Inc. <jhtao@taosdata.com>
+ *
+ * This program is free software: you can use, redistribute, and/or modify
+ * it under the terms of the GNU Affero General Public License, version 3
+ * or later ("AGPL"), as published by the Free Software Foundation.
+ *
+ * This program is distributed in the hope that it will be useful, but WITHOUT
+ * ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or
+ * FITNESS FOR A PARTICULAR PURPOSE.
+ *
+ * You should have received a copy of the GNU Affero General Public License
+ * along with this program. If not, see <http://www.gnu.org/licenses/>.
+ */
+
 package main
 
 import (

importSampleData/import/import_config.go

+/*
+ * Copyright (c) 2019 TAOS Data, Inc. <jhtao@taosdata.com>
+ *
+ * This program is free software: you can use, redistribute, and/or modify
+ * it under the terms of the GNU Affero General Public License, version 3
+ * or later ("AGPL"), as published by the Free Software Foundation.
+ *
+ * This program is distributed in the hope that it will be useful, but WITHOUT
+ * ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or
+ * FITNESS FOR A PARTICULAR PURPOSE.
+ *
+ * You should have received a copy of the GNU Affero General Public License
+ * along with this program. If not, see <http://www.gnu.org/licenses/>.
+ */
+
 package dataimport
 
 import (

src/connector/odbc/examples/go/odbc.go

+/*
+ * Copyright (c) 2019 TAOS Data, Inc. <jhtao@taosdata.com>
+ *
+ * This program is free software: you can use, redistribute, and/or modify
+ * it under the terms of the GNU Affero General Public License, version 3
+ * or later ("AGPL"), as published by the Free Software Foundation.
+ *
+ * This program is distributed in the hope that it will be useful, but WITHOUT
+ * ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or
+ * FITNESS FOR A PARTICULAR PURPOSE.
+ *
+ * You should have received a copy of the GNU Affero General Public License
+ * along with this program. If not, see <http://www.gnu.org/licenses/>.
+ */
+
 package main
 
 import (

tests/comparisonTest/influxdb/main.go

+/*
+ * Copyright (c) 2019 TAOS Data, Inc. <jhtao@taosdata.com>
+ *
+ * This program is free software: you can use, redistribute, and/or modify
+ * it under the terms of the GNU Affero General Public License, version 3
+ * or later ("AGPL"), as published by the Free Software Foundation.
+ *
+ * This program is distributed in the hope that it will be useful, but WITHOUT
+ * ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or
+ * FITNESS FOR A PARTICULAR PURPOSE.
+ *
+ * You should have received a copy of the GNU Affero General Public License
+ * along with this program. If not, see <http://www.gnu.org/licenses/>.
+ */
+
 package main
 
 import (

tests/gotest/case001/case001.go

@@ -12,6 +12,7 @@
  * You should have received a copy of the GNU Affero General Public License
  * along with this program. If not, see <http://www.gnu.org/licenses/>.
  */
+
 package main
 
 import (

tests/script/general/http/bug.go

+/*
+ * Copyright (c) 2019 TAOS Data, Inc. <jhtao@taosdata.com>
+ *
+ * This program is free software: you can use, redistribute, and/or modify
+ * it under the terms of the GNU Affero General Public License, version 3
+ * or later ("AGPL"), as published by the Free Software Foundation.
+ *
+ * This program is distributed in the hope that it will be useful, but WITHOUT
+ * ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or
+ * FITNESS FOR A PARTICULAR PURPOSE.
+ *
+ * You should have received a copy of the GNU Affero General Public License
+ * along with this program. If not, see <http://www.gnu.org/licenses/>.
+ */
+
 package main
 
 import (
@@ -184,7 +199,7 @@ func exec(client *http.Client, sql string) {
 		if (request < 103) {
 			return
 		}
-		
+
 		atomic.AddInt64(&period, spend)
 		if request%5000 == 0 && request != 0 {
 			requestAvg := float64(period) / float64(1000000) / float64(request)
@@ -204,7 +219,7 @@ func insertTable(conn int) {
 	tbStart := conn*config.TablePerConn + config.TableStart
 	tmStart := config.DataBegin
 
-	
+
 	for j := 0; j < config.DataNum; j++ {
 		for i := 0; i < config.TablePerConn; i++ {
 			tmVal := int64(j)*int64(config.DataInterval) + tmStart + 1
@@ -214,7 +229,7 @@ func insertTable(conn int) {
 			if config.DataRandom {
 				dataVal = rand.Intn(1000)
 			}
-			
+
 			sql := fmt.Sprintf("import into %s.%s%d values(%d, %d)", config.DbName, config.TablePrefix, tbIndex, tmVal, dataVal)
 			exec(client, sql)
 			time.Sleep(time.Millisecond * time.Duration(10))
@@ -282,7 +297,7 @@ func selectData(wg *sync.WaitGroup, conn int) {
 
 	client := &http.Client{}
 
-	
+
 	tbStart := conn*config.TablePerConn + config.TableStart
 	for j := 0; j < config.DataNum; j++ {
 		tbIndex := 0 + tbStart
@@ -292,10 +307,10 @@ func selectData(wg *sync.WaitGroup, conn int) {
 			sql += fmt.Sprintf(",'%s%d'", config.TablePrefix, tbIndex)
 		}
 		sql += ") group by orgno"
-		
+
 		//sql := fmt.Sprintf("select count(*) from db.mt")
 		//sql := fmt.Sprintf("select max(i),min(i) from db.mt", config.TablePrefix, tbIndex)
-		
+
 		exec(client, sql)
 		time.Sleep(time.Millisecond * time.Duration(10))
 	}
@@ -303,17 +318,17 @@ func selectData(wg *sync.WaitGroup, conn int) {
 
 func main() {
 	filename := flag.String("config", "taos_cloud.json", "config file name")
-	
+
 	flag.Parse()
-	
+
 	readFile(*filename)
-	
+
 	fmt.Println("\n================http test start======================")
 
 	var wg sync.WaitGroup
 
 	fmt.Println("\n================select data  ========================")
-	
+
 
 	for i := 0; i < config.ConnNum; i++ {
 		wg.Add(1)

tests/script/general/http/httpTestNew.go

+/*
+ * Copyright (c) 2019 TAOS Data, Inc. <jhtao@taosdata.com>
+ *
+ * This program is free software: you can use, redistribute, and/or modify
+ * it under the terms of the GNU Affero General Public License, version 3
+ * or later ("AGPL"), as published by the Free Software Foundation.
+ *
+ * This program is distributed in the hope that it will be useful, but WITHOUT
+ * ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or
+ * FITNESS FOR A PARTICULAR PURPOSE.
+ *
+ * You should have received a copy of the GNU Affero General Public License
+ * along with this program. If not, see <http://www.gnu.org/licenses/>.
+ */
+
 package main
 
 import (

tests/script/general/http/httpTest_cloud.go

+/*
+ * Copyright (c) 2019 TAOS Data, Inc. <jhtao@taosdata.com>
+ *
+ * This program is free software: you can use, redistribute, and/or modify
+ * it under the terms of the GNU Affero General Public License, version 3
+ * or later ("AGPL"), as published by the Free Software Foundation.
+ *
+ * This program is distributed in the hope that it will be useful, but WITHOUT
+ * ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or
+ * FITNESS FOR A PARTICULAR PURPOSE.
+ *
+ * You should have received a copy of the GNU Affero General Public License
+ * along with this program. If not, see <http://www.gnu.org/licenses/>.
+ */
+
 package main
 
 import (
@@ -184,7 +199,7 @@ func exec(client *http.Client, sql string) {
 		if (request < 103) {
 			return
 		}
-		
+
 		atomic.AddInt64(&period, spend)
 		if request%5000 == 0 && request != 0 {
 			requestAvg := float64(period) / float64(1000000) / float64(request)
@@ -333,11 +348,11 @@ func selectData(wg *sync.WaitGroup, conn int) {
 
 func main() {
 	filename := flag.String("config", "taos_cloud.json", "config file name")
-	
+
 	flag.Parse()
-	
+
 	readFile(*filename)
-	
+
 	fmt.Println("\n================http test start======================")
 
 	var wg sync.WaitGroup

tests/script/general/http/httpTest_private.go

+/*
+ * Copyright (c) 2019 TAOS Data, Inc. <jhtao@taosdata.com>
+ *
+ * This program is free software: you can use, redistribute, and/or modify
+ * it under the terms of the GNU Affero General Public License, version 3
+ * or later ("AGPL"), as published by the Free Software Foundation.
+ *
+ * This program is distributed in the hope that it will be useful, but WITHOUT
+ * ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or
+ * FITNESS FOR A PARTICULAR PURPOSE.
+ *
+ * You should have received a copy of the GNU Affero General Public License
+ * along with this program. If not, see <http://www.gnu.org/licenses/>.
+ */
+
 package main
 
 import (
@@ -184,7 +199,7 @@ func exec(client *http.Client, sql string) {
 		if (request < 103) {
 			return
 		}
-		
+
 		atomic.AddInt64(&period, spend)
 		if request%5000 == 0 && request != 0 {
 			requestAvg := float64(period) / float64(1000000) / float64(request)
@@ -256,7 +271,7 @@ func insertTable(conn int) {
 				sql += fmt.Sprintf("(%d, %d)", tmVal, dataVal)
 			}
 
-			
+
 			exec(client, sql)
 			if config.WaitTime != 0 {
 				time.Sleep(time.Millisecond * time.Duration(config.WaitTime))
@@ -333,11 +348,11 @@ func selectData(wg *sync.WaitGroup, conn int) {
 
 func main() {
 	filename := flag.String("config", "taos_cloud.json", "config file name")
-	
+
 	flag.Parse()
-	
+
 	readFile(*filename)
-	
+
 	fmt.Println("\n================http test start======================")
 
 	var wg sync.WaitGroup

tests/script/general/http/telegrafTest.go

+/*
+ * Copyright (c) 2019 TAOS Data, Inc. <jhtao@taosdata.com>
+ *
+ * This program is free software: you can use, redistribute, and/or modify
+ * it under the terms of the GNU Affero General Public License, version 3
+ * or later ("AGPL"), as published by the Free Software Foundation.
+ *
+ * This program is distributed in the hope that it will be useful, but WITHOUT
+ * ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or
+ * FITNESS FOR A PARTICULAR PURPOSE.
+ *
+ * You should have received a copy of the GNU Affero General Public License
+ * along with this program. If not, see <http://www.gnu.org/licenses/>.
+ */
+
 package main
 
 import (
@@ -68,7 +83,7 @@ func readConf(filename string) {
 	fmt.Println("LoopNum:", config.LoopNum)
 	fmt.Println("dbName:", config.DbName)
 	fmt.Println("dataBegin:", config.DataBegin)
-	
+
 	fmt.Println("================http token=============================")
 	token, err = getToken()
 	url = fmt.Sprintf("http://%s:%d/telegraf/%s", config.HostIp, 6020, config.DbName)
@@ -90,9 +105,9 @@ func readReq(filename string) {
 	defer file.Close()
 
 	data, _ := ioutil.ReadAll(file)
-	
+
 	template = string(data[:])
- 
+
 	//fmt.Println(template)
 }
 
@@ -154,13 +169,13 @@ func exec(client *http.Client, sql string) {
 		var jsonResult JsonResult
 		err = json.Unmarshal(data, &jsonResult)
 		if err != nil {
-			fmt.Println("parse json error: ", string(data[:]))	
+			fmt.Println("parse json error: ", string(data[:]))
 			resp.Body.Close()
 			continue
 		}
 
-		
-		atomic.AddInt64(&request, 1)		
+
+		atomic.AddInt64(&request, 1)
 		atomic.AddInt64(&period, spend)
 
 		if request%1000 == 0 && request != 0 {
@@ -179,16 +194,16 @@ func exec(client *http.Client, sql string) {
 func writeData(wg *sync.WaitGroup, tbIndex int) {
 	defer wg.Done()
 	client := &http.Client{}
-	
+
 	tbName := fmt.Sprintf("t%d", tbIndex)
-	
+
 	for j := 0; j < config.LoopNum; j++ {
 		tmVal := fmt.Sprintf("%d", int64(j)*int64(10000) + config.DataBegin)
 		//fmt.Println(tmVal)
 
 		req1 := strings.Replace(template, "panshi-gsl", tbName, -1)
 		req2 := strings.Replace(req1, "1536750390000", tmVal, -1)
-		
+
 		//fmt.Println(req2)
 		exec(client, req2)
 	}
@@ -196,17 +211,17 @@ func writeData(wg *sync.WaitGroup, tbIndex int) {
 
 func main() {
 	filename := flag.String("config", "telegraf.json", "config file name")
-	
+
 	flag.Parse()
-	
+
 	readReq("telegraf.req")
-	
+
 	readConf(*filename)
-	
+
 	fmt.Println("\n================telegraf test start======================")
 
 	var wg sync.WaitGroup
-	
+
 	for i := 0; i < config.MachineNum; i++ {
 		wg.Add(1)
 		go writeData(&wg, i)

tests/stress/main.go

+/*
+ * Copyright (c) 2019 TAOS Data, Inc. <jhtao@taosdata.com>
+ *
+ * This program is free software: you can use, redistribute, and/or modify
+ * it under the terms of the GNU Affero General Public License, version 3
+ * or later ("AGPL"), as published by the Free Software Foundation.
+ *
+ * This program is distributed in the hope that it will be useful, but WITHOUT
+ * ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or
+ * FITNESS FOR A PARTICULAR PURPOSE.
+ *
+ * You should have received a copy of the GNU Affero General Public License
+ * along with this program. If not, see <http://www.gnu.org/licenses/>.
+ */
+
 package main
 
 import (