github/kubeshark
1
0
Fork 0
mirror of https://github.com/kubeshark/kubeshark.git synced 2025-08-12 05:43:34 +00:00
Code Issues Packages Projects Releases Wiki Activity

Update main.go

Browse Source
This commit is contained in:
RamiBerm 2021-07-20 09:58:18 +03:00
parent 1d24188a02
commit b57cb0e615
1 changed files with 0 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
api/main.go
View File

@ -10,7 +10,6 @@ import (
"github.com/romana/rlog" "github.com/romana/rlog"
"github.com/up9inc/mizu/shared" "github.com/up9inc/mizu/shared"
"github.com/up9inc/mizu/tap" "github.com/up9inc/mizu/tap"
"log"
"mizuserver/pkg/api" "mizuserver/pkg/api"
"mizuserver/pkg/middleware" "mizuserver/pkg/middleware"
"mizuserver/pkg/models" "mizuserver/pkg/models"
@ -19,7 +18,6 @@ import (
"mizuserver/pkg/utils" "mizuserver/pkg/utils"
"os" "os"
"os/signal" "os/signal"
"runtime/pprof"
"strings" "strings"
) )
@ -67,12 +65,6 @@ func main() {
go pipeChannelToSocket(socketConnection, harOutputChannel) go pipeChannelToSocket(socketConnection, harOutputChannel)
go api.StartReadingOutbound(outboundLinkOutputChannel) go api.StartReadingOutbound(outboundLinkOutputChannel)
} else if *aggregator { } else if *aggregator {
f, err := os.Create("/app/profile.pprof")
if err != nil {
log.Fatal(err)
}
fmt.Println("Starting profiling4")
pprof.StartCPUProfile(f)
socketHarOutChannel := make(chan *tap.OutputChannelItem, 1000) socketHarOutChannel := make(chan *tap.OutputChannelItem, 1000)
filteredHarChannel := make(chan *tap.OutputChannelItem) filteredHarChannel := make(chan *tap.OutputChannelItem)
@ -85,7 +77,6 @@ func main() {
signalChan := make(chan os.Signal, 1) signalChan := make(chan os.Signal, 1)
signal.Notify(signalChan, os.Interrupt) signal.Notify(signalChan, os.Interrupt)
<-signalChan <-signalChan
rlog.Info("Exiting") rlog.Info("Exiting")
} }