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 4be2b5ece9
commit 7b1565e6a4
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 (
"context"
"crypto/tls"
"fmt"
"net"
"strings"
"time"
@@ -63,7 +63,7 @@ func read(cmd *cobra.Command, args []string) error {
}
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)
if err != nil {
log.Error(err.Error())

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

@@ -3,7 +3,7 @@ package cli
import (
"context"
"crypto/tls"
"fmt"
"net"
"strings"
"time"
@@ -44,22 +44,22 @@ func run(cmd *cobra.Command, args []string) error {
return err
}
instances, err := cloud.GetInstances(target)
portals, err := cloud.GetInstances(target)
if err != nil {
return err
}
pool := pond.New(1000, 10000)
for _, p := range instances {
instance := p
for _, p := range portals {
portal := p
pool.Submit(func() {
fields := log.Fields{
"host": instance.Name,
"address": instance.GetAddress(usePrivateIP),
"host": portal.Name,
"address": portal.GetAddress(usePrivateIP),
}
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)
if err != nil {
log.Error(err.Error())

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

@@ -3,7 +3,7 @@ package cli
import (
"context"
"crypto/tls"
"fmt"
"net"
"strings"
"time"
@@ -90,7 +90,7 @@ func action(cmd *cobra.Command, args []string) error {
}
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)
if err != nil {
log.Error(err.Error())

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

@@ -3,7 +3,7 @@ package cli
import (
"context"
"crypto/tls"
"fmt"
"net"
"time"
"github.com/alitto/pond"
@@ -62,7 +62,7 @@ func reboot(cmd *cobra.Command, _ []string) error {
}
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)
if err != nil {
log.Error(err.Error())