use unix nano as seed (#416)

Signed-off-by: Gabriele Santomaggio <G.santomaggio@gmail.com>

Author: Gsantomaggio

perfTest/cmd/silent.go

@@ -320,7 +320,7 @@ func buildMessages() []message.StreamMessage {
 		if fixedBody > 0 {
 			body = make([]byte, fixedBody)
 		} else if variableBody > 0 {
-			r := rand.New(rand.NewSource(time.Now().Unix()))
+			r := rand.New(rand.NewSource(time.Now().UnixNano()))
 			body = make([]byte, r.Intn(variableBody))
 		}
 		var buff = make([]byte, 8)

pkg/ha/reliable_common.go

@@ -84,7 +84,7 @@ func retry(backoff int, reliable IReliable) (error, bool) {
 }
 
 func randomWaitWithBackoff(attempt int) int {
-	r := rand.New(rand.NewSource(time.Now().Unix()))
+	r := rand.New(rand.NewSource(time.Now().UnixNano()))
 	baseWait := 3_000 + r.Intn(8_000)
 
 	// Calculate the wait time considering the number of attempts

pkg/stream/client.go

@@ -743,7 +743,7 @@ func (c *Client) BrokerForConsumer(stream string) (*Broker, error) {
 		brokers = append(brokers, replica)
 	}
 
-	r := rand.New(rand.NewSource(time.Now().Unix()))
+	r := rand.New(rand.NewSource(time.Now().UnixNano()))
 	n := r.Intn(len(brokers))
 	return brokers[n], nil
 }

pkg/stream/environment.go

@@ -138,7 +138,7 @@ func (env *Environment) maybeReconnectLocator() error {
 		logs.LogError("Can't connect the locator client, error:%s, retry in %d milliseconds, broker: %s", err, sleepTime, brokerUri)
 
 		time.Sleep(time.Duration(sleepTime) * time.Millisecond)
-		r := rand.New(rand.NewSource(time.Now().Unix()))
+		r := rand.New(rand.NewSource(time.Now().UnixNano()))
 		n := r.Intn(len(env.options.ConnectionParameters))
 		c1 := newClient("stream-locator", env.options.ConnectionParameters[n], env.options.TCPParameters,
 			env.options.SaslConfiguration, env.options.RPCTimeout)