dawid/speedrun
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases 8 Wiki Activity

Use

Browse Source
This commit is contained in:
Dawid Pogorzelski
2022-05-13 23:19:56 +02:00
parent b67da0d28e
commit 57dc2d7f34
4 changed files with 13 additions and 13 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
cmd/speedrun/cli/file.go
View File

@@ -3,7 +3,7 @@ package cli
import ( import (
"context" "context"
"crypto/tls" "crypto/tls"
"fmt" "net"
"strings" "strings"
"time" "time"
@@ -63,7 +63,7 @@ func read(cmd *cobra.Command, args []string) error {
} }
log := log.WithFields(fields) log := log.WithFields(fields)
addr := fmt.Sprintf("%s:%d", portal.GetAddress(usePrivateIP), 1337) addr := net.JoinHostPort(portal.GetAddress(usePrivateIP), "1337")
rawconn, err := tls.Dial("tcp", addr, tlsConfig) rawconn, err := tls.Dial("tcp", addr, tlsConfig)
if err != nil { if err != nil {
log.Error(err.Error()) log.Error(err.Error())

14
cmd/speedrun/cli/run.go
View File

@@ -3,7 +3,7 @@ package cli
import ( import (
"context" "context"
"crypto/tls" "crypto/tls"
"fmt" "net"
"strings" "strings"
"time" "time"
@@ -44,22 +44,22 @@ func run(cmd *cobra.Command, args []string) error {
return err return err
} }
instances, err := cloud.GetInstances(target) portals, err := cloud.GetInstances(target)
if err != nil { if err != nil {
return err return err
} }
pool := pond.New(1000, 10000) pool := pond.New(1000, 10000)
for _, p := range instances { for _, p := range portals {
instance := p portal := p
pool.Submit(func() { pool.Submit(func() {
fields := log.Fields{ fields := log.Fields{
"host": instance.Name, "host": portal.Name,
"address": instance.GetAddress(usePrivateIP), "address": portal.GetAddress(usePrivateIP),
} }
log := log.WithFields(fields) log := log.WithFields(fields)
addr := fmt.Sprintf("%s:%d", instance.GetAddress(usePrivateIP), 1337) addr := net.JoinHostPort(portal.GetAddress(usePrivateIP), "1337")
rawconn, err := tls.Dial("tcp", addr, tlsConfig) rawconn, err := tls.Dial("tcp", addr, tlsConfig)
if err != nil { if err != nil {
log.Error(err.Error()) log.Error(err.Error())

4
cmd/speedrun/cli/service.go
View File

@@ -3,7 +3,7 @@ package cli
import ( import (
"context" "context"
"crypto/tls" "crypto/tls"
"fmt" "net"
"strings" "strings"
"time" "time"
@@ -90,7 +90,7 @@ func action(cmd *cobra.Command, args []string) error {
} }
log := log.WithFields(fields) log := log.WithFields(fields)
addr := fmt.Sprintf("%s:%d", portal.GetAddress(usePrivateIP), 1337) addr := net.JoinHostPort(portal.GetAddress(usePrivateIP), "1337")
rawconn, err := tls.Dial("tcp", addr, tlsConfig) rawconn, err := tls.Dial("tcp", addr, tlsConfig)
if err != nil { if err != nil {
log.Error(err.Error()) log.Error(err.Error())

4
cmd/speedrun/cli/system.go
View File

@@ -3,7 +3,7 @@ package cli
import ( import (
"context" "context"
"crypto/tls" "crypto/tls"
"fmt" "net"
"time" "time"
"github.com/alitto/pond" "github.com/alitto/pond"
@@ -62,7 +62,7 @@ func reboot(cmd *cobra.Command, _ []string) error {
} }
log := log.WithFields(fields) log := log.WithFields(fields)
addr := fmt.Sprintf("%s:%d", portal.GetAddress(usePrivateIP), 1337) addr := net.JoinHostPort(portal.GetAddress(usePrivateIP), "1337")
rawconn, err := tls.Dial("tcp", addr, tlsConfig) rawconn, err := tls.Dial("tcp", addr, tlsConfig)
if err != nil { if err != nil {
log.Error(err.Error()) log.Error(err.Error())