vbatts/microservices-demo
1
0
Fork 0
Code Issues Pull requests Releases Wiki Activity

Change to boolean Latency spike

Browse source
This commit is contained in:
Duke Nguyen 2020-07-21 00:42:34 +00:00
parent 39807713f4
commit b9947a4249
2 changed files with 9 additions and 9 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

4
release/kubernetes-manifests.yaml
View file

@ -374,8 +374,8 @@ spec:
value: "1" value: "1"
- name: ENABLE_RELOAD - name: ENABLE_RELOAD
value: "1" value: "1"
- name: LATENCY_SPIKE # - name: LATENCY_SPIKE
value: "100" # value: "100"
# - name: JAEGER_SERVICE_ADDR # - name: JAEGER_SERVICE_ADDR
# value: "jaeger-collector:14268" # value: "jaeger-collector:14268"
readinessProbe: readinessProbe:

14
src/productcatalogservice/server.go
View file

@ -28,7 +28,7 @@ import (
// "syscall" // "syscall"
"time" "time"
"math/rand" "math/rand"
"strconv" // "strconv"
pb "github.com/GoogleCloudPlatform/microservices-demo/src/productcatalogservice/genproto" pb "github.com/GoogleCloudPlatform/microservices-demo/src/productcatalogservice/genproto"
healthpb "google.golang.org/grpc/health/grpc_health_v1" healthpb "google.golang.org/grpc/health/grpc_health_v1"
@ -249,12 +249,12 @@ func (p *productCatalog) ListProducts(context.Context, *pb.Empty) (*pb.ListProdu
func (p *productCatalog) GetProduct(ctx context.Context, req *pb.GetProductRequest) (*pb.Product, error) { func (p *productCatalog) GetProduct(ctx context.Context, req *pb.GetProductRequest) (*pb.Product, error) {
if s := os.Getenv("LATENCY_SPIKE"); s != "" { if s := os.Getenv("LATENCY_SPIKE"); s != "" {
v, err := strconv.Atoi(s) // v, err := strconv.Atoi(s)
if err != nil { // if err != nil {
log.Fatalf("faigit chaled to parse EXTRA_LATENCY (%s) as int: %+v", v, err) // log.Fatalf("faigit chaled to parse EXTRA_LATENCY (%s) as int: %+v", v, err)
} // }
rand.Seed(time.Now().UnixNano()) // rand.Seed(time.Now().UnixNano())
n := 3 * (1 + rand.Intn(v)) // n will be between 0 and v n := 3 * (1 + rand.Intn(10)) // n will be between 0 and v
time.Sleep(time.Duration(n)*time.Second) time.Sleep(time.Duration(n)*time.Second)
log.Infof("extra latency enabled (duration: %v)", extraLatency) log.Infof("extra latency enabled (duration: %v)", extraLatency)
} else { } else {