change package prefixes to tes

src/tes-server/server.go

@@ -39,9 +39,9 @@ func main() {
 	}
 
 	//setup GRPC listener
-	taski := ga4gh_task.NewTaskBolt(*task_db, meta_data)
-	
-	server := ga4gh_task.NewGA4GHServer()
+	taski := tes_server.NewTaskBolt(*task_db, meta_data)
+
+	server := tes_server.NewGA4GHServer()
 	server.RegisterTaskServer(taski)
 	server.RegisterScheduleServer(taski)
 	server.Start(*rpc_port)

src/tes-worker/worker.go

@@ -34,32 +34,32 @@ func main() {
 	defer conn.Close()
 	sched_client := ga4gh_task_ref.NewSchedulerClient(conn)
 
-	var file_client ga4gh_taskengine_worker.FileSystemAccess = nil
+	var file_client tes_taskengine_worker.FileSystemAccess = nil
 
 	if *swift_dir_arg != "" {
 		storage_dir, _ := filepath.Abs(*swift_dir_arg)
 		if _, err := os.Stat(storage_dir); os.IsNotExist(err) {
 			os.Mkdir(storage_dir, 0700)
 		}
 
-		file_client = ga4gh_taskengine_worker.NewSwiftAccess()
+		file_client = tes_taskengine_worker.NewSwiftAccess()
 	} else {
 		storage_dir, _ := filepath.Abs(*storage_dir_arg)
 		if _, err := os.Stat(storage_dir); os.IsNotExist(err) {
 			os.Mkdir(storage_dir, 0700)
 		}
-		file_client = ga4gh_taskengine_worker.NewSharedFS(storage_dir)
+		file_client = tes_taskengine_worker.NewSharedFS(storage_dir)
 	}
-	file_mapper := ga4gh_taskengine_worker.NewFileMapper(&sched_client, file_client, volume_dir)
+	file_mapper := tes_taskengine_worker.NewFileMapper(&sched_client, file_client, volume_dir)
 
 	u, _ := uuid.NewV4()
-	manager, _ := ga4gh_taskengine_worker.NewLocalManager(*nworker, u.String())
+	manager, _ := tes_taskengine_worker.NewLocalManager(*nworker, u.String())
 	if *timeout_arg <= 0 {
 		manager.Run(sched_client, *file_mapper)
 	} else {
 		var start_count int32 = 0
 		last_ping := time.Now().Unix()
-		manager.SetStatusCheck(func(status ga4gh_taskengine_worker.EngineStatus) {
+		manager.SetStatusCheck(func(status tes_taskengine_worker.EngineStatus) {
 			if status.JobCount > start_count || status.ActiveJobs > 0 {
 				start_count = status.JobCount
 				last_ping = time.Now().Unix()

src/tes/server/task_boltdb.go

@@ -1,4 +1,4 @@
-package ga4gh_task
+package tes_server
 
 import (
 	"fmt"

src/tes/server/task_server.go

@@ -1,4 +1,4 @@
-package ga4gh_task
+package tes_server
 
 import (
 	"tes/server/proto"

src/tes/worker/container.go

@@ -1,4 +1,4 @@
-package ga4gh_taskengine_worker
+package tes_taskengine_worker
 
 import (
 	"github.com/fsouza/go-dockerclient"

src/tes/worker/container_engine.go

@@ -1,4 +1,4 @@
-package ga4gh_taskengine_worker
+package tes_taskengine_worker
 
 import (
 	"github.com/docker/engine-api/client"

src/tes/worker/engine.go

@@ -1,4 +1,4 @@
-package ga4gh_taskengine_worker
+package tes_taskengine_worker
 
 import (
 	"fmt"

src/tes/worker/file_client.go

@@ -1,4 +1,4 @@
-package ga4gh_taskengine_worker
+package tes_taskengine_worker
 
 import (
 	"fmt"

src/tes/worker/fork_engine.go

@@ -1,4 +1,4 @@
-package ga4gh_taskengine_worker
+package tes_taskengine_worker
 
 import (
 	"tes/server/proto"

src/tes/worker/fs_client.go

@@ -1,4 +1,4 @@
-package ga4gh_taskengine_worker
+package tes_taskengine_worker
 
 import (
 	"fmt"

src/tes/worker/swift_client.go

@@ -1,4 +1,4 @@
-package ga4gh_taskengine_worker
+package tes_taskengine_worker
 
 import (
 	"fmt"
@@ -77,7 +77,7 @@ func (self *SwiftAccess) Put(storage string, hostPath string, class string) erro
 
 	storage = strings.TrimPrefix(storage, SWIFT_PROTOCOL)
 	storage_split := strings.SplitN(storage, "/", 2)
-	
+
 	if class == "File" {
 		// Now execute the upload
 		opts := objects.CreateOpts{}

src/tes/worker/util.go

@@ -1,4 +1,4 @@
-package ga4gh_taskengine_worker
+package tes_taskengine_worker
 
 import (
 	"fmt"