(ctx context.Context, arg database.BatchUpsertConnectionLogsParams)
| 1705 | } |
| 1706 | |
| 1707 | func (q *querier) BatchUpsertConnectionLogs(ctx context.Context, arg database.BatchUpsertConnectionLogsParams) error { |
| 1708 | if err := q.authorizeContext(ctx, policy.ActionUpdate, rbac.ResourceConnectionLog); err != nil { |
| 1709 | return err |
| 1710 | } |
| 1711 | return q.db.BatchUpsertConnectionLogs(ctx, arg) |
| 1712 | } |
| 1713 | |
| 1714 | func (q *querier) BulkMarkNotificationMessagesFailed(ctx context.Context, arg database.BulkMarkNotificationMessagesFailedParams) (int64, error) { |
| 1715 | if err := q.authorizeContext(ctx, policy.ActionUpdate, rbac.ResourceNotificationMessage); err != nil { |
nothing calls this directly
no test coverage detected