in network/benchmarks/netperf/launch.go [442:499]
func main() {
flag.Parse()
fmt.Println("Network Performance Test")
fmt.Println("Parameters :")
fmt.Println("Iterations : ", iterations)
fmt.Println("Test Namespace : ", testNamespace)
fmt.Println("Docker image : ", netperfImage)
fmt.Println("------------------------------------------------------------")
<<<<<<< HEAD
testParams := lib.TestParams{
Iterations: iterations,
Tag: tag,
TestNamespace: testNamespace,
Image: netperfImage,
CleanupOnly: cleanupOnly,
TestFrom: testFrom,
TestTo: testTo,
JsonOutput: jsonOutput,
KubeConfig: kubeConfig,
}
results, err := lib.PerformTests(testParams)
if err != nil {
fmt.Println(err)
os.Exit(1)
}
fmt.Println("Results :")
for _, result := range results {
fmt.Println("CSV Result File : ", result.CsvResultFile)
fmt.Println("JSON Result File : ", result.JsonResultFile)
}
=======
ctx := context.Background()
var c *kubernetes.Clientset
if c = setupClient(); c == nil {
fmt.Println("Failed to setup REST client to Kubernetes cluster")
return
}
if cleanupOnly {
cleanup(ctx, c)
return
}
nodes := getMinionNodes(ctx, c)
if nodes == nil {
return
}
if len(nodes.Items) < 2 {
fmt.Println("Insufficient number of nodes for test (need minimum 2 nodes)")
return
}
primaryNode = nodes.Items[0]
secondaryNode = nodes.Items[1]
fmt.Printf("Selected primary,secondary nodes = (%s, %s)\n", primaryNode.GetName(), secondaryNode.GetName())
executeTests(ctx, c)
cleanup(ctx, c)
>>>>>>> origin/master
}