github/kubernetes
1
0
Fork 0
mirror of https://github.com/k3s-io/kubernetes.git synced 2025-07-20 10:20:51 +00:00
Code Issues Projects Releases Wiki Activity

Merge pull request #113642 from dashpole/more_tracing_tests

Browse Source 
Additional integration test validations for apiserver tracing
This commit is contained in:
Kubernetes Prow Robot 2022-11-07 16:01:37 -08:00 committed by GitHub
commit 6ee5e10f02
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 465 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

465
test/integration/apiserver/tracing/tracing_test.go
View File

@ -176,6 +176,65 @@ endpoint: %s`, listener.Addr().String())), os.FileMode(0755)); err != nil {
},
},
},
{
name: "authentication",
},
{
name: "Create",
attributes: map[string]func(*commonv1.AnyValue) bool{
"url": func(v *commonv1.AnyValue) bool {
return strings.HasSuffix(v.GetStringValue(), "/api/v1/nodes")
},
"user-agent": func(v *commonv1.AnyValue) bool {
return strings.HasPrefix(v.GetStringValue(), "tracing.test")
},
"audit-id": func(v *commonv1.AnyValue) bool {
return v.GetStringValue() != ""
},
"client": func(v *commonv1.AnyValue) bool {
return v.GetStringValue() == "127.0.0.1"
},
"accept": func(v *commonv1.AnyValue) bool {
return v.GetStringValue() == "application/vnd.kubernetes.protobuf, */*"
},
"protocol": func(v *commonv1.AnyValue) bool {
return v.GetStringValue() == "HTTP/2.0"
},
},
events: []string{
"limitedReadBody succeeded",
"About to convert to expected version",
"Conversion done",
"About to store object in database",
"Write to database call succeeded",
"About to write a response",
"Writing http response done",
},
},
{
name: "Create etcd3",
attributes: map[string]func(*commonv1.AnyValue) bool{
"audit-id": func(v *commonv1.AnyValue) bool {
return v.GetStringValue() != ""
},
"key": func(v *commonv1.AnyValue) bool {
return v.GetStringValue() == "/minions/fake"
},
"type": func(v *commonv1.AnyValue) bool {
return v.GetStringValue() == "*core.Node"
},
"resource": func(v *commonv1.AnyValue) bool {
return v.GetStringValue() == "nodes"
},
},
events: []string{
"About to Encode",
"Encode succeeded",
"TransformToStorage succeeded",
"Txn call succeeded",
"decode succeeded",
},
},
{
name: "etcdserverpb.KV/Txn",
attributes: map[string]func(*commonv1.AnyValue) bool{
@ -185,6 +244,33 @@ endpoint: %s`, listener.Addr().String())), os.FileMode(0755)); err != nil {
},
events: []string{"message"},
},
{
name: "SerializeObject",
attributes: map[string]func(*commonv1.AnyValue) bool{
"url": func(v *commonv1.AnyValue) bool {
return strings.HasSuffix(v.GetStringValue(), "/api/v1/nodes")
},
"audit-id": func(v *commonv1.AnyValue) bool {
return v.GetStringValue() != ""
},
"protocol": func(v *commonv1.AnyValue) bool {
return v.GetStringValue() == "HTTP/2.0"
},
"method": func(v *commonv1.AnyValue) bool {
return v.GetStringValue() == "POST"
},
"mediaType": func(v *commonv1.AnyValue) bool {
return v.GetStringValue() == "application/vnd.kubernetes.protobuf"
},
"encoder": func(v *commonv1.AnyValue) bool {
return v.GetStringValue() == "{\"encodeGV\":\"v1\",\"encoder\":\"protobuf\",\"name\":\"versioning\"}"
},
},
events: []string{
"About to start writing response",
"Write call succeeded",
},
},
},
},
{
@ -209,6 +295,37 @@ endpoint: %s`, listener.Addr().String())), os.FileMode(0755)); err != nil {
},
},
},
{
name: "authentication",
},
{
name: "Get",
attributes: map[string]func(*commonv1.AnyValue) bool{
"url": func(v *commonv1.AnyValue) bool {
return strings.HasSuffix(v.GetStringValue(), "/api/v1/nodes/fake")
},
"user-agent": func(v *commonv1.AnyValue) bool {
return strings.HasPrefix(v.GetStringValue(), "tracing.test")
},
"audit-id": func(v *commonv1.AnyValue) bool {
return v.GetStringValue() != ""
},
"client": func(v *commonv1.AnyValue) bool {
return v.GetStringValue() == "127.0.0.1"
},
"accept": func(v *commonv1.AnyValue) bool {
return v.GetStringValue() == "application/vnd.kubernetes.protobuf, */*"
},
"protocol": func(v *commonv1.AnyValue) bool {
return v.GetStringValue() == "HTTP/2.0"
},
},
events: []string{
"About to Get from storage",
"About to write a response",
"Writing http response done",
},
},
{
name: "etcdserverpb.KV/Range",
attributes: map[string]func(*commonv1.AnyValue) bool{
@ -218,6 +335,33 @@ endpoint: %s`, listener.Addr().String())), os.FileMode(0755)); err != nil {
},
events: []string{"message"},
},
{
name: "SerializeObject",
attributes: map[string]func(*commonv1.AnyValue) bool{
"url": func(v *commonv1.AnyValue) bool {
return v.GetStringValue() == "/api/v1/nodes/fake"
},
"audit-id": func(v *commonv1.AnyValue) bool {
return v.GetStringValue() != ""
},
"protocol": func(v *commonv1.AnyValue) bool {
return v.GetStringValue() == "HTTP/2.0"
},
"method": func(v *commonv1.AnyValue) bool {
return v.GetStringValue() == "GET"
},
"mediaType": func(v *commonv1.AnyValue) bool {
return v.GetStringValue() == "application/vnd.kubernetes.protobuf"
},
"encoder": func(v *commonv1.AnyValue) bool {
return v.GetStringValue() == "{\"encodeGV\":\"v1\",\"encoder\":\"protobuf\",\"name\":\"versioning\"}"
},
},
events: []string{
"About to start writing response",
"Write call succeeded",
},
},
},
},
{
@ -241,6 +385,60 @@ endpoint: %s`, listener.Addr().String())), os.FileMode(0755)); err != nil {
},
},
},
{
name: "authentication",
},
{
name: "List",
attributes: map[string]func(*commonv1.AnyValue) bool{
"url": func(v *commonv1.AnyValue) bool {
return v.GetStringValue() == "/api/v1/nodes"
},
"user-agent": func(v *commonv1.AnyValue) bool {
return strings.HasPrefix(v.GetStringValue(), "tracing.test")
},
"audit-id": func(v *commonv1.AnyValue) bool {
return v.GetStringValue() != ""
},
"client": func(v *commonv1.AnyValue) bool {
return v.GetStringValue() == "127.0.0.1"
},
"accept": func(v *commonv1.AnyValue) bool {
return v.GetStringValue() == "application/vnd.kubernetes.protobuf, */*"
},
"protocol": func(v *commonv1.AnyValue) bool {
return v.GetStringValue() == "HTTP/2.0"
},
},
events: []string{
"About to List from storage",
"Listing from storage done",
"Writing http response done",
},
},
{
name: "List(recursive=true) etcd3",
attributes: map[string]func(*commonv1.AnyValue) bool{
"audit-id": func(v *commonv1.AnyValue) bool {
return v.GetStringValue() != ""
},
"key": func(v *commonv1.AnyValue) bool {
return v.GetStringValue() == "/minions"
},
"resourceVersion": func(v *commonv1.AnyValue) bool {
return v.GetStringValue() == ""
},
"resourceVersionMatch": func(v *commonv1.AnyValue) bool {
return v.GetStringValue() == ""
},
"limit": func(v *commonv1.AnyValue) bool {
return v.GetIntValue() == 0
},
"continue": func(v *commonv1.AnyValue) bool {
return v.GetStringValue() == ""
},
},
},
{
name: "etcdserverpb.KV/Range",
attributes: map[string]func(*commonv1.AnyValue) bool{
@ -250,6 +448,33 @@ endpoint: %s`, listener.Addr().String())), os.FileMode(0755)); err != nil {
},
events: []string{"message"},
},
{
name: "SerializeObject",
attributes: map[string]func(*commonv1.AnyValue) bool{
"url": func(v *commonv1.AnyValue) bool {
return v.GetStringValue() == "/api/v1/nodes"
},
"audit-id": func(v *commonv1.AnyValue) bool {
return v.GetStringValue() != ""
},
"protocol": func(v *commonv1.AnyValue) bool {
return v.GetStringValue() == "HTTP/2.0"
},
"method": func(v *commonv1.AnyValue) bool {
return v.GetStringValue() == "GET"
},
"mediaType": func(v *commonv1.AnyValue) bool {
return v.GetStringValue() == "application/vnd.kubernetes.protobuf"
},
"encoder": func(v *commonv1.AnyValue) bool {
return v.GetStringValue() == "{\"encodeGV\":\"v1\",\"encoder\":\"protobuf\",\"name\":\"versioning\"}"
},
},
events: []string{
"About to start writing response",
"Write call succeeded",
},
},
},
},
{
@ -278,6 +503,68 @@ endpoint: %s`, listener.Addr().String())), os.FileMode(0755)); err != nil {
},
},
},
{
name: "authentication",
},
{
name: "Update",
attributes: map[string]func(*commonv1.AnyValue) bool{
"url": func(v *commonv1.AnyValue) bool {
return strings.HasSuffix(v.GetStringValue(), "/api/v1/nodes/fake")
},
"user-agent": func(v *commonv1.AnyValue) bool {
return strings.HasPrefix(v.GetStringValue(), "tracing.test")
},
"audit-id": func(v *commonv1.AnyValue) bool {
return v.GetStringValue() != ""
},
"client": func(v *commonv1.AnyValue) bool {
return v.GetStringValue() == "127.0.0.1"
},
"accept": func(v *commonv1.AnyValue) bool {
return v.GetStringValue() == "application/vnd.kubernetes.protobuf, */*"
},
"protocol": func(v *commonv1.AnyValue) bool {
return v.GetStringValue() == "HTTP/2.0"
},
},
events: []string{
"limitedReadBody succeeded",
"About to convert to expected version",
"Conversion done",
"About to store object in database",
"Write to database call succeeded",
"About to write a response",
"Writing http response done",
},
},
{
name: "GuaranteedUpdate etcd3",
attributes: map[string]func(*commonv1.AnyValue) bool{
"audit-id": func(v *commonv1.AnyValue) bool {
return v.GetStringValue() != ""
},
"key": func(v *commonv1.AnyValue) bool {
return v.GetStringValue() == "/minions/fake"
},
"type": func(v *commonv1.AnyValue) bool {
return v.GetStringValue() == "*core.Node"
},
"resource": func(v *commonv1.AnyValue) bool {
return v.GetStringValue() == "nodes"
},
},
events: []string{
"initial value restored",
"About to Encode",
"Encode succeeded",
"TransformToStorage succeeded",
"Transaction prepared",
"Txn call completed",
"Transaction committed",
"decode succeeded",
},
},
{
name: "etcdserverpb.KV/Txn",
attributes: map[string]func(*commonv1.AnyValue) bool{
@ -287,6 +574,33 @@ endpoint: %s`, listener.Addr().String())), os.FileMode(0755)); err != nil {
},
events: []string{"message"},
},
{
name: "SerializeObject",
attributes: map[string]func(*commonv1.AnyValue) bool{
"url": func(v *commonv1.AnyValue) bool {
return strings.HasSuffix(v.GetStringValue(), "/api/v1/nodes/fake")
},
"audit-id": func(v *commonv1.AnyValue) bool {
return v.GetStringValue() != ""
},
"protocol": func(v *commonv1.AnyValue) bool {
return v.GetStringValue() == "HTTP/2.0"
},
"method": func(v *commonv1.AnyValue) bool {
return v.GetStringValue() == "PUT"
},
"mediaType": func(v *commonv1.AnyValue) bool {
return v.GetStringValue() == "application/vnd.kubernetes.protobuf"
},
"encoder": func(v *commonv1.AnyValue) bool {
return v.GetStringValue() == "{\"encodeGV\":\"v1\",\"encoder\":\"protobuf\",\"name\":\"versioning\"}"
},
},
events: []string{
"About to start writing response",
"Write call succeeded",
},
},
},
},
{
@ -333,6 +647,68 @@ endpoint: %s`, listener.Addr().String())), os.FileMode(0755)); err != nil {
},
},
},
{
name: "authentication",
},
{
name: "Patch",
attributes: map[string]func(*commonv1.AnyValue) bool{
"url": func(v *commonv1.AnyValue) bool {
return strings.HasSuffix(v.GetStringValue(), "/api/v1/nodes/fake")
},
"user-agent": func(v *commonv1.AnyValue) bool {
return strings.HasPrefix(v.GetStringValue(), "tracing.test")
},
"audit-id": func(v *commonv1.AnyValue) bool {
return v.GetStringValue() != ""
},
"client": func(v *commonv1.AnyValue) bool {
return v.GetStringValue() == "127.0.0.1"
},
"accept": func(v *commonv1.AnyValue) bool {
return v.GetStringValue() == "application/vnd.kubernetes.protobuf, */*"
},
"protocol": func(v *commonv1.AnyValue) bool {
return v.GetStringValue() == "HTTP/2.0"
},
},
events: []string{
"limitedReadBody succeeded",
"Recorded the audit event",
"About to apply patch",
"About to check admission control",
"Object stored in database",
"About to write a response",
"Writing http response done",
},
},
{
name: "GuaranteedUpdate etcd3",
attributes: map[string]func(*commonv1.AnyValue) bool{
"audit-id": func(v *commonv1.AnyValue) bool {
return v.GetStringValue() != ""
},
"key": func(v *commonv1.AnyValue) bool {
return v.GetStringValue() == "/minions/fake"
},
"type": func(v *commonv1.AnyValue) bool {
return v.GetStringValue() == "*core.Node"
},
"resource": func(v *commonv1.AnyValue) bool {
return v.GetStringValue() == "nodes"
},
},
events: []string{
"initial value restored",
"About to Encode",
"Encode succeeded",
"TransformToStorage succeeded",
"Transaction prepared",
"Txn call completed",
"Transaction committed",
"decode succeeded",
},
},
{
name: "etcdserverpb.KV/Txn",
attributes: map[string]func(*commonv1.AnyValue) bool{
@ -342,6 +718,33 @@ endpoint: %s`, listener.Addr().String())), os.FileMode(0755)); err != nil {
},
events: []string{"message"},
},
{
name: "SerializeObject",
attributes: map[string]func(*commonv1.AnyValue) bool{
"url": func(v *commonv1.AnyValue) bool {
return strings.HasSuffix(v.GetStringValue(), "/api/v1/nodes/fake")
},
"audit-id": func(v *commonv1.AnyValue) bool {
return v.GetStringValue() != ""
},
"protocol": func(v *commonv1.AnyValue) bool {
return v.GetStringValue() == "HTTP/2.0"
},
"method": func(v *commonv1.AnyValue) bool {
return v.GetStringValue() == "PATCH"
},
"mediaType": func(v *commonv1.AnyValue) bool {
return v.GetStringValue() == "application/vnd.kubernetes.protobuf"
},
"encoder": func(v *commonv1.AnyValue) bool {
return v.GetStringValue() == "{\"encodeGV\":\"v1\",\"encoder\":\"protobuf\",\"name\":\"versioning\"}"
},
},
events: []string{
"About to start writing response",
"Write call succeeded",
},
},
},
},
{
@ -365,6 +768,41 @@ endpoint: %s`, listener.Addr().String())), os.FileMode(0755)); err != nil {
},
},
},
{
name: "authentication",
},
{
name: "Delete",
attributes: map[string]func(*commonv1.AnyValue) bool{
"url": func(v *commonv1.AnyValue) bool {
return strings.HasSuffix(v.GetStringValue(), "/api/v1/nodes/fake")
},
"user-agent": func(v *commonv1.AnyValue) bool {
return strings.HasPrefix(v.GetStringValue(), "tracing.test")
},
"audit-id": func(v *commonv1.AnyValue) bool {
return v.GetStringValue() != ""
},
"client": func(v *commonv1.AnyValue) bool {
return v.GetStringValue() == "127.0.0.1"
},
"accept": func(v *commonv1.AnyValue) bool {
return v.GetStringValue() == "application/vnd.kubernetes.protobuf, */*"
},
"protocol": func(v *commonv1.AnyValue) bool {
return v.GetStringValue() == "HTTP/2.0"
},
},
events: []string{
"limitedReadBody succeeded",
"Decoded delete options",
"Recorded the audit event",
"About to delete object from database",
"Object deleted from database",
"About to write a response",
"Writing http response done",
},
},
{
name: "etcdserverpb.KV/Txn",
attributes: map[string]func(*commonv1.AnyValue) bool{
@ -374,6 +812,33 @@ endpoint: %s`, listener.Addr().String())), os.FileMode(0755)); err != nil {
},
events: []string{"message"},
},
{
name: "SerializeObject",
attributes: map[string]func(*commonv1.AnyValue) bool{
"url": func(v *commonv1.AnyValue) bool {
return strings.HasSuffix(v.GetStringValue(), "/api/v1/nodes/fake")
},
"audit-id": func(v *commonv1.AnyValue) bool {
return v.GetStringValue() != ""
},
"protocol": func(v *commonv1.AnyValue) bool {
return v.GetStringValue() == "HTTP/2.0"
},
"method": func(v *commonv1.AnyValue) bool {
return v.GetStringValue() == "DELETE"
},
"mediaType": func(v *commonv1.AnyValue) bool {
return v.GetStringValue() == "application/vnd.kubernetes.protobuf"
},
"encoder": func(v *commonv1.AnyValue) bool {
return v.GetStringValue() == "{\"encodeGV\":\"v1\",\"encoder\":\"protobuf\",\"name\":\"versioning\"}"
},
},
events: []string{
"About to start writing response",
"Write call succeeded",
},
},
},
},
} {