Skip to content

Instantly share code, notes, and snippets.

View Pothulapati's full-sized avatar
🎯
Focusing

Tarun Pothulapati Pothulapati

🎯
Focusing
View GitHub Profile
[ 0.000526s] DEBUG ThreadId(01) rustls::anchors: add_pem_file processed 1 valid and 0 invalid certs
[ 0.000748s] WARN ThreadId(01) linkerd_app::env: LINKERD2_PROXY_INBOUND_DEFAULT_POLICY was not set; using `all-unauthenticated`
[ 0.000780s] INFO ThreadId(01) linkerd2_proxy::rt: Using single-threaded proxy runtime
[ 0.000865s] DEBUG ThreadId(01) linkerd_app: building app
[ 0.001405s] INFO ThreadId(01) linkerd2_proxy: Admin interface on 0.0.0.0:4191
[ 0.001420s] INFO ThreadId(01) linkerd2_proxy: Inbound interface on 0.0.0.0:4143
[ 0.001424s] INFO ThreadId(01) linkerd2_proxy: Outbound interface on 127.0.0.1:4140
[ 0.001428s] INFO ThreadId(01) linkerd2_proxy: Tap DISABLED
[ 0.001431s] INFO ThreadId(01) linkerd2_proxy: Local identity is voting.emojivoto.serviceaccount.identity.linkerd.cluster.local
[ 0.001436s] INFO ThreadId(01) linkerd2_proxy: Identity verified via linkerd-identity-headless.linkerd.svc.cluster.local:8080 (linkerd-identity.linkerd.serviceaccount.
---
apiVersion: policy.linkerd.io/v1alpha1
kind: Server
metadata:
namespace: emojivoto
name: emoji-grpc
labels:
app.kubernetes.io/part-of: emojivoto
app.kubernetes.io/name: emoji
app.kubernetes.io/version: v11
on ⛵ kind-kind linkerd2 on 🌱 main [📦📝🤷‍] via 🐼 v1.16.6 via 
➜ ./bin/go-run cli viz stat svc/backend-svc -n linkerd-trafficsplit-test-sp ~/work/linkerd2
NAME APEX LEAF WEIGHT SUCCESS RPS LATENCY_P50 LATENCY_P95 LATENCY_P99
backend-svc.linkerd-trafficsplit-test-sp.svc.cluster.local backend-svc.linkerd-trafficsplit-test-sp.svc.cluster.local backend-svc 500m 100.00% 0.9rps 1ms 2ms 2ms
backend-svc.linkerd-trafficsplit-test-sp.svc.cluster.local backend-svc.linkerd-trafficsplit-test-sp.svc.cluster.local failing-svc 500m 0.00% 1.1rps 1ms 2ms 2ms
on ⛵ kind-kind linkerd2 on 🌱 main [📦📝🤷‍] via 🐼 v1.16.6 via  took 2s
➜ ./bin/go-run cli viz stat svc/backend-svc -n linkerd-trafficsplit-test-sp --from depl
diff --git a/test/integration/trafficsplit/trafficsplit_test.go b/test/integration/trafficsplit/trafficsplit_test.go
index 83921e3e..7349c1b2 100644
--- a/test/integration/trafficsplit/trafficsplit_test.go
+++ b/test/integration/trafficsplit/trafficsplit_test.go
@@ -156,9 +156,7 @@ func validateTrafficSplit(actual *statTsRow, expected *statTsRow) error {
return nil
}
-func validateExpectedTsOutput(rows map[string]*statTsRow, expectedBackendSvc, expectedFailingSvc *statTsRow) error {
- backendSvcLeafKey := "backend-svc"
diff --git a/bin/_test-helpers.sh b/bin/_test-helpers.sh
index 94cc7611..cafe196f 100644
--- a/bin/_test-helpers.sh
+++ b/bin/_test-helpers.sh
@@ -525,9 +525,7 @@ run_deep_test() {
local tests=()
run_test "$test_directory/install_test.go"
while IFS= read -r line; do tests+=("$line"); done <<< "$(go list "$test_directory"/.../...)"
- for test in "${tests[@]}"; do
- run_test "$test"
apiVersion: apps/v1
kind: Deployment
metadata:
name: my-nginx-1
spec:
selector:
matchLabels:
run: my-nginx-1
replicas: 1
template:
apiVersion: v1
kind: Pod
metadata:
name: shell-demo
annotations:
linkerd.io/inject: ingress
spec:
volumes:
- name: shared-data
emptyDir: {}
diff --git a/multicluster/service-mirror/cluster_watcher.go b/multicluster/service-mirror/cluster_watcher.go
index ae6a5bba..ac98472c 100644
--- a/multicluster/service-mirror/cluster_watcher.go
+++ b/multicluster/service-mirror/cluster_watcher.go
@@ -485,7 +485,7 @@ func (rcsw *RemoteClusterServiceWatcher) createOrUpdateService(service *corev1.S
localService, err := rcsw.localAPIClient.Svc().Lister().Services(service.Namespace).Get(localName)
if err != nil {
if kerrors.IsNotFound(err) {
- rcsw.eventsQueue.Add(&RemoteServiceCreated{
+ rcsw.eventsQueue.AddRateLimited(&RemoteServiceCreated{
apiVersion: apps/v1
kind: Deployment
metadata:
name: go-tracer
labels:
app: go-sample-hearbeat
spec:
replicas: 1
selector:
matchLabels:
## Default values for Datadog Agent
## See Datadog helm documentation to learn more:
## https://docs.datadoghq.com/agent/kubernetes/helm/
# nameOverride -- Override name of app
nameOverride: # ""
# fullnameOverride -- Override the full qualified app name
fullnameOverride: # ""