(ctx context.Context, limitVal int32)
| 1604 | } |
| 1605 | |
| 1606 | func (q *querier) AcquireStaleChatDiffStatuses(ctx context.Context, limitVal int32) ([]database.AcquireStaleChatDiffStatusesRow, error) { |
| 1607 | // This is a system-level batch operation used by the gitsync |
| 1608 | // background worker. Per-object authorization is impractical |
| 1609 | // for a SKIP LOCKED acquisition query; callers must use |
| 1610 | // AsChatd context. |
| 1611 | if err := q.authorizeContext(ctx, policy.ActionUpdate, rbac.ResourceChat); err != nil { |
| 1612 | return nil, err |
| 1613 | } |
| 1614 | return q.db.AcquireStaleChatDiffStatuses(ctx, limitVal) |
| 1615 | } |
| 1616 | |
| 1617 | func (q *querier) ActivityBumpWorkspace(ctx context.Context, arg database.ActivityBumpWorkspaceParams) error { |
| 1618 | fetch := func(ctx context.Context, arg database.ActivityBumpWorkspaceParams) (database.Workspace, error) { |
nothing calls this directly
no test coverage detected