(ctx context.Context, staleThreshold time.Time)
| 4184 | } |
| 4185 | |
| 4186 | func (q *querier) GetStaleChats(ctx context.Context, staleThreshold time.Time) ([]database.Chat, error) { |
| 4187 | // GetStaleChats is a system-level operation used by the chat processor for recovery. |
| 4188 | if err := q.authorizeContext(ctx, policy.ActionRead, rbac.ResourceChat); err != nil { |
| 4189 | return nil, err |
| 4190 | } |
| 4191 | return q.db.GetStaleChats(ctx, staleThreshold) |
| 4192 | } |
| 4193 | |
| 4194 | func (q *querier) GetTailnetPeers(ctx context.Context, id uuid.UUID) ([]database.TailnetPeer, error) { |
| 4195 | if err := q.authorizeContext(ctx, policy.ActionRead, rbac.ResourceTailnetCoordinator); err != nil { |
nothing calls this directly
no test coverage detected