File tree 4 files changed +13
-18
lines changed
4 files changed +13
-18
lines changed Original file line number Diff line number Diff line change 5
5
"testing"
6
6
"time"
7
7
8
- "github.com/coder/coder/v2/coderd/database/pubsub"
9
-
10
8
"github.com/stretchr/testify/require"
11
9
12
10
"cdr.dev/slog"
@@ -16,6 +14,7 @@ import (
16
14
"github.com/coder/coder/v2/coderd/database/dbgen"
17
15
"github.com/coder/coder/v2/coderd/database/dbtestutil"
18
16
"github.com/coder/coder/v2/coderd/database/dbtime"
17
+ "github.com/coder/coder/v2/coderd/database/pubsub"
19
18
"github.com/coder/coder/v2/coderd/rbac"
20
19
"github.com/coder/coder/v2/codersdk/agentsdk"
21
20
"github.com/coder/coder/v2/cryptorand"
Original file line number Diff line number Diff line change @@ -11,9 +11,6 @@ import (
11
11
"testing"
12
12
"time"
13
13
14
- "github.com/coder/coder/v2/coderd/database/provisionerjobs"
15
- "github.com/coder/coder/v2/coderd/database/pubsub"
16
-
17
14
"github.com/google/uuid"
18
15
"github.com/moby/moby/pkg/namesgenerator"
19
16
"github.com/sqlc-dev/pqtype"
@@ -22,6 +19,8 @@ import (
22
19
"github.com/coder/coder/v2/coderd/database"
23
20
"github.com/coder/coder/v2/coderd/database/dbauthz"
24
21
"github.com/coder/coder/v2/coderd/database/dbtime"
22
+ "github.com/coder/coder/v2/coderd/database/provisionerjobs"
23
+ "github.com/coder/coder/v2/coderd/database/pubsub"
25
24
"github.com/coder/coder/v2/coderd/rbac"
26
25
"github.com/coder/coder/v2/cryptorand"
27
26
)
Original file line number Diff line number Diff line change @@ -8,22 +8,19 @@ import (
8
8
"testing"
9
9
"time"
10
10
11
- "cdr.dev/slog"
12
- "cdr.dev/slog/sloggers/slogtest"
13
-
14
- "go.uber.org/atomic"
15
-
16
- "github.com/coder/coder/v2/coderd/database/provisionerjobs"
17
- "github.com/coder/coder/v2/coderd/database/pubsub"
18
-
19
11
"github.com/golang/mock/gomock"
20
12
"github.com/google/uuid"
21
13
"github.com/stretchr/testify/assert"
22
14
"github.com/stretchr/testify/require"
15
+ "go.uber.org/atomic"
23
16
17
+ "cdr.dev/slog"
18
+ "cdr.dev/slog/sloggers/slogtest"
24
19
"github.com/coder/coder/v2/coderd/database"
25
20
"github.com/coder/coder/v2/coderd/database/dbmock"
26
21
"github.com/coder/coder/v2/coderd/database/dbtime"
22
+ "github.com/coder/coder/v2/coderd/database/provisionerjobs"
23
+ "github.com/coder/coder/v2/coderd/database/pubsub"
27
24
"github.com/coder/coder/v2/coderd/provisionerdserver"
28
25
"github.com/coder/coder/v2/coderd/wsbuilder"
29
26
"github.com/coder/coder/v2/codersdk"
Original file line number Diff line number Diff line change @@ -145,11 +145,11 @@ service ProvisionerDaemon {
145
145
option deprecated = true ;
146
146
};
147
147
// AcquireJobWithCancel requests a job, blocking until
148
- // a job is available or the client sends CancelAcquire.
149
- // Server will send exactly one AcquiredJob, which is
150
- // empty if a cancel was successful. This RPC is a bidirectional
151
- // stream since both messages are asynchronous with no implied
152
- // ordering.
148
+ // a job is available or the client sends CancelAcquire.
149
+ // Server will send exactly one AcquiredJob, which is
150
+ // empty if a cancel was successful. This RPC is a bidirectional
151
+ // stream since both messages are asynchronous with no implied
152
+ // ordering.
153
153
rpc AcquireJobWithCancel (stream CancelAcquire ) returns (stream AcquiredJob );
154
154
155
155
rpc CommitQuota (CommitQuotaRequest ) returns (CommitQuotaResponse );
You can’t perform that action at this time.
0 commit comments