marker/shuffle-cracked
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

go fmt

Browse Source 
Signed-off-by: Pascal Sthamer <10992664+P4sca1@users.noreply.github.com>
This commit is contained in:
Pascal Sthamer
2025-10-15 11:34:53 +02:00
parent 172d0d8d80
commit 45ed10405c
2 changed files with 29 additions and 29 deletions
Download Patch File Download Diff File Expand all files Collapse all files
functions/onprem/orborus/orborus.go
+27 -27
View File
@@ -3053,8 +3053,8 @@ func createAndStartTenzirNode(ctx context.Context, containerName, imageName stri
Healthcheck: healthconfig, Healthcheck: healthconfig,
ExposedPorts: nat.PortSet{ ExposedPorts: nat.PortSet{
"5160/tcp": struct{}{}, "5160/tcp": struct{}{},
"1514/udp": struct{}{}, "1514/udp": struct{}{},
"1514/tcp": struct{}{}, "1514/tcp": struct{}{},
}, },
Entrypoint: []string{containerName}, Entrypoint: []string{containerName},
Env: []string{}, Env: []string{},
@@ -3100,8 +3100,8 @@ func createAndStartTenzirNode(ctx context.Context, containerName, imageName stri
hostConfig := &container.HostConfig{ hostConfig := &container.HostConfig{
PortBindings: nat.PortMap{ PortBindings: nat.PortMap{
"1514/tcp": []nat.PortBinding{{HostPort: "1514"}}, "1514/tcp": []nat.PortBinding{{HostPort: "1514"}},
"1514/udp": []nat.PortBinding{{HostPort: "1514"}}, "1514/udp": []nat.PortBinding{{HostPort: "1514"}},
"5160/tcp": []nat.PortBinding{{HostPort: "5160"}}, "5160/tcp": []nat.PortBinding{{HostPort: "5160"}},
}, },
Mounts: []mount.Mount{ Mounts: []mount.Mount{
@@ -3111,16 +3111,16 @@ func createAndStartTenzirNode(ctx context.Context, containerName, imageName stri
Target: "/tmp", Target: "/tmp",
}, },
/* /*
{ {
Type: "bind", Type: "bind",
Source: tenzirStorageFolder, Source: tenzirStorageFolder,
Target: "/var/log/tenzir/", Target: "/var/log/tenzir/",
}, },
{ {
Type: "bind", Type: "bind",
Source: tenzirStorageFolder, Source: tenzirStorageFolder,
Target: "/var/cache/tenzir/", Target: "/var/cache/tenzir/",
}, },
*/ */
}, },
VolumeDriver: "local", VolumeDriver: "local",
@@ -3338,7 +3338,7 @@ func createPipeline(command, identifier string) (string, error) {
"name": identifier, "name": identifier,
"hidden": false, "hidden": false,
"retry_delay": "500.0ms", "retry_delay": "500.0ms",
"unstoppable": true, "unstoppable": true,
} }
requestBodyJSON, err := json.Marshal(requestBody) requestBodyJSON, err := json.Marshal(requestBody)
@@ -3410,20 +3410,20 @@ func updatePipelineState(command, pipelineId, action string) (string, error) {
url := fmt.Sprintf("%s/api/v0/pipeline/update", pipelineUrl) url := fmt.Sprintf("%s/api/v0/pipeline/update", pipelineUrl)
forwardMethod := "POST" forwardMethod := "POST"
requestBody := map[string]interface{}{ requestBody := map[string]interface{}{
"id": pipelineId, "id": pipelineId,
"action": action, "action": action,
/* /*
"autostart": map[string]bool{ "autostart": map[string]bool{
"created": true, "created": true,
"completed": false, "completed": false,
"failed": false, "failed": false,
}, },
"autodelete": map[string]bool{ "autodelete": map[string]bool{
"completed": false, "completed": false,
"failed": false, "failed": false,
"stopped": false, "stopped": false,
}, },
*/ */
} }
functions/onprem/worker/worker.go
+1 -1
View File
@@ -4848,7 +4848,7 @@ func runWebserver(listener net.Listener) {
if strings.ToLower(os.Getenv("SHUFFLE_SWARM_CONFIG")) == "run" || strings.ToLower(os.Getenv("SHUFFLE_APP_REPLICAS")) == "" { if strings.ToLower(os.Getenv("SHUFFLE_SWARM_CONFIG")) == "run" || strings.ToLower(os.Getenv("SHUFFLE_APP_REPLICAS")) == "" {
// go AutoScaleApps(ctx, dockercli, maxExecutionsPerMinute) // go AutoScaleApps(ctx, dockercli, maxExecutionsPerMinute)
} }
if (strings.ToLower(os.Getenv("SHUFFLE_DEBUG_MEMORY")) == "true" || strings.ToLower(os.Getenv("DEBUG_MEMORY")) == "true") { if strings.ToLower(os.Getenv("SHUFFLE_DEBUG_MEMORY")) == "true" || strings.ToLower(os.Getenv("DEBUG_MEMORY")) == "true" {
r.HandleFunc("/debug/pprof/", pprof.Index) r.HandleFunc("/debug/pprof/", pprof.Index)
r.HandleFunc("/debug/pprof/heap", pprof.Handler("heap").ServeHTTP) r.HandleFunc("/debug/pprof/heap", pprof.Handler("heap").ServeHTTP)
r.HandleFunc("/debug/pprof/profile", pprof.Profile) r.HandleFunc("/debug/pprof/profile", pprof.Profile)