Skip to content
This repository was archived by the owner on Apr 27, 2022. It is now read-only.

Commit ce12241

Browse files
committed
Remove unused routine
1 parent c6a33a7 commit ce12241

File tree

2 files changed

+1
-11
lines changed

2 files changed

+1
-11
lines changed

cmd/oshinko/oshinko.go

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -31,6 +31,5 @@ func main() {
3131
command := cli.CommandFor(basename)
3232
if err := command.Execute(); err != nil {
3333
os.Exit(1)
34-
3534
}
36-
}
35+
}

core/clusters/clusters.go

Lines changed: 0 additions & 9 deletions
Original file line numberDiff line numberDiff line change
@@ -223,15 +223,6 @@ func sparkWorker(namespace, image string, replicas int, clustername, sparkconfdi
223223
// assign the pod template spec to the deployment config
224224
return dc.PodTemplateSpec(pt.Containers(cont))
225225
}
226-
func addPromPortToPod( metrics string, webport int ) []*ocon.OContainerPort {
227-
webp := ocon.ContainerPort(webPortName, webport)
228-
if metrics != "false"{
229-
promport := 7777
230-
metricp := ocon.ContainerPort(metricsPortName, promport)
231-
return []*ocon.OContainerPort{webp, metricp}
232-
}
233-
return []*ocon.OContainerPort{webp}
234-
}
235226

236227
func mastername(clustername string) string {
237228
return clustername + "-m"

0 commit comments

Comments
 (0)