mirror of https://github.com/linkerd/linkerd2.git
Add TCP data to simulate-proxy script (#165)
simulate-proxy sends HTTP example data. Modify this test script to also send TCP example data. Part of #132 Signed-off-by: Andrew Seigner <andrew@sig.gy>
This commit is contained in:
parent
e56be9bf0e
commit
6f26cf21cf
|
@ -169,6 +169,8 @@ func main() {
|
||||||
count := randomCount()
|
count := randomCount()
|
||||||
sourceIp := randomPod(allPods, nil)
|
sourceIp := randomPod(allPods, nil)
|
||||||
targetIp := randomPod(allPods, sourceIp)
|
targetIp := randomPod(allPods, sourceIp)
|
||||||
|
|
||||||
|
// HTTP
|
||||||
req := &pb.ReportRequest{
|
req := &pb.ReportRequest{
|
||||||
Process: &pb.Process{
|
Process: &pb.Process{
|
||||||
ScheduledInstance: "hello-1mfa0",
|
ScheduledInstance: "hello-1mfa0",
|
||||||
|
@ -207,6 +209,50 @@ func main() {
|
||||||
if err != nil {
|
if err != nil {
|
||||||
log.Fatal(err.Error())
|
log.Fatal(err.Error())
|
||||||
}
|
}
|
||||||
|
|
||||||
|
// TCP
|
||||||
|
req = &pb.ReportRequest{
|
||||||
|
Process: &pb.Process{
|
||||||
|
ScheduledInstance: "hello-tcp-1mfa0",
|
||||||
|
ScheduledNamespace: "people-tcp",
|
||||||
|
},
|
||||||
|
ClientTransports: []*pb.ClientTransport{
|
||||||
|
&pb.ClientTransport{
|
||||||
|
TargetAddr: &common.TcpAddress{
|
||||||
|
Ip: targetIp,
|
||||||
|
Port: randomPort(),
|
||||||
|
},
|
||||||
|
Connects: count,
|
||||||
|
Disconnects: []*pb.TransportSummary{
|
||||||
|
&pb.TransportSummary{
|
||||||
|
DurationMs: uint64(randomCount()),
|
||||||
|
BytesSent: uint64(randomCount()),
|
||||||
|
},
|
||||||
|
},
|
||||||
|
Protocol: common.Protocol_TCP,
|
||||||
|
},
|
||||||
|
},
|
||||||
|
ServerTransports: []*pb.ServerTransport{
|
||||||
|
&pb.ServerTransport{
|
||||||
|
SourceIp: sourceIp,
|
||||||
|
Connects: count,
|
||||||
|
Disconnects: []*pb.TransportSummary{
|
||||||
|
&pb.TransportSummary{
|
||||||
|
DurationMs: uint64(randomCount()),
|
||||||
|
BytesSent: uint64(randomCount()),
|
||||||
|
},
|
||||||
|
},
|
||||||
|
Protocol: common.Protocol_TCP,
|
||||||
|
},
|
||||||
|
},
|
||||||
|
Proxy: pb.ReportRequest_INBOUND,
|
||||||
|
}
|
||||||
|
|
||||||
|
_, err = client.Report(context.Background(), req)
|
||||||
|
if err != nil {
|
||||||
|
log.Fatal(err.Error())
|
||||||
|
}
|
||||||
|
|
||||||
time.Sleep(*sleep)
|
time.Sleep(*sleep)
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
Loading…
Reference in New Issue