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

Commitf742cd1

Browse files
committed
implement dbmem and dbauthz
1 parent5f5579e commitf742cd1

File tree

2 files changed

+35
-0
lines changed

2 files changed

+35
-0
lines changed

‎coderd/database/dbauthz/dbauthz.go

Lines changed: 5 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -3390,6 +3390,11 @@ func (q *querier) InsertWorkspaceAgent(ctx context.Context, arg database.InsertW
33903390
returnq.db.InsertWorkspaceAgent(ctx,arg)
33913391
}
33923392

3393+
func (q*querier)InsertWorkspaceAgentDevcontainers(ctx context.Context,arg database.InsertWorkspaceAgentDevcontainersParams) ([]database.WorkspaceAgentDevcontainer,error) {
3394+
// TODO: This is used by the agent, should we have an rbac check here?
3395+
returnq.db.InsertWorkspaceAgentDevcontainers(ctx,arg)
3396+
}
3397+
33933398
func (q*querier)InsertWorkspaceAgentLogSources(ctx context.Context,arg database.InsertWorkspaceAgentLogSourcesParams) ([]database.WorkspaceAgentLogSource,error) {
33943399
// TODO: This is used by the agent, should we have an rbac check here?
33953400
returnq.db.InsertWorkspaceAgentLogSources(ctx,arg)

‎coderd/database/dbmem/dbmem.go

Lines changed: 30 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -237,6 +237,7 @@ type data struct {
237237
workspaceAgentStats []database.WorkspaceAgentStat
238238
workspaceAgentMemoryResourceMonitors []database.WorkspaceAgentMemoryResourceMonitor
239239
workspaceAgentVolumeResourceMonitors []database.WorkspaceAgentVolumeResourceMonitor
240+
workspaceAgentDevcontainers []database.WorkspaceAgentDevcontainer
240241
workspaceApps []database.WorkspaceApp
241242
workspaceAppAuditSessions []database.WorkspaceAppAuditSession
242243
workspaceAppStatsLastInsertIDint64
@@ -9051,6 +9052,35 @@ func (q *FakeQuerier) InsertWorkspaceAgent(_ context.Context, arg database.Inser
90519052
returnagent,nil
90529053
}
90539054

9055+
func (q*FakeQuerier)InsertWorkspaceAgentDevcontainers(_ context.Context,arg database.InsertWorkspaceAgentDevcontainersParams) ([]database.WorkspaceAgentDevcontainer,error) {
9056+
err:=validateDatabaseType(arg)
9057+
iferr!=nil {
9058+
returnnil,err
9059+
}
9060+
9061+
q.mutex.Lock()
9062+
deferq.mutex.Unlock()
9063+
9064+
for_,agent:=rangeq.workspaceAgents {
9065+
ifagent.ID==arg.WorkspaceAgentID {
9066+
vardevcontainers []database.WorkspaceAgentDevcontainer
9067+
fori,id:=rangearg.ID {
9068+
devcontainers=append(devcontainers, database.WorkspaceAgentDevcontainer{
9069+
WorkspaceAgentID:arg.WorkspaceAgentID,
9070+
CreatedAt:arg.CreatedAt,
9071+
ID:id,
9072+
WorkspaceFolder:arg.WorkspaceFolder[i],
9073+
ConfigPath:arg.ConfigPath[i],
9074+
})
9075+
}
9076+
q.workspaceAgentDevcontainers=append(q.workspaceAgentDevcontainers,devcontainers...)
9077+
returndevcontainers,nil
9078+
}
9079+
}
9080+
9081+
returnnil,errForeignKeyConstraint
9082+
}
9083+
90549084
func (q*FakeQuerier)InsertWorkspaceAgentLogSources(_ context.Context,arg database.InsertWorkspaceAgentLogSourcesParams) ([]database.WorkspaceAgentLogSource,error) {
90559085
err:=validateDatabaseType(arg)
90569086
iferr!=nil {

0 commit comments

Comments
 (0)

[8]ページ先頭

©2009-2025 Movatter.jp