Skip to content

Commit

Permalink
make -nodes accept a comma-separated list of nodes
Browse files Browse the repository at this point in the history
  • Loading branch information
pdziepak committed Jul 7, 2017
1 parent a3bdb9e commit 3d7fb42
Showing 1 changed file with 2 additions and 1 deletion.
3 changes: 2 additions & 1 deletion main.go
Original file line number Diff line number Diff line change
Expand Up @@ -6,6 +6,7 @@ import (
"log"
"os"
"os/signal"
"strings"
"sync/atomic"
"time"

Expand Down Expand Up @@ -205,7 +206,7 @@ func main() {
log.Fatal("time series writes require concurrency less than or equal partition count")
}

cluster := gocql.NewCluster(nodes)
cluster := gocql.NewCluster(strings.Split(nodes, ",")...)
cluster.NumConns = connectionCount
cluster.PageSize = pageSize
cluster.Timeout = timeout
Expand Down

0 comments on commit 3d7fb42

Please sign in to comment.