add ctx initialize

zhangzengfei

2022-05-24 de807541f31f47d15f84c1b505914a34ac7ee55d

 config.go

@@ -17,6 +17,7 @@
package syncdb

import (
   "context"
   "fmt"
   "net"
   "os"
@@ -64,6 +65,32 @@
      Mode:        ModeSingle,
      Config:      agentConf,
      ClusterPort: DefaultClusterPort,
      Ctx:         context.Background()
   }
}

func (c *Config) MergeConf(s *Config) {
   if s != nil {
      if s.Ctx != nil {
         c.Ctx = s.Ctx
      } else {
         c.Ctx = context.Background()
      }
      c.BindAddr = s.BindAddr
      c.RPCAddr = s.RPCAddr
      c.RPCPort = s.RPCPort
      //serf快照地址
      if s.SnapshotPath != "" {
         c.SnapshotPath = s.SnapshotPath
      }
      if s.EncryptKey != "" {
         //报文加密的key
         c.EncryptKey = s.EncryptKey
      }
      if s.RPCAuthKey != "" {
         //RPC认证的key
         c.RPCAuthKey = s.RPCAuthKey
      }
   }
}

@@ -79,6 +106,7 @@
   // port to communicate between cluster members
   ClusterPort int       `yaml:"cluster_port"`
   RPCPort     int       `yaml:"-"`
   Ctx       context.Context
}

// readConfigFile reads configuration from config file