@@ -27,8 +27,8 @@ import (
27
27
"github.com/coder/coder/scaletest/createworkspaces"
28
28
"github.com/coder/coder/scaletest/harness"
29
29
"github.com/coder/coder/scaletest/reconnectingpty"
30
- "github.com/coder/coder/scaletest/trafficgen"
31
30
"github.com/coder/coder/scaletest/workspacebuild"
31
+ "github.com/coder/coder/scaletest/workspacetraffic"
32
32
)
33
33
34
34
const scaletestTracerName = "coder_scaletest"
@@ -43,7 +43,7 @@ func (r *RootCmd) scaletest() *clibase.Cmd {
43
43
Children : []* clibase.Cmd {
44
44
r .scaletestCleanup (),
45
45
r .scaletestCreateWorkspaces (),
46
- r .scaletestTrafficGen (),
46
+ r .scaletestWorkspaceTraffic (),
47
47
},
48
48
}
49
49
@@ -894,7 +894,7 @@ func (r *RootCmd) scaletestCreateWorkspaces() *clibase.Cmd {
894
894
return cmd
895
895
}
896
896
897
- func (r * RootCmd ) scaletestTrafficGen () * clibase.Cmd {
897
+ func (r * RootCmd ) scaletestWorkspaceTraffic () * clibase.Cmd {
898
898
var (
899
899
duration time.Duration
900
900
tickInterval time.Duration
@@ -907,9 +907,8 @@ func (r *RootCmd) scaletestTrafficGen() *clibase.Cmd {
907
907
)
908
908
909
909
cmd := & clibase.Cmd {
910
- Use : "trafficgen" ,
911
- Hidden : true ,
912
- Short : "Generate traffic to scaletest workspaces" ,
910
+ Use : "workspace-traffic" ,
911
+ Short : "Generate traffic to scaletest workspaces through coderd" ,
913
912
Middleware : clibase .Chain (
914
913
r .InitClient (client ),
915
914
),
@@ -958,7 +957,7 @@ func (r *RootCmd) scaletestTrafficGen() *clibase.Cmd {
958
957
for idx , ws := range workspaces {
959
958
var (
960
959
agentID uuid.UUID
961
- name = "trafficgen "
960
+ name = "workspace-traffic "
962
961
id = strconv .Itoa (idx )
963
962
)
964
963
@@ -975,7 +974,7 @@ func (r *RootCmd) scaletestTrafficGen() *clibase.Cmd {
975
974
}
976
975
977
976
// Setup our workspace agent connection.
978
- config := trafficgen .Config {
977
+ config := workspacetraffic .Config {
979
978
AgentID : agentID ,
980
979
BytesPerTick : bytesPerTick ,
981
980
Duration : duration ,
@@ -985,7 +984,7 @@ func (r *RootCmd) scaletestTrafficGen() *clibase.Cmd {
985
984
if err := config .Validate (); err != nil {
986
985
return xerrors .Errorf ("validate config: %w" , err )
987
986
}
988
- var runner harness.Runnable = trafficgen .NewRunner (client , config )
987
+ var runner harness.Runnable = workspacetraffic .NewRunner (client , config )
989
988
if tracingEnabled {
990
989
runner = & runnableTraceWrapper {
991
990
tracer : tracer ,
@@ -1024,21 +1023,21 @@ func (r *RootCmd) scaletestTrafficGen() *clibase.Cmd {
1024
1023
cmd .Options = []clibase.Option {
1025
1024
{
1026
1025
Flag : "duration" ,
1027
- Env : "CODER_SCALETEST_TRAFFICGEN_DURATION " ,
1026
+ Env : "CODER_SCALETEST_WORKSPACE_TRAFFIC_DURATION " ,
1028
1027
Default : "10s" ,
1029
1028
Description : "How long to generate traffic for." ,
1030
1029
Value : clibase .DurationOf (& duration ),
1031
1030
},
1032
1031
{
1033
1032
Flag : "bytes-per-tick" ,
1034
- Env : "CODER_SCALETEST_TRAFFICGEN_BYTES_PER_TICK " ,
1033
+ Env : "CODER_SCALETEST_WORKSPACE_TRAFFIC_BYTES_PER_TICK " ,
1035
1034
Default : "1024" ,
1036
1035
Description : "How much traffic to generate per tick." ,
1037
1036
Value : clibase .Int64Of (& bytesPerTick ),
1038
1037
},
1039
1038
{
1040
1039
Flag : "tick-interval" ,
1041
- Env : "CODER_SCALETEST_TRAFFICGEN_TICK_INTERVAL " ,
1040
+ Env : "CODER_SCALETEST_WORKSPACE_TRAFFIC_TICK_INTERVAL " ,
1042
1041
Default : "100ms" ,
1043
1042
Description : "How often to send traffic." ,
1044
1043
Value : clibase .DurationOf (& tickInterval ),
0 commit comments