Movatterモバイル変換

[0]ホーム
URL:

Skip to content

Navigation Menu

Sign in
Appearance settings

Search code, repositories, users, issues, pull requests...

Provide feedback

We read every piece of feedback, and take your input very seriously.

Saved searches

Use saved searches to filter your results more quickly

 Sign up
Appearance settings

Commit30cfbe3

Browse files
committed
rename package
1 parentf4bfcb6 commit30cfbe3

File tree

4 files changed

+14
-14
lines changed

4 files changed

+14
-14
lines changed

‎scaletest/coderconnect/config.go‎renamed to ‎scaletest/workspaceupdates/config.go‎

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,4 +1,4 @@
1-
packagecoderconnect
1+
packageworkspaceupdates
22

33
import (
44
"sync"

‎scaletest/coderconnect/metrics.go‎renamed to ‎scaletest/workspaceupdates/metrics.go‎

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,4 +1,4 @@
1-
packagecoderconnect
1+
packageworkspaceupdates
22

33
import (
44
"strconv"

‎scaletest/coderconnect/run.go‎renamed to ‎scaletest/workspaceupdates/run.go‎

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -1,4 +1,4 @@
1-
packagecoderconnect
1+
packageworkspaceupdates
22

33
import (
44
"context"
@@ -87,9 +87,9 @@ func (r *Runner) Run(ctx context.Context, id string, logs io.Writer) error {
8787
defercancel()
8888

8989
logger.Info(ctx,"connecting to workspace updates stream")
90-
clients,err:=r.dialCoderConnect(dialCtx,client,user,logger)
90+
clients,err:=r.dialTailnet(dialCtx,client,user,logger)
9191
iferr!=nil {
92-
returnxerrors.Errorf("coder connect dial failed: %w",err)
92+
returnxerrors.Errorf("tailnet dial failed: %w",err)
9393
}
9494
logger.Info(ctx,"connected to workspace updates stream")
9595
deferclients.Closer.Close()
@@ -152,7 +152,7 @@ func (r *Runner) Run(ctx context.Context, id string, logs io.Writer) error {
152152
}
153153
}
154154

155-
func (r*Runner)dialCoderConnect(ctx context.Context,client*codersdk.Client,user codersdk.User,logger slog.Logger) (*tailnet.ControlProtocolClients,error) {
155+
func (r*Runner)dialTailnet(ctx context.Context,client*codersdk.Client,user codersdk.User,logger slog.Logger) (*tailnet.ControlProtocolClients,error) {
156156
u,err:=client.URL.Parse("/api/v2/tailnet")
157157
iferr!=nil {
158158
logger.Error(ctx,"failed to parse tailnet URL",slog.Error(err))

‎scaletest/coderconnect/run_test.go‎renamed to ‎scaletest/workspaceupdates/run_test.go‎

Lines changed: 8 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -1,4 +1,4 @@
1-
packagecoderconnect_test
1+
packageworkspaceupdates_test
22

33
import (
44
"io"
@@ -15,9 +15,9 @@ import (
1515
"github.com/coder/coder/v2/codersdk"
1616
"github.com/coder/coder/v2/provisioner/echo"
1717
"github.com/coder/coder/v2/provisionersdk/proto"
18-
"github.com/coder/coder/v2/scaletest/coderconnect"
1918
"github.com/coder/coder/v2/scaletest/createusers"
2019
"github.com/coder/coder/v2/scaletest/workspacebuild"
20+
"github.com/coder/coder/v2/scaletest/workspaceupdates"
2121
"github.com/coder/coder/v2/testutil"
2222
)
2323

@@ -70,13 +70,13 @@ func TestRun(t *testing.T) {
7070

7171
barrier:=new(sync.WaitGroup)
7272
barrier.Add(numUsers)
73-
metrics:=coderconnect.NewMetrics(prometheus.NewRegistry())
73+
metrics:=workspaceupdates.NewMetrics(prometheus.NewRegistry())
7474

7575
eg,runCtx:=errgroup.WithContext(ctx)
7676

77-
runners:=make([]*coderconnect.Runner,0,numUsers)
77+
runners:=make([]*workspaceupdates.Runner,0,numUsers)
7878
fori:=rangenumUsers {
79-
cfg:=coderconnect.Config{
79+
cfg:=workspaceupdates.Config{
8080
User: createusers.Config{
8181
OrganizationID:user.OrganizationID,
8282
},
@@ -96,7 +96,7 @@ func TestRun(t *testing.T) {
9696
err:=cfg.Validate()
9797
require.NoError(t,err)
9898

99-
runner:=coderconnect.NewRunner(client,cfg)
99+
runner:=workspaceupdates.NewRunner(client,cfg)
100100
runners=append(runners,runner)
101101
eg.Go(func()error {
102102
returnrunner.Run(runCtx,strconv.Itoa(i),io.Discard)
@@ -133,7 +133,7 @@ func TestRun(t *testing.T) {
133133

134134
for_,runner:=rangerunners {
135135
metrics:=runner.GetMetrics()
136-
require.Contains(t,metrics,coderconnect.WorkspaceUpdatesLatencyMetric)
137-
require.Len(t,metrics[coderconnect.WorkspaceUpdatesLatencyMetric],userWorkspaces)
136+
require.Contains(t,metrics,workspaceupdates.WorkspaceUpdatesLatencyMetric)
137+
require.Len(t,metrics[workspaceupdates.WorkspaceUpdatesLatencyMetric],userWorkspaces)
138138
}
139139
}

0 commit comments

Comments
 (0)
[8]ページ先頭
©2009-2025 Movatter.jp