1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
|
package test
import (
"context"
"fmt"
"testing"
"time"
"github.com/stretchr/testify/require"
corev1 "k8s.io/api/core/v1"
metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
"k8s.io/apimachinery/pkg/util/wait"
"k8s.io/client-go/kubernetes"
"k8s.io/client-go/rest"
)
const (
// Set to a correct agent id.
agentID = 3
//kasK8sURL = "https://gdk.test:3443/-/k8s-proxy/"
kasK8sURL = "http://gdk.test:8154/-/k8s-proxy"
concurrency = 1
requestsPerThread = 100
delay = 100 * time.Millisecond
)
func TestLoadTest(t *testing.T) {
t.SkipNow()
cfg := &rest.Config{
Host: kasK8sURL,
BearerToken: fmt.Sprintf("ci:%d:token", agentID),
QPS: -1,
Burst: -1,
}
c, err := kubernetes.NewForConfig(cfg)
require.NoError(t, err)
pods := c.CoreV1().Pods(corev1.NamespaceAll)
var wg wait.Group
for g := 0; g < concurrency; g++ {
wg.Start(func() {
for i := 0; i < requestsPerThread; i++ {
_, err := pods.List(context.Background(), metav1.ListOptions{})
//w, err := pods.Watch(context.Background(), metav1.ListOptions{})
if err != nil {
//fmt.Printf("%v Error: %v\n", time.Now(), err)
time.Sleep(delay)
continue
}
time.Sleep(delay)
//for e := range w.ResultChan() {
// _ = e
//}
}
})
}
wg.Wait()
}
|
