set dbs.GlobalLog to be used in go (migration) routines

dbs/dbs.go

@@ -22,8 +22,12 @@ import (
 
 	"github.com/dmwm/dbs2go/utils"
 	validator "github.com/go-playground/validator/v10"
+	"github.com/vkuznet/auth-proxy-server/logging"
 )
 
+// GlobalLog represents global rorate log object
+var GlobalLog *logging.RotateLogWriter
+
 // API structure represents DBS API. Each API has reader (to read
 // HTTP POST payload), HTTP writer to write results back to client,
 // HTTP context, input HTTP GET paramers, separator for writer,

dbs/migrate.go

@@ -701,6 +701,10 @@ func (a *API) SubmitMigration() error {
 // the code is based on the following example:
 // https://medium.com/geekculture/timeout-context-in-go-e88af0abd08d
 func StartMigrationRequest(rec MigrationRequest) {
+	// set GlobalLog if it is set
+	if GlobalLog != nil {
+		log.SetOutput(GlobalLog)
+	}
 	// setup context with timeout
 	ctx, cancel := context.WithTimeout(
 		context.Background(),

dbs/migration_requests.go

@@ -130,6 +130,7 @@ func (r *MigrationRequest) Decode(reader io.Reader) error {
 
 // MigrationRequests fetches migration requests from migration table
 func MigrationRequests(mid int64) ([]MigrationRequest, error) {
+	log.Println("process migration request", mid)
 	var records []MigrationRequest
 
 	// query MigrationRequest table and fetch all non-completed requests

web/server.go

@@ -328,6 +328,7 @@ func Server(configFile string) {
 		if err == nil {
 			rotlogs := logging.RotateLogWriter{RotateLogs: rl}
 			log.SetOutput(rotlogs)
+			dbs.GlobalLog = &rotlogs
 		} else {
 			log.Println("ERROR: unable to get rotatelogs", err)
 		}