mirror of
https://github.com/coder/coder.git
synced 2025-07-03 16:13:58 +00:00
3036 lines
137 KiB
Go
3036 lines
137 KiB
Go
// Code generated by coderd/database/gen/metrics.
|
|
// Any function can be edited and will not be overwritten.
|
|
// New database functions are automatically generated!
|
|
package dbmetrics
|
|
|
|
import (
|
|
"context"
|
|
"slices"
|
|
"time"
|
|
|
|
"github.com/google/uuid"
|
|
"github.com/prometheus/client_golang/prometheus"
|
|
|
|
"cdr.dev/slog"
|
|
"github.com/coder/coder/v2/coderd/database"
|
|
"github.com/coder/coder/v2/coderd/rbac"
|
|
"github.com/coder/coder/v2/coderd/rbac/policy"
|
|
)
|
|
|
|
var (
|
|
// Force these imports, for some reason the autogen does not include them.
|
|
_ uuid.UUID
|
|
_ policy.Action
|
|
_ rbac.Objecter
|
|
)
|
|
|
|
const wrapname = "dbmetrics.metricsStore"
|
|
|
|
// NewQueryMetrics returns a database.Store that registers metrics for all queries to reg.
|
|
func NewQueryMetrics(s database.Store, logger slog.Logger, reg prometheus.Registerer) database.Store {
|
|
// Don't double-wrap.
|
|
if slices.Contains(s.Wrappers(), wrapname) {
|
|
return s
|
|
}
|
|
queryLatencies := prometheus.NewHistogramVec(prometheus.HistogramOpts{
|
|
Namespace: "coderd",
|
|
Subsystem: "db",
|
|
Name: "query_latencies_seconds",
|
|
Help: "Latency distribution of queries in seconds.",
|
|
Buckets: prometheus.DefBuckets,
|
|
}, []string{"query"})
|
|
reg.MustRegister(queryLatencies)
|
|
return &queryMetricsStore{
|
|
s: s,
|
|
queryLatencies: queryLatencies,
|
|
dbMetrics: NewDBMetrics(s, logger, reg).(*metricsStore),
|
|
}
|
|
}
|
|
|
|
var _ database.Store = (*queryMetricsStore)(nil)
|
|
|
|
type queryMetricsStore struct {
|
|
s database.Store
|
|
queryLatencies *prometheus.HistogramVec
|
|
dbMetrics *metricsStore
|
|
}
|
|
|
|
func (m queryMetricsStore) Wrappers() []string {
|
|
return append(m.s.Wrappers(), wrapname)
|
|
}
|
|
|
|
func (m queryMetricsStore) Ping(ctx context.Context) (time.Duration, error) {
|
|
start := time.Now()
|
|
duration, err := m.s.Ping(ctx)
|
|
m.queryLatencies.WithLabelValues("Ping").Observe(time.Since(start).Seconds())
|
|
return duration, err
|
|
}
|
|
|
|
func (m queryMetricsStore) PGLocks(ctx context.Context) (database.PGLocks, error) {
|
|
start := time.Now()
|
|
locks, err := m.s.PGLocks(ctx)
|
|
m.queryLatencies.WithLabelValues("PGLocks").Observe(time.Since(start).Seconds())
|
|
return locks, err
|
|
}
|
|
|
|
func (m queryMetricsStore) InTx(f func(database.Store) error, options *database.TxOptions) error {
|
|
return m.dbMetrics.InTx(f, options)
|
|
}
|
|
|
|
func (m queryMetricsStore) DeleteOrganization(ctx context.Context, id uuid.UUID) error {
|
|
start := time.Now()
|
|
r0 := m.s.UpdateOrganizationDeletedByID(ctx, database.UpdateOrganizationDeletedByIDParams{
|
|
ID: id,
|
|
UpdatedAt: time.Now(),
|
|
})
|
|
m.queryLatencies.WithLabelValues("DeleteOrganization").Observe(time.Since(start).Seconds())
|
|
return r0
|
|
}
|
|
|
|
func (m queryMetricsStore) AcquireLock(ctx context.Context, pgAdvisoryXactLock int64) error {
|
|
start := time.Now()
|
|
err := m.s.AcquireLock(ctx, pgAdvisoryXactLock)
|
|
m.queryLatencies.WithLabelValues("AcquireLock").Observe(time.Since(start).Seconds())
|
|
return err
|
|
}
|
|
|
|
func (m queryMetricsStore) AcquireNotificationMessages(ctx context.Context, arg database.AcquireNotificationMessagesParams) ([]database.AcquireNotificationMessagesRow, error) {
|
|
start := time.Now()
|
|
r0, r1 := m.s.AcquireNotificationMessages(ctx, arg)
|
|
m.queryLatencies.WithLabelValues("AcquireNotificationMessages").Observe(time.Since(start).Seconds())
|
|
return r0, r1
|
|
}
|
|
|
|
func (m queryMetricsStore) AcquireProvisionerJob(ctx context.Context, arg database.AcquireProvisionerJobParams) (database.ProvisionerJob, error) {
|
|
start := time.Now()
|
|
provisionerJob, err := m.s.AcquireProvisionerJob(ctx, arg)
|
|
m.queryLatencies.WithLabelValues("AcquireProvisionerJob").Observe(time.Since(start).Seconds())
|
|
return provisionerJob, err
|
|
}
|
|
|
|
func (m queryMetricsStore) ActivityBumpWorkspace(ctx context.Context, arg database.ActivityBumpWorkspaceParams) error {
|
|
start := time.Now()
|
|
r0 := m.s.ActivityBumpWorkspace(ctx, arg)
|
|
m.queryLatencies.WithLabelValues("ActivityBumpWorkspace").Observe(time.Since(start).Seconds())
|
|
return r0
|
|
}
|
|
|
|
func (m queryMetricsStore) AllUserIDs(ctx context.Context) ([]uuid.UUID, error) {
|
|
start := time.Now()
|
|
r0, r1 := m.s.AllUserIDs(ctx)
|
|
m.queryLatencies.WithLabelValues("AllUserIDs").Observe(time.Since(start).Seconds())
|
|
return r0, r1
|
|
}
|
|
|
|
func (m queryMetricsStore) ArchiveUnusedTemplateVersions(ctx context.Context, arg database.ArchiveUnusedTemplateVersionsParams) ([]uuid.UUID, error) {
|
|
start := time.Now()
|
|
r0, r1 := m.s.ArchiveUnusedTemplateVersions(ctx, arg)
|
|
m.queryLatencies.WithLabelValues("ArchiveUnusedTemplateVersions").Observe(time.Since(start).Seconds())
|
|
return r0, r1
|
|
}
|
|
|
|
func (m queryMetricsStore) BatchUpdateWorkspaceLastUsedAt(ctx context.Context, arg database.BatchUpdateWorkspaceLastUsedAtParams) error {
|
|
start := time.Now()
|
|
r0 := m.s.BatchUpdateWorkspaceLastUsedAt(ctx, arg)
|
|
m.queryLatencies.WithLabelValues("BatchUpdateWorkspaceLastUsedAt").Observe(time.Since(start).Seconds())
|
|
return r0
|
|
}
|
|
|
|
func (m queryMetricsStore) BatchUpdateWorkspaceNextStartAt(ctx context.Context, arg database.BatchUpdateWorkspaceNextStartAtParams) error {
|
|
start := time.Now()
|
|
r0 := m.s.BatchUpdateWorkspaceNextStartAt(ctx, arg)
|
|
m.queryLatencies.WithLabelValues("BatchUpdateWorkspaceNextStartAt").Observe(time.Since(start).Seconds())
|
|
return r0
|
|
}
|
|
|
|
func (m queryMetricsStore) BulkMarkNotificationMessagesFailed(ctx context.Context, arg database.BulkMarkNotificationMessagesFailedParams) (int64, error) {
|
|
start := time.Now()
|
|
r0, r1 := m.s.BulkMarkNotificationMessagesFailed(ctx, arg)
|
|
m.queryLatencies.WithLabelValues("BulkMarkNotificationMessagesFailed").Observe(time.Since(start).Seconds())
|
|
return r0, r1
|
|
}
|
|
|
|
func (m queryMetricsStore) BulkMarkNotificationMessagesSent(ctx context.Context, arg database.BulkMarkNotificationMessagesSentParams) (int64, error) {
|
|
start := time.Now()
|
|
r0, r1 := m.s.BulkMarkNotificationMessagesSent(ctx, arg)
|
|
m.queryLatencies.WithLabelValues("BulkMarkNotificationMessagesSent").Observe(time.Since(start).Seconds())
|
|
return r0, r1
|
|
}
|
|
|
|
func (m queryMetricsStore) CleanTailnetCoordinators(ctx context.Context) error {
|
|
start := time.Now()
|
|
err := m.s.CleanTailnetCoordinators(ctx)
|
|
m.queryLatencies.WithLabelValues("CleanTailnetCoordinators").Observe(time.Since(start).Seconds())
|
|
return err
|
|
}
|
|
|
|
func (m queryMetricsStore) CleanTailnetLostPeers(ctx context.Context) error {
|
|
start := time.Now()
|
|
r0 := m.s.CleanTailnetLostPeers(ctx)
|
|
m.queryLatencies.WithLabelValues("CleanTailnetLostPeers").Observe(time.Since(start).Seconds())
|
|
return r0
|
|
}
|
|
|
|
func (m queryMetricsStore) CleanTailnetTunnels(ctx context.Context) error {
|
|
start := time.Now()
|
|
r0 := m.s.CleanTailnetTunnels(ctx)
|
|
m.queryLatencies.WithLabelValues("CleanTailnetTunnels").Observe(time.Since(start).Seconds())
|
|
return r0
|
|
}
|
|
|
|
func (m queryMetricsStore) CountUnreadInboxNotificationsByUserID(ctx context.Context, userID uuid.UUID) (int64, error) {
|
|
start := time.Now()
|
|
r0, r1 := m.s.CountUnreadInboxNotificationsByUserID(ctx, userID)
|
|
m.queryLatencies.WithLabelValues("CountUnreadInboxNotificationsByUserID").Observe(time.Since(start).Seconds())
|
|
return r0, r1
|
|
}
|
|
|
|
func (m queryMetricsStore) CustomRoles(ctx context.Context, arg database.CustomRolesParams) ([]database.CustomRole, error) {
|
|
start := time.Now()
|
|
r0, r1 := m.s.CustomRoles(ctx, arg)
|
|
m.queryLatencies.WithLabelValues("CustomRoles").Observe(time.Since(start).Seconds())
|
|
return r0, r1
|
|
}
|
|
|
|
func (m queryMetricsStore) DeleteAPIKeyByID(ctx context.Context, id string) error {
|
|
start := time.Now()
|
|
err := m.s.DeleteAPIKeyByID(ctx, id)
|
|
m.queryLatencies.WithLabelValues("DeleteAPIKeyByID").Observe(time.Since(start).Seconds())
|
|
return err
|
|
}
|
|
|
|
func (m queryMetricsStore) DeleteAPIKeysByUserID(ctx context.Context, userID uuid.UUID) error {
|
|
start := time.Now()
|
|
err := m.s.DeleteAPIKeysByUserID(ctx, userID)
|
|
m.queryLatencies.WithLabelValues("DeleteAPIKeysByUserID").Observe(time.Since(start).Seconds())
|
|
return err
|
|
}
|
|
|
|
func (m queryMetricsStore) DeleteAllTailnetClientSubscriptions(ctx context.Context, arg database.DeleteAllTailnetClientSubscriptionsParams) error {
|
|
start := time.Now()
|
|
r0 := m.s.DeleteAllTailnetClientSubscriptions(ctx, arg)
|
|
m.queryLatencies.WithLabelValues("DeleteAllTailnetClientSubscriptions").Observe(time.Since(start).Seconds())
|
|
return r0
|
|
}
|
|
|
|
func (m queryMetricsStore) DeleteAllTailnetTunnels(ctx context.Context, arg database.DeleteAllTailnetTunnelsParams) error {
|
|
start := time.Now()
|
|
r0 := m.s.DeleteAllTailnetTunnels(ctx, arg)
|
|
m.queryLatencies.WithLabelValues("DeleteAllTailnetTunnels").Observe(time.Since(start).Seconds())
|
|
return r0
|
|
}
|
|
|
|
func (m queryMetricsStore) DeleteApplicationConnectAPIKeysByUserID(ctx context.Context, userID uuid.UUID) error {
|
|
start := time.Now()
|
|
err := m.s.DeleteApplicationConnectAPIKeysByUserID(ctx, userID)
|
|
m.queryLatencies.WithLabelValues("DeleteApplicationConnectAPIKeysByUserID").Observe(time.Since(start).Seconds())
|
|
return err
|
|
}
|
|
|
|
func (m queryMetricsStore) DeleteCoordinator(ctx context.Context, id uuid.UUID) error {
|
|
start := time.Now()
|
|
r0 := m.s.DeleteCoordinator(ctx, id)
|
|
m.queryLatencies.WithLabelValues("DeleteCoordinator").Observe(time.Since(start).Seconds())
|
|
return r0
|
|
}
|
|
|
|
func (m queryMetricsStore) DeleteCryptoKey(ctx context.Context, arg database.DeleteCryptoKeyParams) (database.CryptoKey, error) {
|
|
start := time.Now()
|
|
r0, r1 := m.s.DeleteCryptoKey(ctx, arg)
|
|
m.queryLatencies.WithLabelValues("DeleteCryptoKey").Observe(time.Since(start).Seconds())
|
|
return r0, r1
|
|
}
|
|
|
|
func (m queryMetricsStore) DeleteCustomRole(ctx context.Context, arg database.DeleteCustomRoleParams) error {
|
|
start := time.Now()
|
|
r0 := m.s.DeleteCustomRole(ctx, arg)
|
|
m.queryLatencies.WithLabelValues("DeleteCustomRole").Observe(time.Since(start).Seconds())
|
|
return r0
|
|
}
|
|
|
|
func (m queryMetricsStore) DeleteExternalAuthLink(ctx context.Context, arg database.DeleteExternalAuthLinkParams) error {
|
|
start := time.Now()
|
|
r0 := m.s.DeleteExternalAuthLink(ctx, arg)
|
|
m.queryLatencies.WithLabelValues("DeleteExternalAuthLink").Observe(time.Since(start).Seconds())
|
|
return r0
|
|
}
|
|
|
|
func (m queryMetricsStore) DeleteGitSSHKey(ctx context.Context, userID uuid.UUID) error {
|
|
start := time.Now()
|
|
err := m.s.DeleteGitSSHKey(ctx, userID)
|
|
m.queryLatencies.WithLabelValues("DeleteGitSSHKey").Observe(time.Since(start).Seconds())
|
|
return err
|
|
}
|
|
|
|
func (m queryMetricsStore) DeleteGroupByID(ctx context.Context, id uuid.UUID) error {
|
|
start := time.Now()
|
|
err := m.s.DeleteGroupByID(ctx, id)
|
|
m.queryLatencies.WithLabelValues("DeleteGroupByID").Observe(time.Since(start).Seconds())
|
|
return err
|
|
}
|
|
|
|
func (m queryMetricsStore) DeleteGroupMemberFromGroup(ctx context.Context, arg database.DeleteGroupMemberFromGroupParams) error {
|
|
start := time.Now()
|
|
err := m.s.DeleteGroupMemberFromGroup(ctx, arg)
|
|
m.queryLatencies.WithLabelValues("DeleteGroupMemberFromGroup").Observe(time.Since(start).Seconds())
|
|
return err
|
|
}
|
|
|
|
func (m queryMetricsStore) DeleteLicense(ctx context.Context, id int32) (int32, error) {
|
|
start := time.Now()
|
|
licenseID, err := m.s.DeleteLicense(ctx, id)
|
|
m.queryLatencies.WithLabelValues("DeleteLicense").Observe(time.Since(start).Seconds())
|
|
return licenseID, err
|
|
}
|
|
|
|
func (m queryMetricsStore) DeleteOAuth2ProviderAppByID(ctx context.Context, id uuid.UUID) error {
|
|
start := time.Now()
|
|
r0 := m.s.DeleteOAuth2ProviderAppByID(ctx, id)
|
|
m.queryLatencies.WithLabelValues("DeleteOAuth2ProviderAppByID").Observe(time.Since(start).Seconds())
|
|
return r0
|
|
}
|
|
|
|
func (m queryMetricsStore) DeleteOAuth2ProviderAppCodeByID(ctx context.Context, id uuid.UUID) error {
|
|
start := time.Now()
|
|
r0 := m.s.DeleteOAuth2ProviderAppCodeByID(ctx, id)
|
|
m.queryLatencies.WithLabelValues("DeleteOAuth2ProviderAppCodeByID").Observe(time.Since(start).Seconds())
|
|
return r0
|
|
}
|
|
|
|
func (m queryMetricsStore) DeleteOAuth2ProviderAppCodesByAppAndUserID(ctx context.Context, arg database.DeleteOAuth2ProviderAppCodesByAppAndUserIDParams) error {
|
|
start := time.Now()
|
|
r0 := m.s.DeleteOAuth2ProviderAppCodesByAppAndUserID(ctx, arg)
|
|
m.queryLatencies.WithLabelValues("DeleteOAuth2ProviderAppCodesByAppAndUserID").Observe(time.Since(start).Seconds())
|
|
return r0
|
|
}
|
|
|
|
func (m queryMetricsStore) DeleteOAuth2ProviderAppSecretByID(ctx context.Context, id uuid.UUID) error {
|
|
start := time.Now()
|
|
r0 := m.s.DeleteOAuth2ProviderAppSecretByID(ctx, id)
|
|
m.queryLatencies.WithLabelValues("DeleteOAuth2ProviderAppSecretByID").Observe(time.Since(start).Seconds())
|
|
return r0
|
|
}
|
|
|
|
func (m queryMetricsStore) DeleteOAuth2ProviderAppTokensByAppAndUserID(ctx context.Context, arg database.DeleteOAuth2ProviderAppTokensByAppAndUserIDParams) error {
|
|
start := time.Now()
|
|
r0 := m.s.DeleteOAuth2ProviderAppTokensByAppAndUserID(ctx, arg)
|
|
m.queryLatencies.WithLabelValues("DeleteOAuth2ProviderAppTokensByAppAndUserID").Observe(time.Since(start).Seconds())
|
|
return r0
|
|
}
|
|
|
|
func (m queryMetricsStore) DeleteOldNotificationMessages(ctx context.Context) error {
|
|
start := time.Now()
|
|
r0 := m.s.DeleteOldNotificationMessages(ctx)
|
|
m.queryLatencies.WithLabelValues("DeleteOldNotificationMessages").Observe(time.Since(start).Seconds())
|
|
return r0
|
|
}
|
|
|
|
func (m queryMetricsStore) DeleteOldProvisionerDaemons(ctx context.Context) error {
|
|
start := time.Now()
|
|
r0 := m.s.DeleteOldProvisionerDaemons(ctx)
|
|
m.queryLatencies.WithLabelValues("DeleteOldProvisionerDaemons").Observe(time.Since(start).Seconds())
|
|
return r0
|
|
}
|
|
|
|
func (m queryMetricsStore) DeleteOldWorkspaceAgentLogs(ctx context.Context, arg time.Time) error {
|
|
start := time.Now()
|
|
r0 := m.s.DeleteOldWorkspaceAgentLogs(ctx, arg)
|
|
m.queryLatencies.WithLabelValues("DeleteOldWorkspaceAgentLogs").Observe(time.Since(start).Seconds())
|
|
return r0
|
|
}
|
|
|
|
func (m queryMetricsStore) DeleteOldWorkspaceAgentStats(ctx context.Context) error {
|
|
start := time.Now()
|
|
err := m.s.DeleteOldWorkspaceAgentStats(ctx)
|
|
m.queryLatencies.WithLabelValues("DeleteOldWorkspaceAgentStats").Observe(time.Since(start).Seconds())
|
|
return err
|
|
}
|
|
|
|
func (m queryMetricsStore) DeleteOrganizationMember(ctx context.Context, arg database.DeleteOrganizationMemberParams) error {
|
|
start := time.Now()
|
|
r0 := m.s.DeleteOrganizationMember(ctx, arg)
|
|
m.queryLatencies.WithLabelValues("DeleteOrganizationMember").Observe(time.Since(start).Seconds())
|
|
return r0
|
|
}
|
|
|
|
func (m queryMetricsStore) DeleteProvisionerKey(ctx context.Context, id uuid.UUID) error {
|
|
start := time.Now()
|
|
r0 := m.s.DeleteProvisionerKey(ctx, id)
|
|
m.queryLatencies.WithLabelValues("DeleteProvisionerKey").Observe(time.Since(start).Seconds())
|
|
return r0
|
|
}
|
|
|
|
func (m queryMetricsStore) DeleteReplicasUpdatedBefore(ctx context.Context, updatedAt time.Time) error {
|
|
start := time.Now()
|
|
err := m.s.DeleteReplicasUpdatedBefore(ctx, updatedAt)
|
|
m.queryLatencies.WithLabelValues("DeleteReplicasUpdatedBefore").Observe(time.Since(start).Seconds())
|
|
return err
|
|
}
|
|
|
|
func (m queryMetricsStore) DeleteRuntimeConfig(ctx context.Context, key string) error {
|
|
start := time.Now()
|
|
r0 := m.s.DeleteRuntimeConfig(ctx, key)
|
|
m.queryLatencies.WithLabelValues("DeleteRuntimeConfig").Observe(time.Since(start).Seconds())
|
|
return r0
|
|
}
|
|
|
|
func (m queryMetricsStore) DeleteTailnetAgent(ctx context.Context, arg database.DeleteTailnetAgentParams) (database.DeleteTailnetAgentRow, error) {
|
|
start := time.Now()
|
|
r0, r1 := m.s.DeleteTailnetAgent(ctx, arg)
|
|
m.queryLatencies.WithLabelValues("DeleteTailnetAgent").Observe(time.Since(start).Seconds())
|
|
return r0, r1
|
|
}
|
|
|
|
func (m queryMetricsStore) DeleteTailnetClient(ctx context.Context, arg database.DeleteTailnetClientParams) (database.DeleteTailnetClientRow, error) {
|
|
start := time.Now()
|
|
r0, r1 := m.s.DeleteTailnetClient(ctx, arg)
|
|
m.queryLatencies.WithLabelValues("DeleteTailnetClient").Observe(time.Since(start).Seconds())
|
|
return r0, r1
|
|
}
|
|
|
|
func (m queryMetricsStore) DeleteTailnetClientSubscription(ctx context.Context, arg database.DeleteTailnetClientSubscriptionParams) error {
|
|
start := time.Now()
|
|
r0 := m.s.DeleteTailnetClientSubscription(ctx, arg)
|
|
m.queryLatencies.WithLabelValues("DeleteTailnetClientSubscription").Observe(time.Since(start).Seconds())
|
|
return r0
|
|
}
|
|
|
|
func (m queryMetricsStore) DeleteTailnetPeer(ctx context.Context, arg database.DeleteTailnetPeerParams) (database.DeleteTailnetPeerRow, error) {
|
|
start := time.Now()
|
|
r0, r1 := m.s.DeleteTailnetPeer(ctx, arg)
|
|
m.queryLatencies.WithLabelValues("DeleteTailnetPeer").Observe(time.Since(start).Seconds())
|
|
return r0, r1
|
|
}
|
|
|
|
func (m queryMetricsStore) DeleteTailnetTunnel(ctx context.Context, arg database.DeleteTailnetTunnelParams) (database.DeleteTailnetTunnelRow, error) {
|
|
start := time.Now()
|
|
r0, r1 := m.s.DeleteTailnetTunnel(ctx, arg)
|
|
m.queryLatencies.WithLabelValues("DeleteTailnetTunnel").Observe(time.Since(start).Seconds())
|
|
return r0, r1
|
|
}
|
|
|
|
func (m queryMetricsStore) DeleteWorkspaceAgentPortShare(ctx context.Context, arg database.DeleteWorkspaceAgentPortShareParams) error {
|
|
start := time.Now()
|
|
r0 := m.s.DeleteWorkspaceAgentPortShare(ctx, arg)
|
|
m.queryLatencies.WithLabelValues("DeleteWorkspaceAgentPortShare").Observe(time.Since(start).Seconds())
|
|
return r0
|
|
}
|
|
|
|
func (m queryMetricsStore) DeleteWorkspaceAgentPortSharesByTemplate(ctx context.Context, templateID uuid.UUID) error {
|
|
start := time.Now()
|
|
r0 := m.s.DeleteWorkspaceAgentPortSharesByTemplate(ctx, templateID)
|
|
m.queryLatencies.WithLabelValues("DeleteWorkspaceAgentPortSharesByTemplate").Observe(time.Since(start).Seconds())
|
|
return r0
|
|
}
|
|
|
|
func (m queryMetricsStore) DisableForeignKeysAndTriggers(ctx context.Context) error {
|
|
start := time.Now()
|
|
r0 := m.s.DisableForeignKeysAndTriggers(ctx)
|
|
m.queryLatencies.WithLabelValues("DisableForeignKeysAndTriggers").Observe(time.Since(start).Seconds())
|
|
return r0
|
|
}
|
|
|
|
func (m queryMetricsStore) EnqueueNotificationMessage(ctx context.Context, arg database.EnqueueNotificationMessageParams) error {
|
|
start := time.Now()
|
|
r0 := m.s.EnqueueNotificationMessage(ctx, arg)
|
|
m.queryLatencies.WithLabelValues("EnqueueNotificationMessage").Observe(time.Since(start).Seconds())
|
|
return r0
|
|
}
|
|
|
|
func (m queryMetricsStore) FavoriteWorkspace(ctx context.Context, arg uuid.UUID) error {
|
|
start := time.Now()
|
|
r0 := m.s.FavoriteWorkspace(ctx, arg)
|
|
m.queryLatencies.WithLabelValues("FavoriteWorkspace").Observe(time.Since(start).Seconds())
|
|
return r0
|
|
}
|
|
|
|
func (m queryMetricsStore) FetchMemoryResourceMonitorsByAgentID(ctx context.Context, agentID uuid.UUID) (database.WorkspaceAgentMemoryResourceMonitor, error) {
|
|
start := time.Now()
|
|
r0, r1 := m.s.FetchMemoryResourceMonitorsByAgentID(ctx, agentID)
|
|
m.queryLatencies.WithLabelValues("FetchMemoryResourceMonitorsByAgentID").Observe(time.Since(start).Seconds())
|
|
return r0, r1
|
|
}
|
|
|
|
func (m queryMetricsStore) FetchMemoryResourceMonitorsUpdatedAfter(ctx context.Context, updatedAt time.Time) ([]database.WorkspaceAgentMemoryResourceMonitor, error) {
|
|
start := time.Now()
|
|
r0, r1 := m.s.FetchMemoryResourceMonitorsUpdatedAfter(ctx, updatedAt)
|
|
m.queryLatencies.WithLabelValues("FetchMemoryResourceMonitorsUpdatedAfter").Observe(time.Since(start).Seconds())
|
|
return r0, r1
|
|
}
|
|
|
|
func (m queryMetricsStore) FetchNewMessageMetadata(ctx context.Context, arg database.FetchNewMessageMetadataParams) (database.FetchNewMessageMetadataRow, error) {
|
|
start := time.Now()
|
|
r0, r1 := m.s.FetchNewMessageMetadata(ctx, arg)
|
|
m.queryLatencies.WithLabelValues("FetchNewMessageMetadata").Observe(time.Since(start).Seconds())
|
|
return r0, r1
|
|
}
|
|
|
|
func (m queryMetricsStore) FetchVolumesResourceMonitorsByAgentID(ctx context.Context, agentID uuid.UUID) ([]database.WorkspaceAgentVolumeResourceMonitor, error) {
|
|
start := time.Now()
|
|
r0, r1 := m.s.FetchVolumesResourceMonitorsByAgentID(ctx, agentID)
|
|
m.queryLatencies.WithLabelValues("FetchVolumesResourceMonitorsByAgentID").Observe(time.Since(start).Seconds())
|
|
return r0, r1
|
|
}
|
|
|
|
func (m queryMetricsStore) FetchVolumesResourceMonitorsUpdatedAfter(ctx context.Context, updatedAt time.Time) ([]database.WorkspaceAgentVolumeResourceMonitor, error) {
|
|
start := time.Now()
|
|
r0, r1 := m.s.FetchVolumesResourceMonitorsUpdatedAfter(ctx, updatedAt)
|
|
m.queryLatencies.WithLabelValues("FetchVolumesResourceMonitorsUpdatedAfter").Observe(time.Since(start).Seconds())
|
|
return r0, r1
|
|
}
|
|
|
|
func (m queryMetricsStore) GetAPIKeyByID(ctx context.Context, id string) (database.APIKey, error) {
|
|
start := time.Now()
|
|
apiKey, err := m.s.GetAPIKeyByID(ctx, id)
|
|
m.queryLatencies.WithLabelValues("GetAPIKeyByID").Observe(time.Since(start).Seconds())
|
|
return apiKey, err
|
|
}
|
|
|
|
func (m queryMetricsStore) GetAPIKeyByName(ctx context.Context, arg database.GetAPIKeyByNameParams) (database.APIKey, error) {
|
|
start := time.Now()
|
|
apiKey, err := m.s.GetAPIKeyByName(ctx, arg)
|
|
m.queryLatencies.WithLabelValues("GetAPIKeyByName").Observe(time.Since(start).Seconds())
|
|
return apiKey, err
|
|
}
|
|
|
|
func (m queryMetricsStore) GetAPIKeysByLoginType(ctx context.Context, loginType database.LoginType) ([]database.APIKey, error) {
|
|
start := time.Now()
|
|
apiKeys, err := m.s.GetAPIKeysByLoginType(ctx, loginType)
|
|
m.queryLatencies.WithLabelValues("GetAPIKeysByLoginType").Observe(time.Since(start).Seconds())
|
|
return apiKeys, err
|
|
}
|
|
|
|
func (m queryMetricsStore) GetAPIKeysByUserID(ctx context.Context, arg database.GetAPIKeysByUserIDParams) ([]database.APIKey, error) {
|
|
start := time.Now()
|
|
apiKeys, err := m.s.GetAPIKeysByUserID(ctx, arg)
|
|
m.queryLatencies.WithLabelValues("GetAPIKeysByUserID").Observe(time.Since(start).Seconds())
|
|
return apiKeys, err
|
|
}
|
|
|
|
func (m queryMetricsStore) GetAPIKeysLastUsedAfter(ctx context.Context, lastUsed time.Time) ([]database.APIKey, error) {
|
|
start := time.Now()
|
|
apiKeys, err := m.s.GetAPIKeysLastUsedAfter(ctx, lastUsed)
|
|
m.queryLatencies.WithLabelValues("GetAPIKeysLastUsedAfter").Observe(time.Since(start).Seconds())
|
|
return apiKeys, err
|
|
}
|
|
|
|
func (m queryMetricsStore) GetActiveUserCount(ctx context.Context) (int64, error) {
|
|
start := time.Now()
|
|
count, err := m.s.GetActiveUserCount(ctx)
|
|
m.queryLatencies.WithLabelValues("GetActiveUserCount").Observe(time.Since(start).Seconds())
|
|
return count, err
|
|
}
|
|
|
|
func (m queryMetricsStore) GetActiveWorkspaceBuildsByTemplateID(ctx context.Context, templateID uuid.UUID) ([]database.WorkspaceBuild, error) {
|
|
start := time.Now()
|
|
r0, r1 := m.s.GetActiveWorkspaceBuildsByTemplateID(ctx, templateID)
|
|
m.queryLatencies.WithLabelValues("GetActiveWorkspaceBuildsByTemplateID").Observe(time.Since(start).Seconds())
|
|
return r0, r1
|
|
}
|
|
|
|
func (m queryMetricsStore) GetAllTailnetAgents(ctx context.Context) ([]database.TailnetAgent, error) {
|
|
start := time.Now()
|
|
r0, r1 := m.s.GetAllTailnetAgents(ctx)
|
|
m.queryLatencies.WithLabelValues("GetAllTailnetAgents").Observe(time.Since(start).Seconds())
|
|
return r0, r1
|
|
}
|
|
|
|
func (m queryMetricsStore) GetAllTailnetCoordinators(ctx context.Context) ([]database.TailnetCoordinator, error) {
|
|
start := time.Now()
|
|
r0, r1 := m.s.GetAllTailnetCoordinators(ctx)
|
|
m.queryLatencies.WithLabelValues("GetAllTailnetCoordinators").Observe(time.Since(start).Seconds())
|
|
return r0, r1
|
|
}
|
|
|
|
func (m queryMetricsStore) GetAllTailnetPeers(ctx context.Context) ([]database.TailnetPeer, error) {
|
|
start := time.Now()
|
|
r0, r1 := m.s.GetAllTailnetPeers(ctx)
|
|
m.queryLatencies.WithLabelValues("GetAllTailnetPeers").Observe(time.Since(start).Seconds())
|
|
return r0, r1
|
|
}
|
|
|
|
func (m queryMetricsStore) GetAllTailnetTunnels(ctx context.Context) ([]database.TailnetTunnel, error) {
|
|
start := time.Now()
|
|
r0, r1 := m.s.GetAllTailnetTunnels(ctx)
|
|
m.queryLatencies.WithLabelValues("GetAllTailnetTunnels").Observe(time.Since(start).Seconds())
|
|
return r0, r1
|
|
}
|
|
|
|
func (m queryMetricsStore) GetAnnouncementBanners(ctx context.Context) (string, error) {
|
|
start := time.Now()
|
|
r0, r1 := m.s.GetAnnouncementBanners(ctx)
|
|
m.queryLatencies.WithLabelValues("GetAnnouncementBanners").Observe(time.Since(start).Seconds())
|
|
return r0, r1
|
|
}
|
|
|
|
func (m queryMetricsStore) GetAppSecurityKey(ctx context.Context) (string, error) {
|
|
start := time.Now()
|
|
key, err := m.s.GetAppSecurityKey(ctx)
|
|
m.queryLatencies.WithLabelValues("GetAppSecurityKey").Observe(time.Since(start).Seconds())
|
|
return key, err
|
|
}
|
|
|
|
func (m queryMetricsStore) GetApplicationName(ctx context.Context) (string, error) {
|
|
start := time.Now()
|
|
r0, r1 := m.s.GetApplicationName(ctx)
|
|
m.queryLatencies.WithLabelValues("GetApplicationName").Observe(time.Since(start).Seconds())
|
|
return r0, r1
|
|
}
|
|
|
|
func (m queryMetricsStore) GetAuditLogsOffset(ctx context.Context, arg database.GetAuditLogsOffsetParams) ([]database.GetAuditLogsOffsetRow, error) {
|
|
start := time.Now()
|
|
rows, err := m.s.GetAuditLogsOffset(ctx, arg)
|
|
m.queryLatencies.WithLabelValues("GetAuditLogsOffset").Observe(time.Since(start).Seconds())
|
|
return rows, err
|
|
}
|
|
|
|
func (m queryMetricsStore) GetAuthorizationUserRoles(ctx context.Context, userID uuid.UUID) (database.GetAuthorizationUserRolesRow, error) {
|
|
start := time.Now()
|
|
row, err := m.s.GetAuthorizationUserRoles(ctx, userID)
|
|
m.queryLatencies.WithLabelValues("GetAuthorizationUserRoles").Observe(time.Since(start).Seconds())
|
|
return row, err
|
|
}
|
|
|
|
func (m queryMetricsStore) GetCoordinatorResumeTokenSigningKey(ctx context.Context) (string, error) {
|
|
start := time.Now()
|
|
r0, r1 := m.s.GetCoordinatorResumeTokenSigningKey(ctx)
|
|
m.queryLatencies.WithLabelValues("GetCoordinatorResumeTokenSigningKey").Observe(time.Since(start).Seconds())
|
|
return r0, r1
|
|
}
|
|
|
|
func (m queryMetricsStore) GetCryptoKeyByFeatureAndSequence(ctx context.Context, arg database.GetCryptoKeyByFeatureAndSequenceParams) (database.CryptoKey, error) {
|
|
start := time.Now()
|
|
r0, r1 := m.s.GetCryptoKeyByFeatureAndSequence(ctx, arg)
|
|
m.queryLatencies.WithLabelValues("GetCryptoKeyByFeatureAndSequence").Observe(time.Since(start).Seconds())
|
|
return r0, r1
|
|
}
|
|
|
|
func (m queryMetricsStore) GetCryptoKeys(ctx context.Context) ([]database.CryptoKey, error) {
|
|
start := time.Now()
|
|
r0, r1 := m.s.GetCryptoKeys(ctx)
|
|
m.queryLatencies.WithLabelValues("GetCryptoKeys").Observe(time.Since(start).Seconds())
|
|
return r0, r1
|
|
}
|
|
|
|
func (m queryMetricsStore) GetCryptoKeysByFeature(ctx context.Context, feature database.CryptoKeyFeature) ([]database.CryptoKey, error) {
|
|
start := time.Now()
|
|
r0, r1 := m.s.GetCryptoKeysByFeature(ctx, feature)
|
|
m.queryLatencies.WithLabelValues("GetCryptoKeysByFeature").Observe(time.Since(start).Seconds())
|
|
return r0, r1
|
|
}
|
|
|
|
func (m queryMetricsStore) GetDBCryptKeys(ctx context.Context) ([]database.DBCryptKey, error) {
|
|
start := time.Now()
|
|
r0, r1 := m.s.GetDBCryptKeys(ctx)
|
|
m.queryLatencies.WithLabelValues("GetDBCryptKeys").Observe(time.Since(start).Seconds())
|
|
return r0, r1
|
|
}
|
|
|
|
func (m queryMetricsStore) GetDERPMeshKey(ctx context.Context) (string, error) {
|
|
start := time.Now()
|
|
key, err := m.s.GetDERPMeshKey(ctx)
|
|
m.queryLatencies.WithLabelValues("GetDERPMeshKey").Observe(time.Since(start).Seconds())
|
|
return key, err
|
|
}
|
|
|
|
func (m queryMetricsStore) GetDefaultOrganization(ctx context.Context) (database.Organization, error) {
|
|
start := time.Now()
|
|
r0, r1 := m.s.GetDefaultOrganization(ctx)
|
|
m.queryLatencies.WithLabelValues("GetDefaultOrganization").Observe(time.Since(start).Seconds())
|
|
return r0, r1
|
|
}
|
|
|
|
func (m queryMetricsStore) GetDefaultProxyConfig(ctx context.Context) (database.GetDefaultProxyConfigRow, error) {
|
|
start := time.Now()
|
|
resp, err := m.s.GetDefaultProxyConfig(ctx)
|
|
m.queryLatencies.WithLabelValues("GetDefaultProxyConfig").Observe(time.Since(start).Seconds())
|
|
return resp, err
|
|
}
|
|
|
|
func (m queryMetricsStore) GetDeploymentDAUs(ctx context.Context, tzOffset int32) ([]database.GetDeploymentDAUsRow, error) {
|
|
start := time.Now()
|
|
rows, err := m.s.GetDeploymentDAUs(ctx, tzOffset)
|
|
m.queryLatencies.WithLabelValues("GetDeploymentDAUs").Observe(time.Since(start).Seconds())
|
|
return rows, err
|
|
}
|
|
|
|
func (m queryMetricsStore) GetDeploymentID(ctx context.Context) (string, error) {
|
|
start := time.Now()
|
|
id, err := m.s.GetDeploymentID(ctx)
|
|
m.queryLatencies.WithLabelValues("GetDeploymentID").Observe(time.Since(start).Seconds())
|
|
return id, err
|
|
}
|
|
|
|
func (m queryMetricsStore) GetDeploymentWorkspaceAgentStats(ctx context.Context, createdAt time.Time) (database.GetDeploymentWorkspaceAgentStatsRow, error) {
|
|
start := time.Now()
|
|
row, err := m.s.GetDeploymentWorkspaceAgentStats(ctx, createdAt)
|
|
m.queryLatencies.WithLabelValues("GetDeploymentWorkspaceAgentStats").Observe(time.Since(start).Seconds())
|
|
return row, err
|
|
}
|
|
|
|
func (m queryMetricsStore) GetDeploymentWorkspaceAgentUsageStats(ctx context.Context, createdAt time.Time) (database.GetDeploymentWorkspaceAgentUsageStatsRow, error) {
|
|
start := time.Now()
|
|
r0, r1 := m.s.GetDeploymentWorkspaceAgentUsageStats(ctx, createdAt)
|
|
m.queryLatencies.WithLabelValues("GetDeploymentWorkspaceAgentUsageStats").Observe(time.Since(start).Seconds())
|
|
return r0, r1
|
|
}
|
|
|
|
func (m queryMetricsStore) GetDeploymentWorkspaceStats(ctx context.Context) (database.GetDeploymentWorkspaceStatsRow, error) {
|
|
start := time.Now()
|
|
row, err := m.s.GetDeploymentWorkspaceStats(ctx)
|
|
m.queryLatencies.WithLabelValues("GetDeploymentWorkspaceStats").Observe(time.Since(start).Seconds())
|
|
return row, err
|
|
}
|
|
|
|
func (m queryMetricsStore) GetEligibleProvisionerDaemonsByProvisionerJobIDs(ctx context.Context, provisionerJobIds []uuid.UUID) ([]database.GetEligibleProvisionerDaemonsByProvisionerJobIDsRow, error) {
|
|
start := time.Now()
|
|
r0, r1 := m.s.GetEligibleProvisionerDaemonsByProvisionerJobIDs(ctx, provisionerJobIds)
|
|
m.queryLatencies.WithLabelValues("GetEligibleProvisionerDaemonsByProvisionerJobIDs").Observe(time.Since(start).Seconds())
|
|
return r0, r1
|
|
}
|
|
|
|
func (m queryMetricsStore) GetExternalAuthLink(ctx context.Context, arg database.GetExternalAuthLinkParams) (database.ExternalAuthLink, error) {
|
|
start := time.Now()
|
|
link, err := m.s.GetExternalAuthLink(ctx, arg)
|
|
m.queryLatencies.WithLabelValues("GetExternalAuthLink").Observe(time.Since(start).Seconds())
|
|
return link, err
|
|
}
|
|
|
|
func (m queryMetricsStore) GetExternalAuthLinksByUserID(ctx context.Context, userID uuid.UUID) ([]database.ExternalAuthLink, error) {
|
|
start := time.Now()
|
|
r0, r1 := m.s.GetExternalAuthLinksByUserID(ctx, userID)
|
|
m.queryLatencies.WithLabelValues("GetExternalAuthLinksByUserID").Observe(time.Since(start).Seconds())
|
|
return r0, r1
|
|
}
|
|
|
|
func (m queryMetricsStore) GetFailedWorkspaceBuildsByTemplateID(ctx context.Context, arg database.GetFailedWorkspaceBuildsByTemplateIDParams) ([]database.GetFailedWorkspaceBuildsByTemplateIDRow, error) {
|
|
start := time.Now()
|
|
r0, r1 := m.s.GetFailedWorkspaceBuildsByTemplateID(ctx, arg)
|
|
m.queryLatencies.WithLabelValues("GetFailedWorkspaceBuildsByTemplateID").Observe(time.Since(start).Seconds())
|
|
return r0, r1
|
|
}
|
|
|
|
func (m queryMetricsStore) GetFileByHashAndCreator(ctx context.Context, arg database.GetFileByHashAndCreatorParams) (database.File, error) {
|
|
start := time.Now()
|
|
file, err := m.s.GetFileByHashAndCreator(ctx, arg)
|
|
m.queryLatencies.WithLabelValues("GetFileByHashAndCreator").Observe(time.Since(start).Seconds())
|
|
return file, err
|
|
}
|
|
|
|
func (m queryMetricsStore) GetFileByID(ctx context.Context, id uuid.UUID) (database.File, error) {
|
|
start := time.Now()
|
|
file, err := m.s.GetFileByID(ctx, id)
|
|
m.queryLatencies.WithLabelValues("GetFileByID").Observe(time.Since(start).Seconds())
|
|
return file, err
|
|
}
|
|
|
|
func (m queryMetricsStore) GetFileTemplates(ctx context.Context, fileID uuid.UUID) ([]database.GetFileTemplatesRow, error) {
|
|
start := time.Now()
|
|
rows, err := m.s.GetFileTemplates(ctx, fileID)
|
|
m.queryLatencies.WithLabelValues("GetFileTemplates").Observe(time.Since(start).Seconds())
|
|
return rows, err
|
|
}
|
|
|
|
func (m queryMetricsStore) GetFilteredInboxNotificationsByUserID(ctx context.Context, arg database.GetFilteredInboxNotificationsByUserIDParams) ([]database.InboxNotification, error) {
|
|
start := time.Now()
|
|
r0, r1 := m.s.GetFilteredInboxNotificationsByUserID(ctx, arg)
|
|
m.queryLatencies.WithLabelValues("GetFilteredInboxNotificationsByUserID").Observe(time.Since(start).Seconds())
|
|
return r0, r1
|
|
}
|
|
|
|
func (m queryMetricsStore) GetGitSSHKey(ctx context.Context, userID uuid.UUID) (database.GitSSHKey, error) {
|
|
start := time.Now()
|
|
key, err := m.s.GetGitSSHKey(ctx, userID)
|
|
m.queryLatencies.WithLabelValues("GetGitSSHKey").Observe(time.Since(start).Seconds())
|
|
return key, err
|
|
}
|
|
|
|
func (m queryMetricsStore) GetGroupByID(ctx context.Context, id uuid.UUID) (database.Group, error) {
|
|
start := time.Now()
|
|
group, err := m.s.GetGroupByID(ctx, id)
|
|
m.queryLatencies.WithLabelValues("GetGroupByID").Observe(time.Since(start).Seconds())
|
|
return group, err
|
|
}
|
|
|
|
func (m queryMetricsStore) GetGroupByOrgAndName(ctx context.Context, arg database.GetGroupByOrgAndNameParams) (database.Group, error) {
|
|
start := time.Now()
|
|
group, err := m.s.GetGroupByOrgAndName(ctx, arg)
|
|
m.queryLatencies.WithLabelValues("GetGroupByOrgAndName").Observe(time.Since(start).Seconds())
|
|
return group, err
|
|
}
|
|
|
|
func (m queryMetricsStore) GetGroupMembers(ctx context.Context) ([]database.GroupMember, error) {
|
|
start := time.Now()
|
|
r0, r1 := m.s.GetGroupMembers(ctx)
|
|
m.queryLatencies.WithLabelValues("GetGroupMembers").Observe(time.Since(start).Seconds())
|
|
return r0, r1
|
|
}
|
|
|
|
func (m queryMetricsStore) GetGroupMembersByGroupID(ctx context.Context, groupID uuid.UUID) ([]database.GroupMember, error) {
|
|
start := time.Now()
|
|
users, err := m.s.GetGroupMembersByGroupID(ctx, groupID)
|
|
m.queryLatencies.WithLabelValues("GetGroupMembersByGroupID").Observe(time.Since(start).Seconds())
|
|
return users, err
|
|
}
|
|
|
|
func (m queryMetricsStore) GetGroupMembersCountByGroupID(ctx context.Context, groupID uuid.UUID) (int64, error) {
|
|
start := time.Now()
|
|
r0, r1 := m.s.GetGroupMembersCountByGroupID(ctx, groupID)
|
|
m.queryLatencies.WithLabelValues("GetGroupMembersCountByGroupID").Observe(time.Since(start).Seconds())
|
|
return r0, r1
|
|
}
|
|
|
|
func (m queryMetricsStore) GetGroups(ctx context.Context, arg database.GetGroupsParams) ([]database.GetGroupsRow, error) {
|
|
start := time.Now()
|
|
r0, r1 := m.s.GetGroups(ctx, arg)
|
|
m.queryLatencies.WithLabelValues("GetGroups").Observe(time.Since(start).Seconds())
|
|
return r0, r1
|
|
}
|
|
|
|
func (m queryMetricsStore) GetHealthSettings(ctx context.Context) (string, error) {
|
|
start := time.Now()
|
|
r0, r1 := m.s.GetHealthSettings(ctx)
|
|
m.queryLatencies.WithLabelValues("GetHealthSettings").Observe(time.Since(start).Seconds())
|
|
return r0, r1
|
|
}
|
|
|
|
func (m queryMetricsStore) GetHungProvisionerJobs(ctx context.Context, hungSince time.Time) ([]database.ProvisionerJob, error) {
|
|
start := time.Now()
|
|
jobs, err := m.s.GetHungProvisionerJobs(ctx, hungSince)
|
|
m.queryLatencies.WithLabelValues("GetHungProvisionerJobs").Observe(time.Since(start).Seconds())
|
|
return jobs, err
|
|
}
|
|
|
|
func (m queryMetricsStore) GetInboxNotificationByID(ctx context.Context, id uuid.UUID) (database.InboxNotification, error) {
|
|
start := time.Now()
|
|
r0, r1 := m.s.GetInboxNotificationByID(ctx, id)
|
|
m.queryLatencies.WithLabelValues("GetInboxNotificationByID").Observe(time.Since(start).Seconds())
|
|
return r0, r1
|
|
}
|
|
|
|
func (m queryMetricsStore) GetInboxNotificationsByUserID(ctx context.Context, userID database.GetInboxNotificationsByUserIDParams) ([]database.InboxNotification, error) {
|
|
start := time.Now()
|
|
r0, r1 := m.s.GetInboxNotificationsByUserID(ctx, userID)
|
|
m.queryLatencies.WithLabelValues("GetInboxNotificationsByUserID").Observe(time.Since(start).Seconds())
|
|
return r0, r1
|
|
}
|
|
|
|
func (m queryMetricsStore) GetJFrogXrayScanByWorkspaceAndAgentID(ctx context.Context, arg database.GetJFrogXrayScanByWorkspaceAndAgentIDParams) (database.JfrogXrayScan, error) {
|
|
start := time.Now()
|
|
r0, r1 := m.s.GetJFrogXrayScanByWorkspaceAndAgentID(ctx, arg)
|
|
m.queryLatencies.WithLabelValues("GetJFrogXrayScanByWorkspaceAndAgentID").Observe(time.Since(start).Seconds())
|
|
return r0, r1
|
|
}
|
|
|
|
func (m queryMetricsStore) GetLastUpdateCheck(ctx context.Context) (string, error) {
|
|
start := time.Now()
|
|
version, err := m.s.GetLastUpdateCheck(ctx)
|
|
m.queryLatencies.WithLabelValues("GetLastUpdateCheck").Observe(time.Since(start).Seconds())
|
|
return version, err
|
|
}
|
|
|
|
func (m queryMetricsStore) GetLatestCryptoKeyByFeature(ctx context.Context, feature database.CryptoKeyFeature) (database.CryptoKey, error) {
|
|
start := time.Now()
|
|
r0, r1 := m.s.GetLatestCryptoKeyByFeature(ctx, feature)
|
|
m.queryLatencies.WithLabelValues("GetLatestCryptoKeyByFeature").Observe(time.Since(start).Seconds())
|
|
return r0, r1
|
|
}
|
|
|
|
func (m queryMetricsStore) GetLatestWorkspaceBuildByWorkspaceID(ctx context.Context, workspaceID uuid.UUID) (database.WorkspaceBuild, error) {
|
|
start := time.Now()
|
|
build, err := m.s.GetLatestWorkspaceBuildByWorkspaceID(ctx, workspaceID)
|
|
m.queryLatencies.WithLabelValues("GetLatestWorkspaceBuildByWorkspaceID").Observe(time.Since(start).Seconds())
|
|
return build, err
|
|
}
|
|
|
|
func (m queryMetricsStore) GetLatestWorkspaceBuilds(ctx context.Context) ([]database.WorkspaceBuild, error) {
|
|
start := time.Now()
|
|
builds, err := m.s.GetLatestWorkspaceBuilds(ctx)
|
|
m.queryLatencies.WithLabelValues("GetLatestWorkspaceBuilds").Observe(time.Since(start).Seconds())
|
|
return builds, err
|
|
}
|
|
|
|
func (m queryMetricsStore) GetLatestWorkspaceBuildsByWorkspaceIDs(ctx context.Context, ids []uuid.UUID) ([]database.WorkspaceBuild, error) {
|
|
start := time.Now()
|
|
builds, err := m.s.GetLatestWorkspaceBuildsByWorkspaceIDs(ctx, ids)
|
|
m.queryLatencies.WithLabelValues("GetLatestWorkspaceBuildsByWorkspaceIDs").Observe(time.Since(start).Seconds())
|
|
return builds, err
|
|
}
|
|
|
|
func (m queryMetricsStore) GetLicenseByID(ctx context.Context, id int32) (database.License, error) {
|
|
start := time.Now()
|
|
license, err := m.s.GetLicenseByID(ctx, id)
|
|
m.queryLatencies.WithLabelValues("GetLicenseByID").Observe(time.Since(start).Seconds())
|
|
return license, err
|
|
}
|
|
|
|
func (m queryMetricsStore) GetLicenses(ctx context.Context) ([]database.License, error) {
|
|
start := time.Now()
|
|
licenses, err := m.s.GetLicenses(ctx)
|
|
m.queryLatencies.WithLabelValues("GetLicenses").Observe(time.Since(start).Seconds())
|
|
return licenses, err
|
|
}
|
|
|
|
func (m queryMetricsStore) GetLogoURL(ctx context.Context) (string, error) {
|
|
start := time.Now()
|
|
url, err := m.s.GetLogoURL(ctx)
|
|
m.queryLatencies.WithLabelValues("GetLogoURL").Observe(time.Since(start).Seconds())
|
|
return url, err
|
|
}
|
|
|
|
func (m queryMetricsStore) GetNotificationMessagesByStatus(ctx context.Context, arg database.GetNotificationMessagesByStatusParams) ([]database.NotificationMessage, error) {
|
|
start := time.Now()
|
|
r0, r1 := m.s.GetNotificationMessagesByStatus(ctx, arg)
|
|
m.queryLatencies.WithLabelValues("GetNotificationMessagesByStatus").Observe(time.Since(start).Seconds())
|
|
return r0, r1
|
|
}
|
|
|
|
func (m queryMetricsStore) GetNotificationReportGeneratorLogByTemplate(ctx context.Context, arg uuid.UUID) (database.NotificationReportGeneratorLog, error) {
|
|
start := time.Now()
|
|
r0, r1 := m.s.GetNotificationReportGeneratorLogByTemplate(ctx, arg)
|
|
m.queryLatencies.WithLabelValues("GetNotificationReportGeneratorLogByTemplate").Observe(time.Since(start).Seconds())
|
|
return r0, r1
|
|
}
|
|
|
|
func (m queryMetricsStore) GetNotificationTemplateByID(ctx context.Context, id uuid.UUID) (database.NotificationTemplate, error) {
|
|
start := time.Now()
|
|
r0, r1 := m.s.GetNotificationTemplateByID(ctx, id)
|
|
m.queryLatencies.WithLabelValues("GetNotificationTemplateByID").Observe(time.Since(start).Seconds())
|
|
return r0, r1
|
|
}
|
|
|
|
func (m queryMetricsStore) GetNotificationTemplatesByKind(ctx context.Context, kind database.NotificationTemplateKind) ([]database.NotificationTemplate, error) {
|
|
start := time.Now()
|
|
r0, r1 := m.s.GetNotificationTemplatesByKind(ctx, kind)
|
|
m.queryLatencies.WithLabelValues("GetNotificationTemplatesByKind").Observe(time.Since(start).Seconds())
|
|
return r0, r1
|
|
}
|
|
|
|
func (m queryMetricsStore) GetNotificationsSettings(ctx context.Context) (string, error) {
|
|
start := time.Now()
|
|
r0, r1 := m.s.GetNotificationsSettings(ctx)
|
|
m.queryLatencies.WithLabelValues("GetNotificationsSettings").Observe(time.Since(start).Seconds())
|
|
return r0, r1
|
|
}
|
|
|
|
func (m queryMetricsStore) GetOAuth2GithubDefaultEligible(ctx context.Context) (bool, error) {
|
|
start := time.Now()
|
|
r0, r1 := m.s.GetOAuth2GithubDefaultEligible(ctx)
|
|
m.queryLatencies.WithLabelValues("GetOAuth2GithubDefaultEligible").Observe(time.Since(start).Seconds())
|
|
return r0, r1
|
|
}
|
|
|
|
func (m queryMetricsStore) GetOAuth2ProviderAppByID(ctx context.Context, id uuid.UUID) (database.OAuth2ProviderApp, error) {
|
|
start := time.Now()
|
|
r0, r1 := m.s.GetOAuth2ProviderAppByID(ctx, id)
|
|
m.queryLatencies.WithLabelValues("GetOAuth2ProviderAppByID").Observe(time.Since(start).Seconds())
|
|
return r0, r1
|
|
}
|
|
|
|
func (m queryMetricsStore) GetOAuth2ProviderAppCodeByID(ctx context.Context, id uuid.UUID) (database.OAuth2ProviderAppCode, error) {
|
|
start := time.Now()
|
|
r0, r1 := m.s.GetOAuth2ProviderAppCodeByID(ctx, id)
|
|
m.queryLatencies.WithLabelValues("GetOAuth2ProviderAppCodeByID").Observe(time.Since(start).Seconds())
|
|
return r0, r1
|
|
}
|
|
|
|
func (m queryMetricsStore) GetOAuth2ProviderAppCodeByPrefix(ctx context.Context, secretPrefix []byte) (database.OAuth2ProviderAppCode, error) {
|
|
start := time.Now()
|
|
r0, r1 := m.s.GetOAuth2ProviderAppCodeByPrefix(ctx, secretPrefix)
|
|
m.queryLatencies.WithLabelValues("GetOAuth2ProviderAppCodeByPrefix").Observe(time.Since(start).Seconds())
|
|
return r0, r1
|
|
}
|
|
|
|
func (m queryMetricsStore) GetOAuth2ProviderAppSecretByID(ctx context.Context, id uuid.UUID) (database.OAuth2ProviderAppSecret, error) {
|
|
start := time.Now()
|
|
r0, r1 := m.s.GetOAuth2ProviderAppSecretByID(ctx, id)
|
|
m.queryLatencies.WithLabelValues("GetOAuth2ProviderAppSecretByID").Observe(time.Since(start).Seconds())
|
|
return r0, r1
|
|
}
|
|
|
|
func (m queryMetricsStore) GetOAuth2ProviderAppSecretByPrefix(ctx context.Context, secretPrefix []byte) (database.OAuth2ProviderAppSecret, error) {
|
|
start := time.Now()
|
|
r0, r1 := m.s.GetOAuth2ProviderAppSecretByPrefix(ctx, secretPrefix)
|
|
m.queryLatencies.WithLabelValues("GetOAuth2ProviderAppSecretByPrefix").Observe(time.Since(start).Seconds())
|
|
return r0, r1
|
|
}
|
|
|
|
func (m queryMetricsStore) GetOAuth2ProviderAppSecretsByAppID(ctx context.Context, appID uuid.UUID) ([]database.OAuth2ProviderAppSecret, error) {
|
|
start := time.Now()
|
|
r0, r1 := m.s.GetOAuth2ProviderAppSecretsByAppID(ctx, appID)
|
|
m.queryLatencies.WithLabelValues("GetOAuth2ProviderAppSecretsByAppID").Observe(time.Since(start).Seconds())
|
|
return r0, r1
|
|
}
|
|
|
|
func (m queryMetricsStore) GetOAuth2ProviderAppTokenByPrefix(ctx context.Context, hashPrefix []byte) (database.OAuth2ProviderAppToken, error) {
|
|
start := time.Now()
|
|
r0, r1 := m.s.GetOAuth2ProviderAppTokenByPrefix(ctx, hashPrefix)
|
|
m.queryLatencies.WithLabelValues("GetOAuth2ProviderAppTokenByPrefix").Observe(time.Since(start).Seconds())
|
|
return r0, r1
|
|
}
|
|
|
|
func (m queryMetricsStore) GetOAuth2ProviderApps(ctx context.Context) ([]database.OAuth2ProviderApp, error) {
|
|
start := time.Now()
|
|
r0, r1 := m.s.GetOAuth2ProviderApps(ctx)
|
|
m.queryLatencies.WithLabelValues("GetOAuth2ProviderApps").Observe(time.Since(start).Seconds())
|
|
return r0, r1
|
|
}
|
|
|
|
func (m queryMetricsStore) GetOAuth2ProviderAppsByUserID(ctx context.Context, userID uuid.UUID) ([]database.GetOAuth2ProviderAppsByUserIDRow, error) {
|
|
start := time.Now()
|
|
r0, r1 := m.s.GetOAuth2ProviderAppsByUserID(ctx, userID)
|
|
m.queryLatencies.WithLabelValues("GetOAuth2ProviderAppsByUserID").Observe(time.Since(start).Seconds())
|
|
return r0, r1
|
|
}
|
|
|
|
func (m queryMetricsStore) GetOAuthSigningKey(ctx context.Context) (string, error) {
|
|
start := time.Now()
|
|
r0, r1 := m.s.GetOAuthSigningKey(ctx)
|
|
m.queryLatencies.WithLabelValues("GetOAuthSigningKey").Observe(time.Since(start).Seconds())
|
|
return r0, r1
|
|
}
|
|
|
|
func (m queryMetricsStore) GetOrganizationByID(ctx context.Context, id uuid.UUID) (database.Organization, error) {
|
|
start := time.Now()
|
|
organization, err := m.s.GetOrganizationByID(ctx, id)
|
|
m.queryLatencies.WithLabelValues("GetOrganizationByID").Observe(time.Since(start).Seconds())
|
|
return organization, err
|
|
}
|
|
|
|
func (m queryMetricsStore) GetOrganizationByName(ctx context.Context, name database.GetOrganizationByNameParams) (database.Organization, error) {
|
|
start := time.Now()
|
|
organization, err := m.s.GetOrganizationByName(ctx, name)
|
|
m.queryLatencies.WithLabelValues("GetOrganizationByName").Observe(time.Since(start).Seconds())
|
|
return organization, err
|
|
}
|
|
|
|
func (m queryMetricsStore) GetOrganizationIDsByMemberIDs(ctx context.Context, ids []uuid.UUID) ([]database.GetOrganizationIDsByMemberIDsRow, error) {
|
|
start := time.Now()
|
|
organizations, err := m.s.GetOrganizationIDsByMemberIDs(ctx, ids)
|
|
m.queryLatencies.WithLabelValues("GetOrganizationIDsByMemberIDs").Observe(time.Since(start).Seconds())
|
|
return organizations, err
|
|
}
|
|
|
|
func (m queryMetricsStore) GetOrganizations(ctx context.Context, args database.GetOrganizationsParams) ([]database.Organization, error) {
|
|
start := time.Now()
|
|
organizations, err := m.s.GetOrganizations(ctx, args)
|
|
m.queryLatencies.WithLabelValues("GetOrganizations").Observe(time.Since(start).Seconds())
|
|
return organizations, err
|
|
}
|
|
|
|
func (m queryMetricsStore) GetOrganizationsByUserID(ctx context.Context, userID database.GetOrganizationsByUserIDParams) ([]database.Organization, error) {
|
|
start := time.Now()
|
|
organizations, err := m.s.GetOrganizationsByUserID(ctx, userID)
|
|
m.queryLatencies.WithLabelValues("GetOrganizationsByUserID").Observe(time.Since(start).Seconds())
|
|
return organizations, err
|
|
}
|
|
|
|
func (m queryMetricsStore) GetParameterSchemasByJobID(ctx context.Context, jobID uuid.UUID) ([]database.ParameterSchema, error) {
|
|
start := time.Now()
|
|
schemas, err := m.s.GetParameterSchemasByJobID(ctx, jobID)
|
|
m.queryLatencies.WithLabelValues("GetParameterSchemasByJobID").Observe(time.Since(start).Seconds())
|
|
return schemas, err
|
|
}
|
|
|
|
func (m queryMetricsStore) GetPresetByWorkspaceBuildID(ctx context.Context, workspaceBuildID uuid.UUID) (database.TemplateVersionPreset, error) {
|
|
start := time.Now()
|
|
r0, r1 := m.s.GetPresetByWorkspaceBuildID(ctx, workspaceBuildID)
|
|
m.queryLatencies.WithLabelValues("GetPresetByWorkspaceBuildID").Observe(time.Since(start).Seconds())
|
|
return r0, r1
|
|
}
|
|
|
|
func (m queryMetricsStore) GetPresetParametersByTemplateVersionID(ctx context.Context, templateVersionID uuid.UUID) ([]database.TemplateVersionPresetParameter, error) {
|
|
start := time.Now()
|
|
r0, r1 := m.s.GetPresetParametersByTemplateVersionID(ctx, templateVersionID)
|
|
m.queryLatencies.WithLabelValues("GetPresetParametersByTemplateVersionID").Observe(time.Since(start).Seconds())
|
|
return r0, r1
|
|
}
|
|
|
|
func (m queryMetricsStore) GetPresetsByTemplateVersionID(ctx context.Context, templateVersionID uuid.UUID) ([]database.TemplateVersionPreset, error) {
|
|
start := time.Now()
|
|
r0, r1 := m.s.GetPresetsByTemplateVersionID(ctx, templateVersionID)
|
|
m.queryLatencies.WithLabelValues("GetPresetsByTemplateVersionID").Observe(time.Since(start).Seconds())
|
|
return r0, r1
|
|
}
|
|
|
|
func (m queryMetricsStore) GetPreviousTemplateVersion(ctx context.Context, arg database.GetPreviousTemplateVersionParams) (database.TemplateVersion, error) {
|
|
start := time.Now()
|
|
version, err := m.s.GetPreviousTemplateVersion(ctx, arg)
|
|
m.queryLatencies.WithLabelValues("GetPreviousTemplateVersion").Observe(time.Since(start).Seconds())
|
|
return version, err
|
|
}
|
|
|
|
func (m queryMetricsStore) GetProvisionerDaemons(ctx context.Context) ([]database.ProvisionerDaemon, error) {
|
|
start := time.Now()
|
|
daemons, err := m.s.GetProvisionerDaemons(ctx)
|
|
m.queryLatencies.WithLabelValues("GetProvisionerDaemons").Observe(time.Since(start).Seconds())
|
|
return daemons, err
|
|
}
|
|
|
|
func (m queryMetricsStore) GetProvisionerDaemonsByOrganization(ctx context.Context, arg database.GetProvisionerDaemonsByOrganizationParams) ([]database.ProvisionerDaemon, error) {
|
|
start := time.Now()
|
|
r0, r1 := m.s.GetProvisionerDaemonsByOrganization(ctx, arg)
|
|
m.queryLatencies.WithLabelValues("GetProvisionerDaemonsByOrganization").Observe(time.Since(start).Seconds())
|
|
return r0, r1
|
|
}
|
|
|
|
func (m queryMetricsStore) GetProvisionerDaemonsWithStatusByOrganization(ctx context.Context, arg database.GetProvisionerDaemonsWithStatusByOrganizationParams) ([]database.GetProvisionerDaemonsWithStatusByOrganizationRow, error) {
|
|
start := time.Now()
|
|
r0, r1 := m.s.GetProvisionerDaemonsWithStatusByOrganization(ctx, arg)
|
|
m.queryLatencies.WithLabelValues("GetProvisionerDaemonsWithStatusByOrganization").Observe(time.Since(start).Seconds())
|
|
return r0, r1
|
|
}
|
|
|
|
func (m queryMetricsStore) GetProvisionerJobByID(ctx context.Context, id uuid.UUID) (database.ProvisionerJob, error) {
|
|
start := time.Now()
|
|
job, err := m.s.GetProvisionerJobByID(ctx, id)
|
|
m.queryLatencies.WithLabelValues("GetProvisionerJobByID").Observe(time.Since(start).Seconds())
|
|
return job, err
|
|
}
|
|
|
|
func (m queryMetricsStore) GetProvisionerJobTimingsByJobID(ctx context.Context, jobID uuid.UUID) ([]database.ProvisionerJobTiming, error) {
|
|
start := time.Now()
|
|
r0, r1 := m.s.GetProvisionerJobTimingsByJobID(ctx, jobID)
|
|
m.queryLatencies.WithLabelValues("GetProvisionerJobTimingsByJobID").Observe(time.Since(start).Seconds())
|
|
return r0, r1
|
|
}
|
|
|
|
func (m queryMetricsStore) GetProvisionerJobsByIDs(ctx context.Context, ids []uuid.UUID) ([]database.ProvisionerJob, error) {
|
|
start := time.Now()
|
|
jobs, err := m.s.GetProvisionerJobsByIDs(ctx, ids)
|
|
m.queryLatencies.WithLabelValues("GetProvisionerJobsByIDs").Observe(time.Since(start).Seconds())
|
|
return jobs, err
|
|
}
|
|
|
|
func (m queryMetricsStore) GetProvisionerJobsByIDsWithQueuePosition(ctx context.Context, ids []uuid.UUID) ([]database.GetProvisionerJobsByIDsWithQueuePositionRow, error) {
|
|
start := time.Now()
|
|
r0, r1 := m.s.GetProvisionerJobsByIDsWithQueuePosition(ctx, ids)
|
|
m.queryLatencies.WithLabelValues("GetProvisionerJobsByIDsWithQueuePosition").Observe(time.Since(start).Seconds())
|
|
return r0, r1
|
|
}
|
|
|
|
func (m queryMetricsStore) GetProvisionerJobsByOrganizationAndStatusWithQueuePositionAndProvisioner(ctx context.Context, arg database.GetProvisionerJobsByOrganizationAndStatusWithQueuePositionAndProvisionerParams) ([]database.GetProvisionerJobsByOrganizationAndStatusWithQueuePositionAndProvisionerRow, error) {
|
|
start := time.Now()
|
|
r0, r1 := m.s.GetProvisionerJobsByOrganizationAndStatusWithQueuePositionAndProvisioner(ctx, arg)
|
|
m.queryLatencies.WithLabelValues("GetProvisionerJobsByOrganizationAndStatusWithQueuePositionAndProvisioner").Observe(time.Since(start).Seconds())
|
|
return r0, r1
|
|
}
|
|
|
|
func (m queryMetricsStore) GetProvisionerJobsCreatedAfter(ctx context.Context, createdAt time.Time) ([]database.ProvisionerJob, error) {
|
|
start := time.Now()
|
|
jobs, err := m.s.GetProvisionerJobsCreatedAfter(ctx, createdAt)
|
|
m.queryLatencies.WithLabelValues("GetProvisionerJobsCreatedAfter").Observe(time.Since(start).Seconds())
|
|
return jobs, err
|
|
}
|
|
|
|
func (m queryMetricsStore) GetProvisionerKeyByHashedSecret(ctx context.Context, hashedSecret []byte) (database.ProvisionerKey, error) {
|
|
start := time.Now()
|
|
r0, r1 := m.s.GetProvisionerKeyByHashedSecret(ctx, hashedSecret)
|
|
m.queryLatencies.WithLabelValues("GetProvisionerKeyByHashedSecret").Observe(time.Since(start).Seconds())
|
|
return r0, r1
|
|
}
|
|
|
|
func (m queryMetricsStore) GetProvisionerKeyByID(ctx context.Context, id uuid.UUID) (database.ProvisionerKey, error) {
|
|
start := time.Now()
|
|
r0, r1 := m.s.GetProvisionerKeyByID(ctx, id)
|
|
m.queryLatencies.WithLabelValues("GetProvisionerKeyByID").Observe(time.Since(start).Seconds())
|
|
return r0, r1
|
|
}
|
|
|
|
func (m queryMetricsStore) GetProvisionerKeyByName(ctx context.Context, name database.GetProvisionerKeyByNameParams) (database.ProvisionerKey, error) {
|
|
start := time.Now()
|
|
r0, r1 := m.s.GetProvisionerKeyByName(ctx, name)
|
|
m.queryLatencies.WithLabelValues("GetProvisionerKeyByName").Observe(time.Since(start).Seconds())
|
|
return r0, r1
|
|
}
|
|
|
|
func (m queryMetricsStore) GetProvisionerLogsAfterID(ctx context.Context, arg database.GetProvisionerLogsAfterIDParams) ([]database.ProvisionerJobLog, error) {
|
|
start := time.Now()
|
|
logs, err := m.s.GetProvisionerLogsAfterID(ctx, arg)
|
|
m.queryLatencies.WithLabelValues("GetProvisionerLogsAfterID").Observe(time.Since(start).Seconds())
|
|
return logs, err
|
|
}
|
|
|
|
func (m queryMetricsStore) GetQuotaAllowanceForUser(ctx context.Context, userID database.GetQuotaAllowanceForUserParams) (int64, error) {
|
|
start := time.Now()
|
|
allowance, err := m.s.GetQuotaAllowanceForUser(ctx, userID)
|
|
m.queryLatencies.WithLabelValues("GetQuotaAllowanceForUser").Observe(time.Since(start).Seconds())
|
|
return allowance, err
|
|
}
|
|
|
|
func (m queryMetricsStore) GetQuotaConsumedForUser(ctx context.Context, ownerID database.GetQuotaConsumedForUserParams) (int64, error) {
|
|
start := time.Now()
|
|
consumed, err := m.s.GetQuotaConsumedForUser(ctx, ownerID)
|
|
m.queryLatencies.WithLabelValues("GetQuotaConsumedForUser").Observe(time.Since(start).Seconds())
|
|
return consumed, err
|
|
}
|
|
|
|
func (m queryMetricsStore) GetReplicaByID(ctx context.Context, id uuid.UUID) (database.Replica, error) {
|
|
start := time.Now()
|
|
replica, err := m.s.GetReplicaByID(ctx, id)
|
|
m.queryLatencies.WithLabelValues("GetReplicaByID").Observe(time.Since(start).Seconds())
|
|
return replica, err
|
|
}
|
|
|
|
func (m queryMetricsStore) GetReplicasUpdatedAfter(ctx context.Context, updatedAt time.Time) ([]database.Replica, error) {
|
|
start := time.Now()
|
|
replicas, err := m.s.GetReplicasUpdatedAfter(ctx, updatedAt)
|
|
m.queryLatencies.WithLabelValues("GetReplicasUpdatedAfter").Observe(time.Since(start).Seconds())
|
|
return replicas, err
|
|
}
|
|
|
|
func (m queryMetricsStore) GetRuntimeConfig(ctx context.Context, key string) (string, error) {
|
|
start := time.Now()
|
|
r0, r1 := m.s.GetRuntimeConfig(ctx, key)
|
|
m.queryLatencies.WithLabelValues("GetRuntimeConfig").Observe(time.Since(start).Seconds())
|
|
return r0, r1
|
|
}
|
|
|
|
func (m queryMetricsStore) GetTailnetAgents(ctx context.Context, id uuid.UUID) ([]database.TailnetAgent, error) {
|
|
start := time.Now()
|
|
r0, r1 := m.s.GetTailnetAgents(ctx, id)
|
|
m.queryLatencies.WithLabelValues("GetTailnetAgents").Observe(time.Since(start).Seconds())
|
|
return r0, r1
|
|
}
|
|
|
|
func (m queryMetricsStore) GetTailnetClientsForAgent(ctx context.Context, agentID uuid.UUID) ([]database.TailnetClient, error) {
|
|
start := time.Now()
|
|
r0, r1 := m.s.GetTailnetClientsForAgent(ctx, agentID)
|
|
m.queryLatencies.WithLabelValues("GetTailnetClientsForAgent").Observe(time.Since(start).Seconds())
|
|
return r0, r1
|
|
}
|
|
|
|
func (m queryMetricsStore) GetTailnetPeers(ctx context.Context, id uuid.UUID) ([]database.TailnetPeer, error) {
|
|
start := time.Now()
|
|
r0, r1 := m.s.GetTailnetPeers(ctx, id)
|
|
m.queryLatencies.WithLabelValues("GetTailnetPeers").Observe(time.Since(start).Seconds())
|
|
return r0, r1
|
|
}
|
|
|
|
func (m queryMetricsStore) GetTailnetTunnelPeerBindings(ctx context.Context, srcID uuid.UUID) ([]database.GetTailnetTunnelPeerBindingsRow, error) {
|
|
start := time.Now()
|
|
r0, r1 := m.s.GetTailnetTunnelPeerBindings(ctx, srcID)
|
|
m.queryLatencies.WithLabelValues("GetTailnetTunnelPeerBindings").Observe(time.Since(start).Seconds())
|
|
return r0, r1
|
|
}
|
|
|
|
func (m queryMetricsStore) GetTailnetTunnelPeerIDs(ctx context.Context, srcID uuid.UUID) ([]database.GetTailnetTunnelPeerIDsRow, error) {
|
|
start := time.Now()
|
|
r0, r1 := m.s.GetTailnetTunnelPeerIDs(ctx, srcID)
|
|
m.queryLatencies.WithLabelValues("GetTailnetTunnelPeerIDs").Observe(time.Since(start).Seconds())
|
|
return r0, r1
|
|
}
|
|
|
|
func (m queryMetricsStore) GetTelemetryItem(ctx context.Context, key string) (database.TelemetryItem, error) {
|
|
start := time.Now()
|
|
r0, r1 := m.s.GetTelemetryItem(ctx, key)
|
|
m.queryLatencies.WithLabelValues("GetTelemetryItem").Observe(time.Since(start).Seconds())
|
|
return r0, r1
|
|
}
|
|
|
|
func (m queryMetricsStore) GetTelemetryItems(ctx context.Context) ([]database.TelemetryItem, error) {
|
|
start := time.Now()
|
|
r0, r1 := m.s.GetTelemetryItems(ctx)
|
|
m.queryLatencies.WithLabelValues("GetTelemetryItems").Observe(time.Since(start).Seconds())
|
|
return r0, r1
|
|
}
|
|
|
|
func (m queryMetricsStore) GetTemplateAppInsights(ctx context.Context, arg database.GetTemplateAppInsightsParams) ([]database.GetTemplateAppInsightsRow, error) {
|
|
start := time.Now()
|
|
r0, r1 := m.s.GetTemplateAppInsights(ctx, arg)
|
|
m.queryLatencies.WithLabelValues("GetTemplateAppInsights").Observe(time.Since(start).Seconds())
|
|
return r0, r1
|
|
}
|
|
|
|
func (m queryMetricsStore) GetTemplateAppInsightsByTemplate(ctx context.Context, arg database.GetTemplateAppInsightsByTemplateParams) ([]database.GetTemplateAppInsightsByTemplateRow, error) {
|
|
start := time.Now()
|
|
r0, r1 := m.s.GetTemplateAppInsightsByTemplate(ctx, arg)
|
|
m.queryLatencies.WithLabelValues("GetTemplateAppInsightsByTemplate").Observe(time.Since(start).Seconds())
|
|
return r0, r1
|
|
}
|
|
|
|
func (m queryMetricsStore) GetTemplateAverageBuildTime(ctx context.Context, arg database.GetTemplateAverageBuildTimeParams) (database.GetTemplateAverageBuildTimeRow, error) {
|
|
start := time.Now()
|
|
buildTime, err := m.s.GetTemplateAverageBuildTime(ctx, arg)
|
|
m.queryLatencies.WithLabelValues("GetTemplateAverageBuildTime").Observe(time.Since(start).Seconds())
|
|
return buildTime, err
|
|
}
|
|
|
|
func (m queryMetricsStore) GetTemplateByID(ctx context.Context, id uuid.UUID) (database.Template, error) {
|
|
start := time.Now()
|
|
template, err := m.s.GetTemplateByID(ctx, id)
|
|
m.queryLatencies.WithLabelValues("GetTemplateByID").Observe(time.Since(start).Seconds())
|
|
return template, err
|
|
}
|
|
|
|
func (m queryMetricsStore) GetTemplateByOrganizationAndName(ctx context.Context, arg database.GetTemplateByOrganizationAndNameParams) (database.Template, error) {
|
|
start := time.Now()
|
|
template, err := m.s.GetTemplateByOrganizationAndName(ctx, arg)
|
|
m.queryLatencies.WithLabelValues("GetTemplateByOrganizationAndName").Observe(time.Since(start).Seconds())
|
|
return template, err
|
|
}
|
|
|
|
func (m queryMetricsStore) GetTemplateDAUs(ctx context.Context, arg database.GetTemplateDAUsParams) ([]database.GetTemplateDAUsRow, error) {
|
|
start := time.Now()
|
|
daus, err := m.s.GetTemplateDAUs(ctx, arg)
|
|
m.queryLatencies.WithLabelValues("GetTemplateDAUs").Observe(time.Since(start).Seconds())
|
|
return daus, err
|
|
}
|
|
|
|
func (m queryMetricsStore) GetTemplateInsights(ctx context.Context, arg database.GetTemplateInsightsParams) (database.GetTemplateInsightsRow, error) {
|
|
start := time.Now()
|
|
r0, r1 := m.s.GetTemplateInsights(ctx, arg)
|
|
m.queryLatencies.WithLabelValues("GetTemplateInsights").Observe(time.Since(start).Seconds())
|
|
return r0, r1
|
|
}
|
|
|
|
func (m queryMetricsStore) GetTemplateInsightsByInterval(ctx context.Context, arg database.GetTemplateInsightsByIntervalParams) ([]database.GetTemplateInsightsByIntervalRow, error) {
|
|
start := time.Now()
|
|
r0, r1 := m.s.GetTemplateInsightsByInterval(ctx, arg)
|
|
m.queryLatencies.WithLabelValues("GetTemplateInsightsByInterval").Observe(time.Since(start).Seconds())
|
|
return r0, r1
|
|
}
|
|
|
|
func (m queryMetricsStore) GetTemplateInsightsByTemplate(ctx context.Context, arg database.GetTemplateInsightsByTemplateParams) ([]database.GetTemplateInsightsByTemplateRow, error) {
|
|
start := time.Now()
|
|
r0, r1 := m.s.GetTemplateInsightsByTemplate(ctx, arg)
|
|
m.queryLatencies.WithLabelValues("GetTemplateInsightsByTemplate").Observe(time.Since(start).Seconds())
|
|
return r0, r1
|
|
}
|
|
|
|
func (m queryMetricsStore) GetTemplateParameterInsights(ctx context.Context, arg database.GetTemplateParameterInsightsParams) ([]database.GetTemplateParameterInsightsRow, error) {
|
|
start := time.Now()
|
|
r0, r1 := m.s.GetTemplateParameterInsights(ctx, arg)
|
|
m.queryLatencies.WithLabelValues("GetTemplateParameterInsights").Observe(time.Since(start).Seconds())
|
|
return r0, r1
|
|
}
|
|
|
|
func (m queryMetricsStore) GetTemplateUsageStats(ctx context.Context, arg database.GetTemplateUsageStatsParams) ([]database.TemplateUsageStat, error) {
|
|
start := time.Now()
|
|
r0, r1 := m.s.GetTemplateUsageStats(ctx, arg)
|
|
m.queryLatencies.WithLabelValues("GetTemplateUsageStats").Observe(time.Since(start).Seconds())
|
|
return r0, r1
|
|
}
|
|
|
|
func (m queryMetricsStore) GetTemplateVersionByID(ctx context.Context, id uuid.UUID) (database.TemplateVersion, error) {
|
|
start := time.Now()
|
|
version, err := m.s.GetTemplateVersionByID(ctx, id)
|
|
m.queryLatencies.WithLabelValues("GetTemplateVersionByID").Observe(time.Since(start).Seconds())
|
|
return version, err
|
|
}
|
|
|
|
func (m queryMetricsStore) GetTemplateVersionByJobID(ctx context.Context, jobID uuid.UUID) (database.TemplateVersion, error) {
|
|
start := time.Now()
|
|
version, err := m.s.GetTemplateVersionByJobID(ctx, jobID)
|
|
m.queryLatencies.WithLabelValues("GetTemplateVersionByJobID").Observe(time.Since(start).Seconds())
|
|
return version, err
|
|
}
|
|
|
|
func (m queryMetricsStore) GetTemplateVersionByTemplateIDAndName(ctx context.Context, arg database.GetTemplateVersionByTemplateIDAndNameParams) (database.TemplateVersion, error) {
|
|
start := time.Now()
|
|
version, err := m.s.GetTemplateVersionByTemplateIDAndName(ctx, arg)
|
|
m.queryLatencies.WithLabelValues("GetTemplateVersionByTemplateIDAndName").Observe(time.Since(start).Seconds())
|
|
return version, err
|
|
}
|
|
|
|
func (m queryMetricsStore) GetTemplateVersionParameters(ctx context.Context, templateVersionID uuid.UUID) ([]database.TemplateVersionParameter, error) {
|
|
start := time.Now()
|
|
parameters, err := m.s.GetTemplateVersionParameters(ctx, templateVersionID)
|
|
m.queryLatencies.WithLabelValues("GetTemplateVersionParameters").Observe(time.Since(start).Seconds())
|
|
return parameters, err
|
|
}
|
|
|
|
func (m queryMetricsStore) GetTemplateVersionVariables(ctx context.Context, templateVersionID uuid.UUID) ([]database.TemplateVersionVariable, error) {
|
|
start := time.Now()
|
|
variables, err := m.s.GetTemplateVersionVariables(ctx, templateVersionID)
|
|
m.queryLatencies.WithLabelValues("GetTemplateVersionVariables").Observe(time.Since(start).Seconds())
|
|
return variables, err
|
|
}
|
|
|
|
func (m queryMetricsStore) GetTemplateVersionWorkspaceTags(ctx context.Context, templateVersionID uuid.UUID) ([]database.TemplateVersionWorkspaceTag, error) {
|
|
start := time.Now()
|
|
r0, r1 := m.s.GetTemplateVersionWorkspaceTags(ctx, templateVersionID)
|
|
m.queryLatencies.WithLabelValues("GetTemplateVersionWorkspaceTags").Observe(time.Since(start).Seconds())
|
|
return r0, r1
|
|
}
|
|
|
|
func (m queryMetricsStore) GetTemplateVersionsByIDs(ctx context.Context, ids []uuid.UUID) ([]database.TemplateVersion, error) {
|
|
start := time.Now()
|
|
versions, err := m.s.GetTemplateVersionsByIDs(ctx, ids)
|
|
m.queryLatencies.WithLabelValues("GetTemplateVersionsByIDs").Observe(time.Since(start).Seconds())
|
|
return versions, err
|
|
}
|
|
|
|
func (m queryMetricsStore) GetTemplateVersionsByTemplateID(ctx context.Context, arg database.GetTemplateVersionsByTemplateIDParams) ([]database.TemplateVersion, error) {
|
|
start := time.Now()
|
|
versions, err := m.s.GetTemplateVersionsByTemplateID(ctx, arg)
|
|
m.queryLatencies.WithLabelValues("GetTemplateVersionsByTemplateID").Observe(time.Since(start).Seconds())
|
|
return versions, err
|
|
}
|
|
|
|
func (m queryMetricsStore) GetTemplateVersionsCreatedAfter(ctx context.Context, createdAt time.Time) ([]database.TemplateVersion, error) {
|
|
start := time.Now()
|
|
versions, err := m.s.GetTemplateVersionsCreatedAfter(ctx, createdAt)
|
|
m.queryLatencies.WithLabelValues("GetTemplateVersionsCreatedAfter").Observe(time.Since(start).Seconds())
|
|
return versions, err
|
|
}
|
|
|
|
func (m queryMetricsStore) GetTemplates(ctx context.Context) ([]database.Template, error) {
|
|
start := time.Now()
|
|
templates, err := m.s.GetTemplates(ctx)
|
|
m.queryLatencies.WithLabelValues("GetTemplates").Observe(time.Since(start).Seconds())
|
|
return templates, err
|
|
}
|
|
|
|
func (m queryMetricsStore) GetTemplatesWithFilter(ctx context.Context, arg database.GetTemplatesWithFilterParams) ([]database.Template, error) {
|
|
start := time.Now()
|
|
templates, err := m.s.GetTemplatesWithFilter(ctx, arg)
|
|
m.queryLatencies.WithLabelValues("GetTemplatesWithFilter").Observe(time.Since(start).Seconds())
|
|
return templates, err
|
|
}
|
|
|
|
func (m queryMetricsStore) GetUnexpiredLicenses(ctx context.Context) ([]database.License, error) {
|
|
start := time.Now()
|
|
licenses, err := m.s.GetUnexpiredLicenses(ctx)
|
|
m.queryLatencies.WithLabelValues("GetUnexpiredLicenses").Observe(time.Since(start).Seconds())
|
|
return licenses, err
|
|
}
|
|
|
|
func (m queryMetricsStore) GetUserActivityInsights(ctx context.Context, arg database.GetUserActivityInsightsParams) ([]database.GetUserActivityInsightsRow, error) {
|
|
start := time.Now()
|
|
r0, r1 := m.s.GetUserActivityInsights(ctx, arg)
|
|
m.queryLatencies.WithLabelValues("GetUserActivityInsights").Observe(time.Since(start).Seconds())
|
|
return r0, r1
|
|
}
|
|
|
|
func (m queryMetricsStore) GetUserAppearanceSettings(ctx context.Context, userID uuid.UUID) (string, error) {
|
|
start := time.Now()
|
|
r0, r1 := m.s.GetUserAppearanceSettings(ctx, userID)
|
|
m.queryLatencies.WithLabelValues("GetUserAppearanceSettings").Observe(time.Since(start).Seconds())
|
|
return r0, r1
|
|
}
|
|
|
|
func (m queryMetricsStore) GetUserByEmailOrUsername(ctx context.Context, arg database.GetUserByEmailOrUsernameParams) (database.User, error) {
|
|
start := time.Now()
|
|
user, err := m.s.GetUserByEmailOrUsername(ctx, arg)
|
|
m.queryLatencies.WithLabelValues("GetUserByEmailOrUsername").Observe(time.Since(start).Seconds())
|
|
return user, err
|
|
}
|
|
|
|
func (m queryMetricsStore) GetUserByID(ctx context.Context, id uuid.UUID) (database.User, error) {
|
|
start := time.Now()
|
|
user, err := m.s.GetUserByID(ctx, id)
|
|
m.queryLatencies.WithLabelValues("GetUserByID").Observe(time.Since(start).Seconds())
|
|
return user, err
|
|
}
|
|
|
|
func (m queryMetricsStore) GetUserCount(ctx context.Context) (int64, error) {
|
|
start := time.Now()
|
|
count, err := m.s.GetUserCount(ctx)
|
|
m.queryLatencies.WithLabelValues("GetUserCount").Observe(time.Since(start).Seconds())
|
|
return count, err
|
|
}
|
|
|
|
func (m queryMetricsStore) GetUserLatencyInsights(ctx context.Context, arg database.GetUserLatencyInsightsParams) ([]database.GetUserLatencyInsightsRow, error) {
|
|
start := time.Now()
|
|
r0, r1 := m.s.GetUserLatencyInsights(ctx, arg)
|
|
m.queryLatencies.WithLabelValues("GetUserLatencyInsights").Observe(time.Since(start).Seconds())
|
|
return r0, r1
|
|
}
|
|
|
|
func (m queryMetricsStore) GetUserLinkByLinkedID(ctx context.Context, linkedID string) (database.UserLink, error) {
|
|
start := time.Now()
|
|
link, err := m.s.GetUserLinkByLinkedID(ctx, linkedID)
|
|
m.queryLatencies.WithLabelValues("GetUserLinkByLinkedID").Observe(time.Since(start).Seconds())
|
|
return link, err
|
|
}
|
|
|
|
func (m queryMetricsStore) GetUserLinkByUserIDLoginType(ctx context.Context, arg database.GetUserLinkByUserIDLoginTypeParams) (database.UserLink, error) {
|
|
start := time.Now()
|
|
link, err := m.s.GetUserLinkByUserIDLoginType(ctx, arg)
|
|
m.queryLatencies.WithLabelValues("GetUserLinkByUserIDLoginType").Observe(time.Since(start).Seconds())
|
|
return link, err
|
|
}
|
|
|
|
func (m queryMetricsStore) GetUserLinksByUserID(ctx context.Context, userID uuid.UUID) ([]database.UserLink, error) {
|
|
start := time.Now()
|
|
r0, r1 := m.s.GetUserLinksByUserID(ctx, userID)
|
|
m.queryLatencies.WithLabelValues("GetUserLinksByUserID").Observe(time.Since(start).Seconds())
|
|
return r0, r1
|
|
}
|
|
|
|
func (m queryMetricsStore) GetUserNotificationPreferences(ctx context.Context, userID uuid.UUID) ([]database.NotificationPreference, error) {
|
|
start := time.Now()
|
|
r0, r1 := m.s.GetUserNotificationPreferences(ctx, userID)
|
|
m.queryLatencies.WithLabelValues("GetUserNotificationPreferences").Observe(time.Since(start).Seconds())
|
|
return r0, r1
|
|
}
|
|
|
|
func (m queryMetricsStore) GetUserStatusCounts(ctx context.Context, arg database.GetUserStatusCountsParams) ([]database.GetUserStatusCountsRow, error) {
|
|
start := time.Now()
|
|
r0, r1 := m.s.GetUserStatusCounts(ctx, arg)
|
|
m.queryLatencies.WithLabelValues("GetUserStatusCounts").Observe(time.Since(start).Seconds())
|
|
return r0, r1
|
|
}
|
|
|
|
func (m queryMetricsStore) GetUserWorkspaceBuildParameters(ctx context.Context, ownerID database.GetUserWorkspaceBuildParametersParams) ([]database.GetUserWorkspaceBuildParametersRow, error) {
|
|
start := time.Now()
|
|
r0, r1 := m.s.GetUserWorkspaceBuildParameters(ctx, ownerID)
|
|
m.queryLatencies.WithLabelValues("GetUserWorkspaceBuildParameters").Observe(time.Since(start).Seconds())
|
|
return r0, r1
|
|
}
|
|
|
|
func (m queryMetricsStore) GetUsers(ctx context.Context, arg database.GetUsersParams) ([]database.GetUsersRow, error) {
|
|
start := time.Now()
|
|
users, err := m.s.GetUsers(ctx, arg)
|
|
m.queryLatencies.WithLabelValues("GetUsers").Observe(time.Since(start).Seconds())
|
|
return users, err
|
|
}
|
|
|
|
func (m queryMetricsStore) GetUsersByIDs(ctx context.Context, ids []uuid.UUID) ([]database.User, error) {
|
|
start := time.Now()
|
|
users, err := m.s.GetUsersByIDs(ctx, ids)
|
|
m.queryLatencies.WithLabelValues("GetUsersByIDs").Observe(time.Since(start).Seconds())
|
|
return users, err
|
|
}
|
|
|
|
func (m queryMetricsStore) GetWorkspaceAgentAndLatestBuildByAuthToken(ctx context.Context, authToken uuid.UUID) (database.GetWorkspaceAgentAndLatestBuildByAuthTokenRow, error) {
|
|
start := time.Now()
|
|
r0, r1 := m.s.GetWorkspaceAgentAndLatestBuildByAuthToken(ctx, authToken)
|
|
m.queryLatencies.WithLabelValues("GetWorkspaceAgentAndLatestBuildByAuthToken").Observe(time.Since(start).Seconds())
|
|
return r0, r1
|
|
}
|
|
|
|
func (m queryMetricsStore) GetWorkspaceAgentByID(ctx context.Context, id uuid.UUID) (database.WorkspaceAgent, error) {
|
|
start := time.Now()
|
|
agent, err := m.s.GetWorkspaceAgentByID(ctx, id)
|
|
m.queryLatencies.WithLabelValues("GetWorkspaceAgentByID").Observe(time.Since(start).Seconds())
|
|
return agent, err
|
|
}
|
|
|
|
func (m queryMetricsStore) GetWorkspaceAgentByInstanceID(ctx context.Context, authInstanceID string) (database.WorkspaceAgent, error) {
|
|
start := time.Now()
|
|
agent, err := m.s.GetWorkspaceAgentByInstanceID(ctx, authInstanceID)
|
|
m.queryLatencies.WithLabelValues("GetWorkspaceAgentByInstanceID").Observe(time.Since(start).Seconds())
|
|
return agent, err
|
|
}
|
|
|
|
func (m queryMetricsStore) GetWorkspaceAgentLifecycleStateByID(ctx context.Context, id uuid.UUID) (database.GetWorkspaceAgentLifecycleStateByIDRow, error) {
|
|
start := time.Now()
|
|
r0, r1 := m.s.GetWorkspaceAgentLifecycleStateByID(ctx, id)
|
|
m.queryLatencies.WithLabelValues("GetWorkspaceAgentLifecycleStateByID").Observe(time.Since(start).Seconds())
|
|
return r0, r1
|
|
}
|
|
|
|
func (m queryMetricsStore) GetWorkspaceAgentLogSourcesByAgentIDs(ctx context.Context, ids []uuid.UUID) ([]database.WorkspaceAgentLogSource, error) {
|
|
start := time.Now()
|
|
r0, r1 := m.s.GetWorkspaceAgentLogSourcesByAgentIDs(ctx, ids)
|
|
m.queryLatencies.WithLabelValues("GetWorkspaceAgentLogSourcesByAgentIDs").Observe(time.Since(start).Seconds())
|
|
return r0, r1
|
|
}
|
|
|
|
func (m queryMetricsStore) GetWorkspaceAgentLogsAfter(ctx context.Context, arg database.GetWorkspaceAgentLogsAfterParams) ([]database.WorkspaceAgentLog, error) {
|
|
start := time.Now()
|
|
r0, r1 := m.s.GetWorkspaceAgentLogsAfter(ctx, arg)
|
|
m.queryLatencies.WithLabelValues("GetWorkspaceAgentLogsAfter").Observe(time.Since(start).Seconds())
|
|
return r0, r1
|
|
}
|
|
|
|
func (m queryMetricsStore) GetWorkspaceAgentMetadata(ctx context.Context, workspaceAgentID database.GetWorkspaceAgentMetadataParams) ([]database.WorkspaceAgentMetadatum, error) {
|
|
start := time.Now()
|
|
metadata, err := m.s.GetWorkspaceAgentMetadata(ctx, workspaceAgentID)
|
|
m.queryLatencies.WithLabelValues("GetWorkspaceAgentMetadata").Observe(time.Since(start).Seconds())
|
|
return metadata, err
|
|
}
|
|
|
|
func (m queryMetricsStore) GetWorkspaceAgentPortShare(ctx context.Context, arg database.GetWorkspaceAgentPortShareParams) (database.WorkspaceAgentPortShare, error) {
|
|
start := time.Now()
|
|
r0, r1 := m.s.GetWorkspaceAgentPortShare(ctx, arg)
|
|
m.queryLatencies.WithLabelValues("GetWorkspaceAgentPortShare").Observe(time.Since(start).Seconds())
|
|
return r0, r1
|
|
}
|
|
|
|
func (m queryMetricsStore) GetWorkspaceAgentScriptTimingsByBuildID(ctx context.Context, id uuid.UUID) ([]database.GetWorkspaceAgentScriptTimingsByBuildIDRow, error) {
|
|
start := time.Now()
|
|
r0, r1 := m.s.GetWorkspaceAgentScriptTimingsByBuildID(ctx, id)
|
|
m.queryLatencies.WithLabelValues("GetWorkspaceAgentScriptTimingsByBuildID").Observe(time.Since(start).Seconds())
|
|
return r0, r1
|
|
}
|
|
|
|
func (m queryMetricsStore) GetWorkspaceAgentScriptsByAgentIDs(ctx context.Context, ids []uuid.UUID) ([]database.WorkspaceAgentScript, error) {
|
|
start := time.Now()
|
|
r0, r1 := m.s.GetWorkspaceAgentScriptsByAgentIDs(ctx, ids)
|
|
m.queryLatencies.WithLabelValues("GetWorkspaceAgentScriptsByAgentIDs").Observe(time.Since(start).Seconds())
|
|
return r0, r1
|
|
}
|
|
|
|
func (m queryMetricsStore) GetWorkspaceAgentStats(ctx context.Context, createdAt time.Time) ([]database.GetWorkspaceAgentStatsRow, error) {
|
|
start := time.Now()
|
|
stats, err := m.s.GetWorkspaceAgentStats(ctx, createdAt)
|
|
m.queryLatencies.WithLabelValues("GetWorkspaceAgentStats").Observe(time.Since(start).Seconds())
|
|
return stats, err
|
|
}
|
|
|
|
func (m queryMetricsStore) GetWorkspaceAgentStatsAndLabels(ctx context.Context, createdAt time.Time) ([]database.GetWorkspaceAgentStatsAndLabelsRow, error) {
|
|
start := time.Now()
|
|
stats, err := m.s.GetWorkspaceAgentStatsAndLabels(ctx, createdAt)
|
|
m.queryLatencies.WithLabelValues("GetWorkspaceAgentStatsAndLabels").Observe(time.Since(start).Seconds())
|
|
return stats, err
|
|
}
|
|
|
|
func (m queryMetricsStore) GetWorkspaceAgentUsageStats(ctx context.Context, createdAt time.Time) ([]database.GetWorkspaceAgentUsageStatsRow, error) {
|
|
start := time.Now()
|
|
r0, r1 := m.s.GetWorkspaceAgentUsageStats(ctx, createdAt)
|
|
m.queryLatencies.WithLabelValues("GetWorkspaceAgentUsageStats").Observe(time.Since(start).Seconds())
|
|
return r0, r1
|
|
}
|
|
|
|
func (m queryMetricsStore) GetWorkspaceAgentUsageStatsAndLabels(ctx context.Context, createdAt time.Time) ([]database.GetWorkspaceAgentUsageStatsAndLabelsRow, error) {
|
|
start := time.Now()
|
|
r0, r1 := m.s.GetWorkspaceAgentUsageStatsAndLabels(ctx, createdAt)
|
|
m.queryLatencies.WithLabelValues("GetWorkspaceAgentUsageStatsAndLabels").Observe(time.Since(start).Seconds())
|
|
return r0, r1
|
|
}
|
|
|
|
func (m queryMetricsStore) GetWorkspaceAgentsByResourceIDs(ctx context.Context, ids []uuid.UUID) ([]database.WorkspaceAgent, error) {
|
|
start := time.Now()
|
|
agents, err := m.s.GetWorkspaceAgentsByResourceIDs(ctx, ids)
|
|
m.queryLatencies.WithLabelValues("GetWorkspaceAgentsByResourceIDs").Observe(time.Since(start).Seconds())
|
|
return agents, err
|
|
}
|
|
|
|
func (m queryMetricsStore) GetWorkspaceAgentsCreatedAfter(ctx context.Context, createdAt time.Time) ([]database.WorkspaceAgent, error) {
|
|
start := time.Now()
|
|
agents, err := m.s.GetWorkspaceAgentsCreatedAfter(ctx, createdAt)
|
|
m.queryLatencies.WithLabelValues("GetWorkspaceAgentsCreatedAfter").Observe(time.Since(start).Seconds())
|
|
return agents, err
|
|
}
|
|
|
|
func (m queryMetricsStore) GetWorkspaceAgentsInLatestBuildByWorkspaceID(ctx context.Context, workspaceID uuid.UUID) ([]database.WorkspaceAgent, error) {
|
|
start := time.Now()
|
|
agents, err := m.s.GetWorkspaceAgentsInLatestBuildByWorkspaceID(ctx, workspaceID)
|
|
m.queryLatencies.WithLabelValues("GetWorkspaceAgentsInLatestBuildByWorkspaceID").Observe(time.Since(start).Seconds())
|
|
return agents, err
|
|
}
|
|
|
|
func (m queryMetricsStore) GetWorkspaceAppByAgentIDAndSlug(ctx context.Context, arg database.GetWorkspaceAppByAgentIDAndSlugParams) (database.WorkspaceApp, error) {
|
|
start := time.Now()
|
|
app, err := m.s.GetWorkspaceAppByAgentIDAndSlug(ctx, arg)
|
|
m.queryLatencies.WithLabelValues("GetWorkspaceAppByAgentIDAndSlug").Observe(time.Since(start).Seconds())
|
|
return app, err
|
|
}
|
|
|
|
func (m queryMetricsStore) GetWorkspaceAppsByAgentID(ctx context.Context, agentID uuid.UUID) ([]database.WorkspaceApp, error) {
|
|
start := time.Now()
|
|
apps, err := m.s.GetWorkspaceAppsByAgentID(ctx, agentID)
|
|
m.queryLatencies.WithLabelValues("GetWorkspaceAppsByAgentID").Observe(time.Since(start).Seconds())
|
|
return apps, err
|
|
}
|
|
|
|
func (m queryMetricsStore) GetWorkspaceAppsByAgentIDs(ctx context.Context, ids []uuid.UUID) ([]database.WorkspaceApp, error) {
|
|
start := time.Now()
|
|
apps, err := m.s.GetWorkspaceAppsByAgentIDs(ctx, ids)
|
|
m.queryLatencies.WithLabelValues("GetWorkspaceAppsByAgentIDs").Observe(time.Since(start).Seconds())
|
|
return apps, err
|
|
}
|
|
|
|
func (m queryMetricsStore) GetWorkspaceAppsCreatedAfter(ctx context.Context, createdAt time.Time) ([]database.WorkspaceApp, error) {
|
|
start := time.Now()
|
|
apps, err := m.s.GetWorkspaceAppsCreatedAfter(ctx, createdAt)
|
|
m.queryLatencies.WithLabelValues("GetWorkspaceAppsCreatedAfter").Observe(time.Since(start).Seconds())
|
|
return apps, err
|
|
}
|
|
|
|
func (m queryMetricsStore) GetWorkspaceBuildByID(ctx context.Context, id uuid.UUID) (database.WorkspaceBuild, error) {
|
|
start := time.Now()
|
|
build, err := m.s.GetWorkspaceBuildByID(ctx, id)
|
|
m.queryLatencies.WithLabelValues("GetWorkspaceBuildByID").Observe(time.Since(start).Seconds())
|
|
return build, err
|
|
}
|
|
|
|
func (m queryMetricsStore) GetWorkspaceBuildByJobID(ctx context.Context, jobID uuid.UUID) (database.WorkspaceBuild, error) {
|
|
start := time.Now()
|
|
build, err := m.s.GetWorkspaceBuildByJobID(ctx, jobID)
|
|
m.queryLatencies.WithLabelValues("GetWorkspaceBuildByJobID").Observe(time.Since(start).Seconds())
|
|
return build, err
|
|
}
|
|
|
|
func (m queryMetricsStore) GetWorkspaceBuildByWorkspaceIDAndBuildNumber(ctx context.Context, arg database.GetWorkspaceBuildByWorkspaceIDAndBuildNumberParams) (database.WorkspaceBuild, error) {
|
|
start := time.Now()
|
|
build, err := m.s.GetWorkspaceBuildByWorkspaceIDAndBuildNumber(ctx, arg)
|
|
m.queryLatencies.WithLabelValues("GetWorkspaceBuildByWorkspaceIDAndBuildNumber").Observe(time.Since(start).Seconds())
|
|
return build, err
|
|
}
|
|
|
|
func (m queryMetricsStore) GetWorkspaceBuildParameters(ctx context.Context, workspaceBuildID uuid.UUID) ([]database.WorkspaceBuildParameter, error) {
|
|
start := time.Now()
|
|
params, err := m.s.GetWorkspaceBuildParameters(ctx, workspaceBuildID)
|
|
m.queryLatencies.WithLabelValues("GetWorkspaceBuildParameters").Observe(time.Since(start).Seconds())
|
|
return params, err
|
|
}
|
|
|
|
func (m queryMetricsStore) GetWorkspaceBuildStatsByTemplates(ctx context.Context, since time.Time) ([]database.GetWorkspaceBuildStatsByTemplatesRow, error) {
|
|
start := time.Now()
|
|
r0, r1 := m.s.GetWorkspaceBuildStatsByTemplates(ctx, since)
|
|
m.queryLatencies.WithLabelValues("GetWorkspaceBuildStatsByTemplates").Observe(time.Since(start).Seconds())
|
|
return r0, r1
|
|
}
|
|
|
|
func (m queryMetricsStore) GetWorkspaceBuildsByWorkspaceID(ctx context.Context, arg database.GetWorkspaceBuildsByWorkspaceIDParams) ([]database.WorkspaceBuild, error) {
|
|
start := time.Now()
|
|
builds, err := m.s.GetWorkspaceBuildsByWorkspaceID(ctx, arg)
|
|
m.queryLatencies.WithLabelValues("GetWorkspaceBuildsByWorkspaceID").Observe(time.Since(start).Seconds())
|
|
return builds, err
|
|
}
|
|
|
|
func (m queryMetricsStore) GetWorkspaceBuildsCreatedAfter(ctx context.Context, createdAt time.Time) ([]database.WorkspaceBuild, error) {
|
|
start := time.Now()
|
|
builds, err := m.s.GetWorkspaceBuildsCreatedAfter(ctx, createdAt)
|
|
m.queryLatencies.WithLabelValues("GetWorkspaceBuildsCreatedAfter").Observe(time.Since(start).Seconds())
|
|
return builds, err
|
|
}
|
|
|
|
func (m queryMetricsStore) GetWorkspaceByAgentID(ctx context.Context, agentID uuid.UUID) (database.Workspace, error) {
|
|
start := time.Now()
|
|
workspace, err := m.s.GetWorkspaceByAgentID(ctx, agentID)
|
|
m.queryLatencies.WithLabelValues("GetWorkspaceByAgentID").Observe(time.Since(start).Seconds())
|
|
return workspace, err
|
|
}
|
|
|
|
func (m queryMetricsStore) GetWorkspaceByID(ctx context.Context, id uuid.UUID) (database.Workspace, error) {
|
|
start := time.Now()
|
|
workspace, err := m.s.GetWorkspaceByID(ctx, id)
|
|
m.queryLatencies.WithLabelValues("GetWorkspaceByID").Observe(time.Since(start).Seconds())
|
|
return workspace, err
|
|
}
|
|
|
|
func (m queryMetricsStore) GetWorkspaceByOwnerIDAndName(ctx context.Context, arg database.GetWorkspaceByOwnerIDAndNameParams) (database.Workspace, error) {
|
|
start := time.Now()
|
|
workspace, err := m.s.GetWorkspaceByOwnerIDAndName(ctx, arg)
|
|
m.queryLatencies.WithLabelValues("GetWorkspaceByOwnerIDAndName").Observe(time.Since(start).Seconds())
|
|
return workspace, err
|
|
}
|
|
|
|
func (m queryMetricsStore) GetWorkspaceByWorkspaceAppID(ctx context.Context, workspaceAppID uuid.UUID) (database.Workspace, error) {
|
|
start := time.Now()
|
|
workspace, err := m.s.GetWorkspaceByWorkspaceAppID(ctx, workspaceAppID)
|
|
m.queryLatencies.WithLabelValues("GetWorkspaceByWorkspaceAppID").Observe(time.Since(start).Seconds())
|
|
return workspace, err
|
|
}
|
|
|
|
func (m queryMetricsStore) GetWorkspaceModulesByJobID(ctx context.Context, jobID uuid.UUID) ([]database.WorkspaceModule, error) {
|
|
start := time.Now()
|
|
r0, r1 := m.s.GetWorkspaceModulesByJobID(ctx, jobID)
|
|
m.queryLatencies.WithLabelValues("GetWorkspaceModulesByJobID").Observe(time.Since(start).Seconds())
|
|
return r0, r1
|
|
}
|
|
|
|
func (m queryMetricsStore) GetWorkspaceModulesCreatedAfter(ctx context.Context, createdAt time.Time) ([]database.WorkspaceModule, error) {
|
|
start := time.Now()
|
|
r0, r1 := m.s.GetWorkspaceModulesCreatedAfter(ctx, createdAt)
|
|
m.queryLatencies.WithLabelValues("GetWorkspaceModulesCreatedAfter").Observe(time.Since(start).Seconds())
|
|
return r0, r1
|
|
}
|
|
|
|
func (m queryMetricsStore) GetWorkspaceProxies(ctx context.Context) ([]database.WorkspaceProxy, error) {
|
|
start := time.Now()
|
|
proxies, err := m.s.GetWorkspaceProxies(ctx)
|
|
m.queryLatencies.WithLabelValues("GetWorkspaceProxies").Observe(time.Since(start).Seconds())
|
|
return proxies, err
|
|
}
|
|
|
|
func (m queryMetricsStore) GetWorkspaceProxyByHostname(ctx context.Context, arg database.GetWorkspaceProxyByHostnameParams) (database.WorkspaceProxy, error) {
|
|
start := time.Now()
|
|
proxy, err := m.s.GetWorkspaceProxyByHostname(ctx, arg)
|
|
m.queryLatencies.WithLabelValues("GetWorkspaceProxyByHostname").Observe(time.Since(start).Seconds())
|
|
return proxy, err
|
|
}
|
|
|
|
func (m queryMetricsStore) GetWorkspaceProxyByID(ctx context.Context, id uuid.UUID) (database.WorkspaceProxy, error) {
|
|
start := time.Now()
|
|
proxy, err := m.s.GetWorkspaceProxyByID(ctx, id)
|
|
m.queryLatencies.WithLabelValues("GetWorkspaceProxyByID").Observe(time.Since(start).Seconds())
|
|
return proxy, err
|
|
}
|
|
|
|
func (m queryMetricsStore) GetWorkspaceProxyByName(ctx context.Context, name string) (database.WorkspaceProxy, error) {
|
|
start := time.Now()
|
|
proxy, err := m.s.GetWorkspaceProxyByName(ctx, name)
|
|
m.queryLatencies.WithLabelValues("GetWorkspaceProxyByName").Observe(time.Since(start).Seconds())
|
|
return proxy, err
|
|
}
|
|
|
|
func (m queryMetricsStore) GetWorkspaceResourceByID(ctx context.Context, id uuid.UUID) (database.WorkspaceResource, error) {
|
|
start := time.Now()
|
|
resource, err := m.s.GetWorkspaceResourceByID(ctx, id)
|
|
m.queryLatencies.WithLabelValues("GetWorkspaceResourceByID").Observe(time.Since(start).Seconds())
|
|
return resource, err
|
|
}
|
|
|
|
func (m queryMetricsStore) GetWorkspaceResourceMetadataByResourceIDs(ctx context.Context, ids []uuid.UUID) ([]database.WorkspaceResourceMetadatum, error) {
|
|
start := time.Now()
|
|
metadata, err := m.s.GetWorkspaceResourceMetadataByResourceIDs(ctx, ids)
|
|
m.queryLatencies.WithLabelValues("GetWorkspaceResourceMetadataByResourceIDs").Observe(time.Since(start).Seconds())
|
|
return metadata, err
|
|
}
|
|
|
|
func (m queryMetricsStore) GetWorkspaceResourceMetadataCreatedAfter(ctx context.Context, createdAt time.Time) ([]database.WorkspaceResourceMetadatum, error) {
|
|
start := time.Now()
|
|
metadata, err := m.s.GetWorkspaceResourceMetadataCreatedAfter(ctx, createdAt)
|
|
m.queryLatencies.WithLabelValues("GetWorkspaceResourceMetadataCreatedAfter").Observe(time.Since(start).Seconds())
|
|
return metadata, err
|
|
}
|
|
|
|
func (m queryMetricsStore) GetWorkspaceResourcesByJobID(ctx context.Context, jobID uuid.UUID) ([]database.WorkspaceResource, error) {
|
|
start := time.Now()
|
|
resources, err := m.s.GetWorkspaceResourcesByJobID(ctx, jobID)
|
|
m.queryLatencies.WithLabelValues("GetWorkspaceResourcesByJobID").Observe(time.Since(start).Seconds())
|
|
return resources, err
|
|
}
|
|
|
|
func (m queryMetricsStore) GetWorkspaceResourcesByJobIDs(ctx context.Context, ids []uuid.UUID) ([]database.WorkspaceResource, error) {
|
|
start := time.Now()
|
|
resources, err := m.s.GetWorkspaceResourcesByJobIDs(ctx, ids)
|
|
m.queryLatencies.WithLabelValues("GetWorkspaceResourcesByJobIDs").Observe(time.Since(start).Seconds())
|
|
return resources, err
|
|
}
|
|
|
|
func (m queryMetricsStore) GetWorkspaceResourcesCreatedAfter(ctx context.Context, createdAt time.Time) ([]database.WorkspaceResource, error) {
|
|
start := time.Now()
|
|
resources, err := m.s.GetWorkspaceResourcesCreatedAfter(ctx, createdAt)
|
|
m.queryLatencies.WithLabelValues("GetWorkspaceResourcesCreatedAfter").Observe(time.Since(start).Seconds())
|
|
return resources, err
|
|
}
|
|
|
|
func (m queryMetricsStore) GetWorkspaceUniqueOwnerCountByTemplateIDs(ctx context.Context, templateIds []uuid.UUID) ([]database.GetWorkspaceUniqueOwnerCountByTemplateIDsRow, error) {
|
|
start := time.Now()
|
|
r0, r1 := m.s.GetWorkspaceUniqueOwnerCountByTemplateIDs(ctx, templateIds)
|
|
m.queryLatencies.WithLabelValues("GetWorkspaceUniqueOwnerCountByTemplateIDs").Observe(time.Since(start).Seconds())
|
|
return r0, r1
|
|
}
|
|
|
|
func (m queryMetricsStore) GetWorkspaces(ctx context.Context, arg database.GetWorkspacesParams) ([]database.GetWorkspacesRow, error) {
|
|
start := time.Now()
|
|
workspaces, err := m.s.GetWorkspaces(ctx, arg)
|
|
m.queryLatencies.WithLabelValues("GetWorkspaces").Observe(time.Since(start).Seconds())
|
|
return workspaces, err
|
|
}
|
|
|
|
func (m queryMetricsStore) GetWorkspacesAndAgentsByOwnerID(ctx context.Context, ownerID uuid.UUID) ([]database.GetWorkspacesAndAgentsByOwnerIDRow, error) {
|
|
start := time.Now()
|
|
r0, r1 := m.s.GetWorkspacesAndAgentsByOwnerID(ctx, ownerID)
|
|
m.queryLatencies.WithLabelValues("GetWorkspacesAndAgentsByOwnerID").Observe(time.Since(start).Seconds())
|
|
return r0, r1
|
|
}
|
|
|
|
func (m queryMetricsStore) GetWorkspacesByTemplateID(ctx context.Context, templateID uuid.UUID) ([]database.WorkspaceTable, error) {
|
|
start := time.Now()
|
|
r0, r1 := m.s.GetWorkspacesByTemplateID(ctx, templateID)
|
|
m.queryLatencies.WithLabelValues("GetWorkspacesByTemplateID").Observe(time.Since(start).Seconds())
|
|
return r0, r1
|
|
}
|
|
|
|
func (m queryMetricsStore) GetWorkspacesEligibleForTransition(ctx context.Context, now time.Time) ([]database.GetWorkspacesEligibleForTransitionRow, error) {
|
|
start := time.Now()
|
|
workspaces, err := m.s.GetWorkspacesEligibleForTransition(ctx, now)
|
|
m.queryLatencies.WithLabelValues("GetWorkspacesEligibleForAutoStartStop").Observe(time.Since(start).Seconds())
|
|
return workspaces, err
|
|
}
|
|
|
|
func (m queryMetricsStore) InsertAPIKey(ctx context.Context, arg database.InsertAPIKeyParams) (database.APIKey, error) {
|
|
start := time.Now()
|
|
key, err := m.s.InsertAPIKey(ctx, arg)
|
|
m.queryLatencies.WithLabelValues("InsertAPIKey").Observe(time.Since(start).Seconds())
|
|
return key, err
|
|
}
|
|
|
|
func (m queryMetricsStore) InsertAllUsersGroup(ctx context.Context, organizationID uuid.UUID) (database.Group, error) {
|
|
start := time.Now()
|
|
group, err := m.s.InsertAllUsersGroup(ctx, organizationID)
|
|
m.queryLatencies.WithLabelValues("InsertAllUsersGroup").Observe(time.Since(start).Seconds())
|
|
return group, err
|
|
}
|
|
|
|
func (m queryMetricsStore) InsertAuditLog(ctx context.Context, arg database.InsertAuditLogParams) (database.AuditLog, error) {
|
|
start := time.Now()
|
|
log, err := m.s.InsertAuditLog(ctx, arg)
|
|
m.queryLatencies.WithLabelValues("InsertAuditLog").Observe(time.Since(start).Seconds())
|
|
return log, err
|
|
}
|
|
|
|
func (m queryMetricsStore) InsertCryptoKey(ctx context.Context, arg database.InsertCryptoKeyParams) (database.CryptoKey, error) {
|
|
start := time.Now()
|
|
key, err := m.s.InsertCryptoKey(ctx, arg)
|
|
m.queryLatencies.WithLabelValues("InsertCryptoKey").Observe(time.Since(start).Seconds())
|
|
return key, err
|
|
}
|
|
|
|
func (m queryMetricsStore) InsertCustomRole(ctx context.Context, arg database.InsertCustomRoleParams) (database.CustomRole, error) {
|
|
start := time.Now()
|
|
r0, r1 := m.s.InsertCustomRole(ctx, arg)
|
|
m.queryLatencies.WithLabelValues("InsertCustomRole").Observe(time.Since(start).Seconds())
|
|
return r0, r1
|
|
}
|
|
|
|
func (m queryMetricsStore) InsertDBCryptKey(ctx context.Context, arg database.InsertDBCryptKeyParams) error {
|
|
start := time.Now()
|
|
r0 := m.s.InsertDBCryptKey(ctx, arg)
|
|
m.queryLatencies.WithLabelValues("InsertDBCryptKey").Observe(time.Since(start).Seconds())
|
|
return r0
|
|
}
|
|
|
|
func (m queryMetricsStore) InsertDERPMeshKey(ctx context.Context, value string) error {
|
|
start := time.Now()
|
|
err := m.s.InsertDERPMeshKey(ctx, value)
|
|
m.queryLatencies.WithLabelValues("InsertDERPMeshKey").Observe(time.Since(start).Seconds())
|
|
return err
|
|
}
|
|
|
|
func (m queryMetricsStore) InsertDeploymentID(ctx context.Context, value string) error {
|
|
start := time.Now()
|
|
err := m.s.InsertDeploymentID(ctx, value)
|
|
m.queryLatencies.WithLabelValues("InsertDeploymentID").Observe(time.Since(start).Seconds())
|
|
return err
|
|
}
|
|
|
|
func (m queryMetricsStore) InsertExternalAuthLink(ctx context.Context, arg database.InsertExternalAuthLinkParams) (database.ExternalAuthLink, error) {
|
|
start := time.Now()
|
|
link, err := m.s.InsertExternalAuthLink(ctx, arg)
|
|
m.queryLatencies.WithLabelValues("InsertExternalAuthLink").Observe(time.Since(start).Seconds())
|
|
return link, err
|
|
}
|
|
|
|
func (m queryMetricsStore) InsertFile(ctx context.Context, arg database.InsertFileParams) (database.File, error) {
|
|
start := time.Now()
|
|
file, err := m.s.InsertFile(ctx, arg)
|
|
m.queryLatencies.WithLabelValues("InsertFile").Observe(time.Since(start).Seconds())
|
|
return file, err
|
|
}
|
|
|
|
func (m queryMetricsStore) InsertGitSSHKey(ctx context.Context, arg database.InsertGitSSHKeyParams) (database.GitSSHKey, error) {
|
|
start := time.Now()
|
|
key, err := m.s.InsertGitSSHKey(ctx, arg)
|
|
m.queryLatencies.WithLabelValues("InsertGitSSHKey").Observe(time.Since(start).Seconds())
|
|
return key, err
|
|
}
|
|
|
|
func (m queryMetricsStore) InsertGroup(ctx context.Context, arg database.InsertGroupParams) (database.Group, error) {
|
|
start := time.Now()
|
|
group, err := m.s.InsertGroup(ctx, arg)
|
|
m.queryLatencies.WithLabelValues("InsertGroup").Observe(time.Since(start).Seconds())
|
|
return group, err
|
|
}
|
|
|
|
func (m queryMetricsStore) InsertGroupMember(ctx context.Context, arg database.InsertGroupMemberParams) error {
|
|
start := time.Now()
|
|
err := m.s.InsertGroupMember(ctx, arg)
|
|
m.queryLatencies.WithLabelValues("InsertGroupMember").Observe(time.Since(start).Seconds())
|
|
return err
|
|
}
|
|
|
|
func (m queryMetricsStore) InsertInboxNotification(ctx context.Context, arg database.InsertInboxNotificationParams) (database.InboxNotification, error) {
|
|
start := time.Now()
|
|
r0, r1 := m.s.InsertInboxNotification(ctx, arg)
|
|
m.queryLatencies.WithLabelValues("InsertInboxNotification").Observe(time.Since(start).Seconds())
|
|
return r0, r1
|
|
}
|
|
|
|
func (m queryMetricsStore) InsertLicense(ctx context.Context, arg database.InsertLicenseParams) (database.License, error) {
|
|
start := time.Now()
|
|
license, err := m.s.InsertLicense(ctx, arg)
|
|
m.queryLatencies.WithLabelValues("InsertLicense").Observe(time.Since(start).Seconds())
|
|
return license, err
|
|
}
|
|
|
|
func (m queryMetricsStore) InsertMemoryResourceMonitor(ctx context.Context, arg database.InsertMemoryResourceMonitorParams) (database.WorkspaceAgentMemoryResourceMonitor, error) {
|
|
start := time.Now()
|
|
r0, r1 := m.s.InsertMemoryResourceMonitor(ctx, arg)
|
|
m.queryLatencies.WithLabelValues("InsertMemoryResourceMonitor").Observe(time.Since(start).Seconds())
|
|
return r0, r1
|
|
}
|
|
|
|
func (m queryMetricsStore) InsertMissingGroups(ctx context.Context, arg database.InsertMissingGroupsParams) ([]database.Group, error) {
|
|
start := time.Now()
|
|
r0, r1 := m.s.InsertMissingGroups(ctx, arg)
|
|
m.queryLatencies.WithLabelValues("InsertMissingGroups").Observe(time.Since(start).Seconds())
|
|
return r0, r1
|
|
}
|
|
|
|
func (m queryMetricsStore) InsertOAuth2ProviderApp(ctx context.Context, arg database.InsertOAuth2ProviderAppParams) (database.OAuth2ProviderApp, error) {
|
|
start := time.Now()
|
|
r0, r1 := m.s.InsertOAuth2ProviderApp(ctx, arg)
|
|
m.queryLatencies.WithLabelValues("InsertOAuth2ProviderApp").Observe(time.Since(start).Seconds())
|
|
return r0, r1
|
|
}
|
|
|
|
func (m queryMetricsStore) InsertOAuth2ProviderAppCode(ctx context.Context, arg database.InsertOAuth2ProviderAppCodeParams) (database.OAuth2ProviderAppCode, error) {
|
|
start := time.Now()
|
|
r0, r1 := m.s.InsertOAuth2ProviderAppCode(ctx, arg)
|
|
m.queryLatencies.WithLabelValues("InsertOAuth2ProviderAppCode").Observe(time.Since(start).Seconds())
|
|
return r0, r1
|
|
}
|
|
|
|
func (m queryMetricsStore) InsertOAuth2ProviderAppSecret(ctx context.Context, arg database.InsertOAuth2ProviderAppSecretParams) (database.OAuth2ProviderAppSecret, error) {
|
|
start := time.Now()
|
|
r0, r1 := m.s.InsertOAuth2ProviderAppSecret(ctx, arg)
|
|
m.queryLatencies.WithLabelValues("InsertOAuth2ProviderAppSecret").Observe(time.Since(start).Seconds())
|
|
return r0, r1
|
|
}
|
|
|
|
func (m queryMetricsStore) InsertOAuth2ProviderAppToken(ctx context.Context, arg database.InsertOAuth2ProviderAppTokenParams) (database.OAuth2ProviderAppToken, error) {
|
|
start := time.Now()
|
|
r0, r1 := m.s.InsertOAuth2ProviderAppToken(ctx, arg)
|
|
m.queryLatencies.WithLabelValues("InsertOAuth2ProviderAppToken").Observe(time.Since(start).Seconds())
|
|
return r0, r1
|
|
}
|
|
|
|
func (m queryMetricsStore) InsertOrganization(ctx context.Context, arg database.InsertOrganizationParams) (database.Organization, error) {
|
|
start := time.Now()
|
|
organization, err := m.s.InsertOrganization(ctx, arg)
|
|
m.queryLatencies.WithLabelValues("InsertOrganization").Observe(time.Since(start).Seconds())
|
|
return organization, err
|
|
}
|
|
|
|
func (m queryMetricsStore) InsertOrganizationMember(ctx context.Context, arg database.InsertOrganizationMemberParams) (database.OrganizationMember, error) {
|
|
start := time.Now()
|
|
member, err := m.s.InsertOrganizationMember(ctx, arg)
|
|
m.queryLatencies.WithLabelValues("InsertOrganizationMember").Observe(time.Since(start).Seconds())
|
|
return member, err
|
|
}
|
|
|
|
func (m queryMetricsStore) InsertPreset(ctx context.Context, arg database.InsertPresetParams) (database.TemplateVersionPreset, error) {
|
|
start := time.Now()
|
|
r0, r1 := m.s.InsertPreset(ctx, arg)
|
|
m.queryLatencies.WithLabelValues("InsertPreset").Observe(time.Since(start).Seconds())
|
|
return r0, r1
|
|
}
|
|
|
|
func (m queryMetricsStore) InsertPresetParameters(ctx context.Context, arg database.InsertPresetParametersParams) ([]database.TemplateVersionPresetParameter, error) {
|
|
start := time.Now()
|
|
r0, r1 := m.s.InsertPresetParameters(ctx, arg)
|
|
m.queryLatencies.WithLabelValues("InsertPresetParameters").Observe(time.Since(start).Seconds())
|
|
return r0, r1
|
|
}
|
|
|
|
func (m queryMetricsStore) InsertProvisionerJob(ctx context.Context, arg database.InsertProvisionerJobParams) (database.ProvisionerJob, error) {
|
|
start := time.Now()
|
|
job, err := m.s.InsertProvisionerJob(ctx, arg)
|
|
m.queryLatencies.WithLabelValues("InsertProvisionerJob").Observe(time.Since(start).Seconds())
|
|
return job, err
|
|
}
|
|
|
|
func (m queryMetricsStore) InsertProvisionerJobLogs(ctx context.Context, arg database.InsertProvisionerJobLogsParams) ([]database.ProvisionerJobLog, error) {
|
|
start := time.Now()
|
|
logs, err := m.s.InsertProvisionerJobLogs(ctx, arg)
|
|
m.queryLatencies.WithLabelValues("InsertProvisionerJobLogs").Observe(time.Since(start).Seconds())
|
|
return logs, err
|
|
}
|
|
|
|
func (m queryMetricsStore) InsertProvisionerJobTimings(ctx context.Context, arg database.InsertProvisionerJobTimingsParams) ([]database.ProvisionerJobTiming, error) {
|
|
start := time.Now()
|
|
r0, r1 := m.s.InsertProvisionerJobTimings(ctx, arg)
|
|
m.queryLatencies.WithLabelValues("InsertProvisionerJobTimings").Observe(time.Since(start).Seconds())
|
|
return r0, r1
|
|
}
|
|
|
|
func (m queryMetricsStore) InsertProvisionerKey(ctx context.Context, arg database.InsertProvisionerKeyParams) (database.ProvisionerKey, error) {
|
|
start := time.Now()
|
|
r0, r1 := m.s.InsertProvisionerKey(ctx, arg)
|
|
m.queryLatencies.WithLabelValues("InsertProvisionerKey").Observe(time.Since(start).Seconds())
|
|
return r0, r1
|
|
}
|
|
|
|
func (m queryMetricsStore) InsertReplica(ctx context.Context, arg database.InsertReplicaParams) (database.Replica, error) {
|
|
start := time.Now()
|
|
replica, err := m.s.InsertReplica(ctx, arg)
|
|
m.queryLatencies.WithLabelValues("InsertReplica").Observe(time.Since(start).Seconds())
|
|
return replica, err
|
|
}
|
|
|
|
func (m queryMetricsStore) InsertTelemetryItemIfNotExists(ctx context.Context, arg database.InsertTelemetryItemIfNotExistsParams) error {
|
|
start := time.Now()
|
|
r0 := m.s.InsertTelemetryItemIfNotExists(ctx, arg)
|
|
m.queryLatencies.WithLabelValues("InsertTelemetryItemIfNotExists").Observe(time.Since(start).Seconds())
|
|
return r0
|
|
}
|
|
|
|
func (m queryMetricsStore) InsertTemplate(ctx context.Context, arg database.InsertTemplateParams) error {
|
|
start := time.Now()
|
|
err := m.s.InsertTemplate(ctx, arg)
|
|
m.queryLatencies.WithLabelValues("InsertTemplate").Observe(time.Since(start).Seconds())
|
|
return err
|
|
}
|
|
|
|
func (m queryMetricsStore) InsertTemplateVersion(ctx context.Context, arg database.InsertTemplateVersionParams) error {
|
|
start := time.Now()
|
|
err := m.s.InsertTemplateVersion(ctx, arg)
|
|
m.queryLatencies.WithLabelValues("InsertTemplateVersion").Observe(time.Since(start).Seconds())
|
|
return err
|
|
}
|
|
|
|
func (m queryMetricsStore) InsertTemplateVersionParameter(ctx context.Context, arg database.InsertTemplateVersionParameterParams) (database.TemplateVersionParameter, error) {
|
|
start := time.Now()
|
|
parameter, err := m.s.InsertTemplateVersionParameter(ctx, arg)
|
|
m.queryLatencies.WithLabelValues("InsertTemplateVersionParameter").Observe(time.Since(start).Seconds())
|
|
return parameter, err
|
|
}
|
|
|
|
func (m queryMetricsStore) InsertTemplateVersionVariable(ctx context.Context, arg database.InsertTemplateVersionVariableParams) (database.TemplateVersionVariable, error) {
|
|
start := time.Now()
|
|
variable, err := m.s.InsertTemplateVersionVariable(ctx, arg)
|
|
m.queryLatencies.WithLabelValues("InsertTemplateVersionVariable").Observe(time.Since(start).Seconds())
|
|
return variable, err
|
|
}
|
|
|
|
func (m queryMetricsStore) InsertTemplateVersionWorkspaceTag(ctx context.Context, arg database.InsertTemplateVersionWorkspaceTagParams) (database.TemplateVersionWorkspaceTag, error) {
|
|
start := time.Now()
|
|
r0, r1 := m.s.InsertTemplateVersionWorkspaceTag(ctx, arg)
|
|
m.queryLatencies.WithLabelValues("InsertTemplateVersionWorkspaceTag").Observe(time.Since(start).Seconds())
|
|
return r0, r1
|
|
}
|
|
|
|
func (m queryMetricsStore) InsertUser(ctx context.Context, arg database.InsertUserParams) (database.User, error) {
|
|
start := time.Now()
|
|
user, err := m.s.InsertUser(ctx, arg)
|
|
m.queryLatencies.WithLabelValues("InsertUser").Observe(time.Since(start).Seconds())
|
|
return user, err
|
|
}
|
|
|
|
func (m queryMetricsStore) InsertUserGroupsByID(ctx context.Context, arg database.InsertUserGroupsByIDParams) ([]uuid.UUID, error) {
|
|
start := time.Now()
|
|
r0, r1 := m.s.InsertUserGroupsByID(ctx, arg)
|
|
m.queryLatencies.WithLabelValues("InsertUserGroupsByID").Observe(time.Since(start).Seconds())
|
|
return r0, r1
|
|
}
|
|
|
|
func (m queryMetricsStore) InsertUserGroupsByName(ctx context.Context, arg database.InsertUserGroupsByNameParams) error {
|
|
start := time.Now()
|
|
err := m.s.InsertUserGroupsByName(ctx, arg)
|
|
m.queryLatencies.WithLabelValues("InsertUserGroupsByName").Observe(time.Since(start).Seconds())
|
|
return err
|
|
}
|
|
|
|
func (m queryMetricsStore) InsertUserLink(ctx context.Context, arg database.InsertUserLinkParams) (database.UserLink, error) {
|
|
start := time.Now()
|
|
link, err := m.s.InsertUserLink(ctx, arg)
|
|
m.queryLatencies.WithLabelValues("InsertUserLink").Observe(time.Since(start).Seconds())
|
|
return link, err
|
|
}
|
|
|
|
func (m queryMetricsStore) InsertVolumeResourceMonitor(ctx context.Context, arg database.InsertVolumeResourceMonitorParams) (database.WorkspaceAgentVolumeResourceMonitor, error) {
|
|
start := time.Now()
|
|
r0, r1 := m.s.InsertVolumeResourceMonitor(ctx, arg)
|
|
m.queryLatencies.WithLabelValues("InsertVolumeResourceMonitor").Observe(time.Since(start).Seconds())
|
|
return r0, r1
|
|
}
|
|
|
|
func (m queryMetricsStore) InsertWorkspace(ctx context.Context, arg database.InsertWorkspaceParams) (database.WorkspaceTable, error) {
|
|
start := time.Now()
|
|
workspace, err := m.s.InsertWorkspace(ctx, arg)
|
|
m.queryLatencies.WithLabelValues("InsertWorkspace").Observe(time.Since(start).Seconds())
|
|
return workspace, err
|
|
}
|
|
|
|
func (m queryMetricsStore) InsertWorkspaceAgent(ctx context.Context, arg database.InsertWorkspaceAgentParams) (database.WorkspaceAgent, error) {
|
|
start := time.Now()
|
|
agent, err := m.s.InsertWorkspaceAgent(ctx, arg)
|
|
m.queryLatencies.WithLabelValues("InsertWorkspaceAgent").Observe(time.Since(start).Seconds())
|
|
return agent, err
|
|
}
|
|
|
|
func (m queryMetricsStore) InsertWorkspaceAgentLogSources(ctx context.Context, arg database.InsertWorkspaceAgentLogSourcesParams) ([]database.WorkspaceAgentLogSource, error) {
|
|
start := time.Now()
|
|
r0, r1 := m.s.InsertWorkspaceAgentLogSources(ctx, arg)
|
|
m.queryLatencies.WithLabelValues("InsertWorkspaceAgentLogSources").Observe(time.Since(start).Seconds())
|
|
return r0, r1
|
|
}
|
|
|
|
func (m queryMetricsStore) InsertWorkspaceAgentLogs(ctx context.Context, arg database.InsertWorkspaceAgentLogsParams) ([]database.WorkspaceAgentLog, error) {
|
|
start := time.Now()
|
|
r0, r1 := m.s.InsertWorkspaceAgentLogs(ctx, arg)
|
|
m.queryLatencies.WithLabelValues("InsertWorkspaceAgentLogs").Observe(time.Since(start).Seconds())
|
|
return r0, r1
|
|
}
|
|
|
|
func (m queryMetricsStore) InsertWorkspaceAgentMetadata(ctx context.Context, arg database.InsertWorkspaceAgentMetadataParams) error {
|
|
start := time.Now()
|
|
err := m.s.InsertWorkspaceAgentMetadata(ctx, arg)
|
|
m.queryLatencies.WithLabelValues("InsertWorkspaceAgentMetadata").Observe(time.Since(start).Seconds())
|
|
return err
|
|
}
|
|
|
|
func (m queryMetricsStore) InsertWorkspaceAgentScriptTimings(ctx context.Context, arg database.InsertWorkspaceAgentScriptTimingsParams) (database.WorkspaceAgentScriptTiming, error) {
|
|
start := time.Now()
|
|
r0, r1 := m.s.InsertWorkspaceAgentScriptTimings(ctx, arg)
|
|
m.queryLatencies.WithLabelValues("InsertWorkspaceAgentScriptTimings").Observe(time.Since(start).Seconds())
|
|
return r0, r1
|
|
}
|
|
|
|
func (m queryMetricsStore) InsertWorkspaceAgentScripts(ctx context.Context, arg database.InsertWorkspaceAgentScriptsParams) ([]database.WorkspaceAgentScript, error) {
|
|
start := time.Now()
|
|
r0, r1 := m.s.InsertWorkspaceAgentScripts(ctx, arg)
|
|
m.queryLatencies.WithLabelValues("InsertWorkspaceAgentScripts").Observe(time.Since(start).Seconds())
|
|
return r0, r1
|
|
}
|
|
|
|
func (m queryMetricsStore) InsertWorkspaceAgentStats(ctx context.Context, arg database.InsertWorkspaceAgentStatsParams) error {
|
|
start := time.Now()
|
|
r0 := m.s.InsertWorkspaceAgentStats(ctx, arg)
|
|
m.queryLatencies.WithLabelValues("InsertWorkspaceAgentStats").Observe(time.Since(start).Seconds())
|
|
return r0
|
|
}
|
|
|
|
func (m queryMetricsStore) InsertWorkspaceApp(ctx context.Context, arg database.InsertWorkspaceAppParams) (database.WorkspaceApp, error) {
|
|
start := time.Now()
|
|
app, err := m.s.InsertWorkspaceApp(ctx, arg)
|
|
m.queryLatencies.WithLabelValues("InsertWorkspaceApp").Observe(time.Since(start).Seconds())
|
|
return app, err
|
|
}
|
|
|
|
func (m queryMetricsStore) InsertWorkspaceAppStats(ctx context.Context, arg database.InsertWorkspaceAppStatsParams) error {
|
|
start := time.Now()
|
|
r0 := m.s.InsertWorkspaceAppStats(ctx, arg)
|
|
m.queryLatencies.WithLabelValues("InsertWorkspaceAppStats").Observe(time.Since(start).Seconds())
|
|
return r0
|
|
}
|
|
|
|
func (m queryMetricsStore) InsertWorkspaceBuild(ctx context.Context, arg database.InsertWorkspaceBuildParams) error {
|
|
start := time.Now()
|
|
err := m.s.InsertWorkspaceBuild(ctx, arg)
|
|
m.queryLatencies.WithLabelValues("InsertWorkspaceBuild").Observe(time.Since(start).Seconds())
|
|
return err
|
|
}
|
|
|
|
func (m queryMetricsStore) InsertWorkspaceBuildParameters(ctx context.Context, arg database.InsertWorkspaceBuildParametersParams) error {
|
|
start := time.Now()
|
|
err := m.s.InsertWorkspaceBuildParameters(ctx, arg)
|
|
m.queryLatencies.WithLabelValues("InsertWorkspaceBuildParameters").Observe(time.Since(start).Seconds())
|
|
return err
|
|
}
|
|
|
|
func (m queryMetricsStore) InsertWorkspaceModule(ctx context.Context, arg database.InsertWorkspaceModuleParams) (database.WorkspaceModule, error) {
|
|
start := time.Now()
|
|
r0, r1 := m.s.InsertWorkspaceModule(ctx, arg)
|
|
m.queryLatencies.WithLabelValues("InsertWorkspaceModule").Observe(time.Since(start).Seconds())
|
|
return r0, r1
|
|
}
|
|
|
|
func (m queryMetricsStore) InsertWorkspaceProxy(ctx context.Context, arg database.InsertWorkspaceProxyParams) (database.WorkspaceProxy, error) {
|
|
start := time.Now()
|
|
proxy, err := m.s.InsertWorkspaceProxy(ctx, arg)
|
|
m.queryLatencies.WithLabelValues("InsertWorkspaceProxy").Observe(time.Since(start).Seconds())
|
|
return proxy, err
|
|
}
|
|
|
|
func (m queryMetricsStore) InsertWorkspaceResource(ctx context.Context, arg database.InsertWorkspaceResourceParams) (database.WorkspaceResource, error) {
|
|
start := time.Now()
|
|
resource, err := m.s.InsertWorkspaceResource(ctx, arg)
|
|
m.queryLatencies.WithLabelValues("InsertWorkspaceResource").Observe(time.Since(start).Seconds())
|
|
return resource, err
|
|
}
|
|
|
|
func (m queryMetricsStore) InsertWorkspaceResourceMetadata(ctx context.Context, arg database.InsertWorkspaceResourceMetadataParams) ([]database.WorkspaceResourceMetadatum, error) {
|
|
start := time.Now()
|
|
metadata, err := m.s.InsertWorkspaceResourceMetadata(ctx, arg)
|
|
m.queryLatencies.WithLabelValues("InsertWorkspaceResourceMetadata").Observe(time.Since(start).Seconds())
|
|
return metadata, err
|
|
}
|
|
|
|
func (m queryMetricsStore) ListProvisionerKeysByOrganization(ctx context.Context, organizationID uuid.UUID) ([]database.ProvisionerKey, error) {
|
|
start := time.Now()
|
|
r0, r1 := m.s.ListProvisionerKeysByOrganization(ctx, organizationID)
|
|
m.queryLatencies.WithLabelValues("ListProvisionerKeysByOrganization").Observe(time.Since(start).Seconds())
|
|
return r0, r1
|
|
}
|
|
|
|
func (m queryMetricsStore) ListProvisionerKeysByOrganizationExcludeReserved(ctx context.Context, organizationID uuid.UUID) ([]database.ProvisionerKey, error) {
|
|
start := time.Now()
|
|
r0, r1 := m.s.ListProvisionerKeysByOrganizationExcludeReserved(ctx, organizationID)
|
|
m.queryLatencies.WithLabelValues("ListProvisionerKeysByOrganizationExcludeReserved").Observe(time.Since(start).Seconds())
|
|
return r0, r1
|
|
}
|
|
|
|
func (m queryMetricsStore) ListWorkspaceAgentPortShares(ctx context.Context, workspaceID uuid.UUID) ([]database.WorkspaceAgentPortShare, error) {
|
|
start := time.Now()
|
|
r0, r1 := m.s.ListWorkspaceAgentPortShares(ctx, workspaceID)
|
|
m.queryLatencies.WithLabelValues("ListWorkspaceAgentPortShares").Observe(time.Since(start).Seconds())
|
|
return r0, r1
|
|
}
|
|
|
|
func (m queryMetricsStore) OIDCClaimFieldValues(ctx context.Context, organizationID database.OIDCClaimFieldValuesParams) ([]string, error) {
|
|
start := time.Now()
|
|
r0, r1 := m.s.OIDCClaimFieldValues(ctx, organizationID)
|
|
m.queryLatencies.WithLabelValues("OIDCClaimFieldValues").Observe(time.Since(start).Seconds())
|
|
return r0, r1
|
|
}
|
|
|
|
func (m queryMetricsStore) OIDCClaimFields(ctx context.Context, organizationID uuid.UUID) ([]string, error) {
|
|
start := time.Now()
|
|
r0, r1 := m.s.OIDCClaimFields(ctx, organizationID)
|
|
m.queryLatencies.WithLabelValues("OIDCClaimFields").Observe(time.Since(start).Seconds())
|
|
return r0, r1
|
|
}
|
|
|
|
func (m queryMetricsStore) OrganizationMembers(ctx context.Context, arg database.OrganizationMembersParams) ([]database.OrganizationMembersRow, error) {
|
|
start := time.Now()
|
|
r0, r1 := m.s.OrganizationMembers(ctx, arg)
|
|
m.queryLatencies.WithLabelValues("OrganizationMembers").Observe(time.Since(start).Seconds())
|
|
return r0, r1
|
|
}
|
|
|
|
func (m queryMetricsStore) PaginatedOrganizationMembers(ctx context.Context, arg database.PaginatedOrganizationMembersParams) ([]database.PaginatedOrganizationMembersRow, error) {
|
|
start := time.Now()
|
|
r0, r1 := m.s.PaginatedOrganizationMembers(ctx, arg)
|
|
m.queryLatencies.WithLabelValues("PaginatedOrganizationMembers").Observe(time.Since(start).Seconds())
|
|
return r0, r1
|
|
}
|
|
|
|
func (m queryMetricsStore) ReduceWorkspaceAgentShareLevelToAuthenticatedByTemplate(ctx context.Context, templateID uuid.UUID) error {
|
|
start := time.Now()
|
|
r0 := m.s.ReduceWorkspaceAgentShareLevelToAuthenticatedByTemplate(ctx, templateID)
|
|
m.queryLatencies.WithLabelValues("ReduceWorkspaceAgentShareLevelToAuthenticatedByTemplate").Observe(time.Since(start).Seconds())
|
|
return r0
|
|
}
|
|
|
|
func (m queryMetricsStore) RegisterWorkspaceProxy(ctx context.Context, arg database.RegisterWorkspaceProxyParams) (database.WorkspaceProxy, error) {
|
|
start := time.Now()
|
|
proxy, err := m.s.RegisterWorkspaceProxy(ctx, arg)
|
|
m.queryLatencies.WithLabelValues("RegisterWorkspaceProxy").Observe(time.Since(start).Seconds())
|
|
return proxy, err
|
|
}
|
|
|
|
func (m queryMetricsStore) RemoveUserFromAllGroups(ctx context.Context, userID uuid.UUID) error {
|
|
start := time.Now()
|
|
r0 := m.s.RemoveUserFromAllGroups(ctx, userID)
|
|
m.queryLatencies.WithLabelValues("RemoveUserFromAllGroups").Observe(time.Since(start).Seconds())
|
|
return r0
|
|
}
|
|
|
|
func (m queryMetricsStore) RemoveUserFromGroups(ctx context.Context, arg database.RemoveUserFromGroupsParams) ([]uuid.UUID, error) {
|
|
start := time.Now()
|
|
r0, r1 := m.s.RemoveUserFromGroups(ctx, arg)
|
|
m.queryLatencies.WithLabelValues("RemoveUserFromGroups").Observe(time.Since(start).Seconds())
|
|
return r0, r1
|
|
}
|
|
|
|
func (m queryMetricsStore) RevokeDBCryptKey(ctx context.Context, activeKeyDigest string) error {
|
|
start := time.Now()
|
|
r0 := m.s.RevokeDBCryptKey(ctx, activeKeyDigest)
|
|
m.queryLatencies.WithLabelValues("RevokeDBCryptKey").Observe(time.Since(start).Seconds())
|
|
return r0
|
|
}
|
|
|
|
func (m queryMetricsStore) TryAcquireLock(ctx context.Context, pgTryAdvisoryXactLock int64) (bool, error) {
|
|
start := time.Now()
|
|
ok, err := m.s.TryAcquireLock(ctx, pgTryAdvisoryXactLock)
|
|
m.queryLatencies.WithLabelValues("TryAcquireLock").Observe(time.Since(start).Seconds())
|
|
return ok, err
|
|
}
|
|
|
|
func (m queryMetricsStore) UnarchiveTemplateVersion(ctx context.Context, arg database.UnarchiveTemplateVersionParams) error {
|
|
start := time.Now()
|
|
r0 := m.s.UnarchiveTemplateVersion(ctx, arg)
|
|
m.queryLatencies.WithLabelValues("UnarchiveTemplateVersion").Observe(time.Since(start).Seconds())
|
|
return r0
|
|
}
|
|
|
|
func (m queryMetricsStore) UnfavoriteWorkspace(ctx context.Context, arg uuid.UUID) error {
|
|
start := time.Now()
|
|
r0 := m.s.UnfavoriteWorkspace(ctx, arg)
|
|
m.queryLatencies.WithLabelValues("UnfavoriteWorkspace").Observe(time.Since(start).Seconds())
|
|
return r0
|
|
}
|
|
|
|
func (m queryMetricsStore) UpdateAPIKeyByID(ctx context.Context, arg database.UpdateAPIKeyByIDParams) error {
|
|
start := time.Now()
|
|
err := m.s.UpdateAPIKeyByID(ctx, arg)
|
|
m.queryLatencies.WithLabelValues("UpdateAPIKeyByID").Observe(time.Since(start).Seconds())
|
|
return err
|
|
}
|
|
|
|
func (m queryMetricsStore) UpdateCryptoKeyDeletesAt(ctx context.Context, arg database.UpdateCryptoKeyDeletesAtParams) (database.CryptoKey, error) {
|
|
start := time.Now()
|
|
key, err := m.s.UpdateCryptoKeyDeletesAt(ctx, arg)
|
|
m.queryLatencies.WithLabelValues("UpdateCryptoKeyDeletesAt").Observe(time.Since(start).Seconds())
|
|
return key, err
|
|
}
|
|
|
|
func (m queryMetricsStore) UpdateCustomRole(ctx context.Context, arg database.UpdateCustomRoleParams) (database.CustomRole, error) {
|
|
start := time.Now()
|
|
r0, r1 := m.s.UpdateCustomRole(ctx, arg)
|
|
m.queryLatencies.WithLabelValues("UpdateCustomRole").Observe(time.Since(start).Seconds())
|
|
return r0, r1
|
|
}
|
|
|
|
func (m queryMetricsStore) UpdateExternalAuthLink(ctx context.Context, arg database.UpdateExternalAuthLinkParams) (database.ExternalAuthLink, error) {
|
|
start := time.Now()
|
|
link, err := m.s.UpdateExternalAuthLink(ctx, arg)
|
|
m.queryLatencies.WithLabelValues("UpdateExternalAuthLink").Observe(time.Since(start).Seconds())
|
|
return link, err
|
|
}
|
|
|
|
func (m queryMetricsStore) UpdateExternalAuthLinkRefreshToken(ctx context.Context, arg database.UpdateExternalAuthLinkRefreshTokenParams) error {
|
|
start := time.Now()
|
|
r0 := m.s.UpdateExternalAuthLinkRefreshToken(ctx, arg)
|
|
m.queryLatencies.WithLabelValues("UpdateExternalAuthLinkRefreshToken").Observe(time.Since(start).Seconds())
|
|
return r0
|
|
}
|
|
|
|
func (m queryMetricsStore) UpdateGitSSHKey(ctx context.Context, arg database.UpdateGitSSHKeyParams) (database.GitSSHKey, error) {
|
|
start := time.Now()
|
|
key, err := m.s.UpdateGitSSHKey(ctx, arg)
|
|
m.queryLatencies.WithLabelValues("UpdateGitSSHKey").Observe(time.Since(start).Seconds())
|
|
return key, err
|
|
}
|
|
|
|
func (m queryMetricsStore) UpdateGroupByID(ctx context.Context, arg database.UpdateGroupByIDParams) (database.Group, error) {
|
|
start := time.Now()
|
|
group, err := m.s.UpdateGroupByID(ctx, arg)
|
|
m.queryLatencies.WithLabelValues("UpdateGroupByID").Observe(time.Since(start).Seconds())
|
|
return group, err
|
|
}
|
|
|
|
func (m queryMetricsStore) UpdateInactiveUsersToDormant(ctx context.Context, lastSeenAfter database.UpdateInactiveUsersToDormantParams) ([]database.UpdateInactiveUsersToDormantRow, error) {
|
|
start := time.Now()
|
|
r0, r1 := m.s.UpdateInactiveUsersToDormant(ctx, lastSeenAfter)
|
|
m.queryLatencies.WithLabelValues("UpdateInactiveUsersToDormant").Observe(time.Since(start).Seconds())
|
|
return r0, r1
|
|
}
|
|
|
|
func (m queryMetricsStore) UpdateInboxNotificationReadStatus(ctx context.Context, arg database.UpdateInboxNotificationReadStatusParams) error {
|
|
start := time.Now()
|
|
r0 := m.s.UpdateInboxNotificationReadStatus(ctx, arg)
|
|
m.queryLatencies.WithLabelValues("UpdateInboxNotificationReadStatus").Observe(time.Since(start).Seconds())
|
|
return r0
|
|
}
|
|
|
|
func (m queryMetricsStore) UpdateMemberRoles(ctx context.Context, arg database.UpdateMemberRolesParams) (database.OrganizationMember, error) {
|
|
start := time.Now()
|
|
member, err := m.s.UpdateMemberRoles(ctx, arg)
|
|
m.queryLatencies.WithLabelValues("UpdateMemberRoles").Observe(time.Since(start).Seconds())
|
|
return member, err
|
|
}
|
|
|
|
func (m queryMetricsStore) UpdateMemoryResourceMonitor(ctx context.Context, arg database.UpdateMemoryResourceMonitorParams) error {
|
|
start := time.Now()
|
|
r0 := m.s.UpdateMemoryResourceMonitor(ctx, arg)
|
|
m.queryLatencies.WithLabelValues("UpdateMemoryResourceMonitor").Observe(time.Since(start).Seconds())
|
|
return r0
|
|
}
|
|
|
|
func (m queryMetricsStore) UpdateNotificationTemplateMethodByID(ctx context.Context, arg database.UpdateNotificationTemplateMethodByIDParams) (database.NotificationTemplate, error) {
|
|
start := time.Now()
|
|
r0, r1 := m.s.UpdateNotificationTemplateMethodByID(ctx, arg)
|
|
m.queryLatencies.WithLabelValues("UpdateNotificationTemplateMethodByID").Observe(time.Since(start).Seconds())
|
|
return r0, r1
|
|
}
|
|
|
|
func (m queryMetricsStore) UpdateOAuth2ProviderAppByID(ctx context.Context, arg database.UpdateOAuth2ProviderAppByIDParams) (database.OAuth2ProviderApp, error) {
|
|
start := time.Now()
|
|
r0, r1 := m.s.UpdateOAuth2ProviderAppByID(ctx, arg)
|
|
m.queryLatencies.WithLabelValues("UpdateOAuth2ProviderAppByID").Observe(time.Since(start).Seconds())
|
|
return r0, r1
|
|
}
|
|
|
|
func (m queryMetricsStore) UpdateOAuth2ProviderAppSecretByID(ctx context.Context, arg database.UpdateOAuth2ProviderAppSecretByIDParams) (database.OAuth2ProviderAppSecret, error) {
|
|
start := time.Now()
|
|
r0, r1 := m.s.UpdateOAuth2ProviderAppSecretByID(ctx, arg)
|
|
m.queryLatencies.WithLabelValues("UpdateOAuth2ProviderAppSecretByID").Observe(time.Since(start).Seconds())
|
|
return r0, r1
|
|
}
|
|
|
|
func (m queryMetricsStore) UpdateOrganization(ctx context.Context, arg database.UpdateOrganizationParams) (database.Organization, error) {
|
|
start := time.Now()
|
|
r0, r1 := m.s.UpdateOrganization(ctx, arg)
|
|
m.queryLatencies.WithLabelValues("UpdateOrganization").Observe(time.Since(start).Seconds())
|
|
return r0, r1
|
|
}
|
|
|
|
func (m queryMetricsStore) UpdateOrganizationDeletedByID(ctx context.Context, arg database.UpdateOrganizationDeletedByIDParams) error {
|
|
start := time.Now()
|
|
r0 := m.s.UpdateOrganizationDeletedByID(ctx, arg)
|
|
m.queryLatencies.WithLabelValues("UpdateOrganizationDeletedByID").Observe(time.Since(start).Seconds())
|
|
return r0
|
|
}
|
|
|
|
func (m queryMetricsStore) UpdateProvisionerDaemonLastSeenAt(ctx context.Context, arg database.UpdateProvisionerDaemonLastSeenAtParams) error {
|
|
start := time.Now()
|
|
r0 := m.s.UpdateProvisionerDaemonLastSeenAt(ctx, arg)
|
|
m.queryLatencies.WithLabelValues("UpdateProvisionerDaemonLastSeenAt").Observe(time.Since(start).Seconds())
|
|
return r0
|
|
}
|
|
|
|
func (m queryMetricsStore) UpdateProvisionerJobByID(ctx context.Context, arg database.UpdateProvisionerJobByIDParams) error {
|
|
start := time.Now()
|
|
err := m.s.UpdateProvisionerJobByID(ctx, arg)
|
|
m.queryLatencies.WithLabelValues("UpdateProvisionerJobByID").Observe(time.Since(start).Seconds())
|
|
return err
|
|
}
|
|
|
|
func (m queryMetricsStore) UpdateProvisionerJobWithCancelByID(ctx context.Context, arg database.UpdateProvisionerJobWithCancelByIDParams) error {
|
|
start := time.Now()
|
|
err := m.s.UpdateProvisionerJobWithCancelByID(ctx, arg)
|
|
m.queryLatencies.WithLabelValues("UpdateProvisionerJobWithCancelByID").Observe(time.Since(start).Seconds())
|
|
return err
|
|
}
|
|
|
|
func (m queryMetricsStore) UpdateProvisionerJobWithCompleteByID(ctx context.Context, arg database.UpdateProvisionerJobWithCompleteByIDParams) error {
|
|
start := time.Now()
|
|
err := m.s.UpdateProvisionerJobWithCompleteByID(ctx, arg)
|
|
m.queryLatencies.WithLabelValues("UpdateProvisionerJobWithCompleteByID").Observe(time.Since(start).Seconds())
|
|
return err
|
|
}
|
|
|
|
func (m queryMetricsStore) UpdateReplica(ctx context.Context, arg database.UpdateReplicaParams) (database.Replica, error) {
|
|
start := time.Now()
|
|
replica, err := m.s.UpdateReplica(ctx, arg)
|
|
m.queryLatencies.WithLabelValues("UpdateReplica").Observe(time.Since(start).Seconds())
|
|
return replica, err
|
|
}
|
|
|
|
func (m queryMetricsStore) UpdateTailnetPeerStatusByCoordinator(ctx context.Context, arg database.UpdateTailnetPeerStatusByCoordinatorParams) error {
|
|
start := time.Now()
|
|
r0 := m.s.UpdateTailnetPeerStatusByCoordinator(ctx, arg)
|
|
m.queryLatencies.WithLabelValues("UpdateTailnetPeerStatusByCoordinator").Observe(time.Since(start).Seconds())
|
|
return r0
|
|
}
|
|
|
|
func (m queryMetricsStore) UpdateTemplateACLByID(ctx context.Context, arg database.UpdateTemplateACLByIDParams) error {
|
|
start := time.Now()
|
|
err := m.s.UpdateTemplateACLByID(ctx, arg)
|
|
m.queryLatencies.WithLabelValues("UpdateTemplateACLByID").Observe(time.Since(start).Seconds())
|
|
return err
|
|
}
|
|
|
|
func (m queryMetricsStore) UpdateTemplateAccessControlByID(ctx context.Context, arg database.UpdateTemplateAccessControlByIDParams) error {
|
|
start := time.Now()
|
|
r0 := m.s.UpdateTemplateAccessControlByID(ctx, arg)
|
|
m.queryLatencies.WithLabelValues("UpdateTemplateAccessControlByID").Observe(time.Since(start).Seconds())
|
|
return r0
|
|
}
|
|
|
|
func (m queryMetricsStore) UpdateTemplateActiveVersionByID(ctx context.Context, arg database.UpdateTemplateActiveVersionByIDParams) error {
|
|
start := time.Now()
|
|
err := m.s.UpdateTemplateActiveVersionByID(ctx, arg)
|
|
m.queryLatencies.WithLabelValues("UpdateTemplateActiveVersionByID").Observe(time.Since(start).Seconds())
|
|
return err
|
|
}
|
|
|
|
func (m queryMetricsStore) UpdateTemplateDeletedByID(ctx context.Context, arg database.UpdateTemplateDeletedByIDParams) error {
|
|
start := time.Now()
|
|
err := m.s.UpdateTemplateDeletedByID(ctx, arg)
|
|
m.queryLatencies.WithLabelValues("UpdateTemplateDeletedByID").Observe(time.Since(start).Seconds())
|
|
return err
|
|
}
|
|
|
|
func (m queryMetricsStore) UpdateTemplateMetaByID(ctx context.Context, arg database.UpdateTemplateMetaByIDParams) error {
|
|
start := time.Now()
|
|
err := m.s.UpdateTemplateMetaByID(ctx, arg)
|
|
m.queryLatencies.WithLabelValues("UpdateTemplateMetaByID").Observe(time.Since(start).Seconds())
|
|
return err
|
|
}
|
|
|
|
func (m queryMetricsStore) UpdateTemplateScheduleByID(ctx context.Context, arg database.UpdateTemplateScheduleByIDParams) error {
|
|
start := time.Now()
|
|
err := m.s.UpdateTemplateScheduleByID(ctx, arg)
|
|
m.queryLatencies.WithLabelValues("UpdateTemplateScheduleByID").Observe(time.Since(start).Seconds())
|
|
return err
|
|
}
|
|
|
|
func (m queryMetricsStore) UpdateTemplateVersionByID(ctx context.Context, arg database.UpdateTemplateVersionByIDParams) error {
|
|
start := time.Now()
|
|
err := m.s.UpdateTemplateVersionByID(ctx, arg)
|
|
m.queryLatencies.WithLabelValues("UpdateTemplateVersionByID").Observe(time.Since(start).Seconds())
|
|
return err
|
|
}
|
|
|
|
func (m queryMetricsStore) UpdateTemplateVersionDescriptionByJobID(ctx context.Context, arg database.UpdateTemplateVersionDescriptionByJobIDParams) error {
|
|
start := time.Now()
|
|
err := m.s.UpdateTemplateVersionDescriptionByJobID(ctx, arg)
|
|
m.queryLatencies.WithLabelValues("UpdateTemplateVersionDescriptionByJobID").Observe(time.Since(start).Seconds())
|
|
return err
|
|
}
|
|
|
|
func (m queryMetricsStore) UpdateTemplateVersionExternalAuthProvidersByJobID(ctx context.Context, arg database.UpdateTemplateVersionExternalAuthProvidersByJobIDParams) error {
|
|
start := time.Now()
|
|
err := m.s.UpdateTemplateVersionExternalAuthProvidersByJobID(ctx, arg)
|
|
m.queryLatencies.WithLabelValues("UpdateTemplateVersionExternalAuthProvidersByJobID").Observe(time.Since(start).Seconds())
|
|
return err
|
|
}
|
|
|
|
func (m queryMetricsStore) UpdateTemplateWorkspacesLastUsedAt(ctx context.Context, arg database.UpdateTemplateWorkspacesLastUsedAtParams) error {
|
|
start := time.Now()
|
|
r0 := m.s.UpdateTemplateWorkspacesLastUsedAt(ctx, arg)
|
|
m.queryLatencies.WithLabelValues("UpdateTemplateWorkspacesLastUsedAt").Observe(time.Since(start).Seconds())
|
|
return r0
|
|
}
|
|
|
|
func (m queryMetricsStore) UpdateUserAppearanceSettings(ctx context.Context, arg database.UpdateUserAppearanceSettingsParams) (database.UserConfig, error) {
|
|
start := time.Now()
|
|
r0, r1 := m.s.UpdateUserAppearanceSettings(ctx, arg)
|
|
m.queryLatencies.WithLabelValues("UpdateUserAppearanceSettings").Observe(time.Since(start).Seconds())
|
|
return r0, r1
|
|
}
|
|
|
|
func (m queryMetricsStore) UpdateUserDeletedByID(ctx context.Context, id uuid.UUID) error {
|
|
start := time.Now()
|
|
r0 := m.s.UpdateUserDeletedByID(ctx, id)
|
|
m.queryLatencies.WithLabelValues("UpdateUserDeletedByID").Observe(time.Since(start).Seconds())
|
|
return r0
|
|
}
|
|
|
|
func (m queryMetricsStore) UpdateUserGithubComUserID(ctx context.Context, arg database.UpdateUserGithubComUserIDParams) error {
|
|
start := time.Now()
|
|
r0 := m.s.UpdateUserGithubComUserID(ctx, arg)
|
|
m.queryLatencies.WithLabelValues("UpdateUserGithubComUserID").Observe(time.Since(start).Seconds())
|
|
return r0
|
|
}
|
|
|
|
func (m queryMetricsStore) UpdateUserHashedOneTimePasscode(ctx context.Context, arg database.UpdateUserHashedOneTimePasscodeParams) error {
|
|
start := time.Now()
|
|
r0 := m.s.UpdateUserHashedOneTimePasscode(ctx, arg)
|
|
m.queryLatencies.WithLabelValues("UpdateUserHashedOneTimePasscode").Observe(time.Since(start).Seconds())
|
|
return r0
|
|
}
|
|
|
|
func (m queryMetricsStore) UpdateUserHashedPassword(ctx context.Context, arg database.UpdateUserHashedPasswordParams) error {
|
|
start := time.Now()
|
|
err := m.s.UpdateUserHashedPassword(ctx, arg)
|
|
m.queryLatencies.WithLabelValues("UpdateUserHashedPassword").Observe(time.Since(start).Seconds())
|
|
return err
|
|
}
|
|
|
|
func (m queryMetricsStore) UpdateUserLastSeenAt(ctx context.Context, arg database.UpdateUserLastSeenAtParams) (database.User, error) {
|
|
start := time.Now()
|
|
user, err := m.s.UpdateUserLastSeenAt(ctx, arg)
|
|
m.queryLatencies.WithLabelValues("UpdateUserLastSeenAt").Observe(time.Since(start).Seconds())
|
|
return user, err
|
|
}
|
|
|
|
func (m queryMetricsStore) UpdateUserLink(ctx context.Context, arg database.UpdateUserLinkParams) (database.UserLink, error) {
|
|
start := time.Now()
|
|
link, err := m.s.UpdateUserLink(ctx, arg)
|
|
m.queryLatencies.WithLabelValues("UpdateUserLink").Observe(time.Since(start).Seconds())
|
|
return link, err
|
|
}
|
|
|
|
func (m queryMetricsStore) UpdateUserLinkedID(ctx context.Context, arg database.UpdateUserLinkedIDParams) (database.UserLink, error) {
|
|
start := time.Now()
|
|
link, err := m.s.UpdateUserLinkedID(ctx, arg)
|
|
m.queryLatencies.WithLabelValues("UpdateUserLinkedID").Observe(time.Since(start).Seconds())
|
|
return link, err
|
|
}
|
|
|
|
func (m queryMetricsStore) UpdateUserLoginType(ctx context.Context, arg database.UpdateUserLoginTypeParams) (database.User, error) {
|
|
start := time.Now()
|
|
r0, r1 := m.s.UpdateUserLoginType(ctx, arg)
|
|
m.queryLatencies.WithLabelValues("UpdateUserLoginType").Observe(time.Since(start).Seconds())
|
|
return r0, r1
|
|
}
|
|
|
|
func (m queryMetricsStore) UpdateUserNotificationPreferences(ctx context.Context, arg database.UpdateUserNotificationPreferencesParams) (int64, error) {
|
|
start := time.Now()
|
|
r0, r1 := m.s.UpdateUserNotificationPreferences(ctx, arg)
|
|
m.queryLatencies.WithLabelValues("UpdateUserNotificationPreferences").Observe(time.Since(start).Seconds())
|
|
return r0, r1
|
|
}
|
|
|
|
func (m queryMetricsStore) UpdateUserProfile(ctx context.Context, arg database.UpdateUserProfileParams) (database.User, error) {
|
|
start := time.Now()
|
|
user, err := m.s.UpdateUserProfile(ctx, arg)
|
|
m.queryLatencies.WithLabelValues("UpdateUserProfile").Observe(time.Since(start).Seconds())
|
|
return user, err
|
|
}
|
|
|
|
func (m queryMetricsStore) UpdateUserQuietHoursSchedule(ctx context.Context, arg database.UpdateUserQuietHoursScheduleParams) (database.User, error) {
|
|
start := time.Now()
|
|
r0, r1 := m.s.UpdateUserQuietHoursSchedule(ctx, arg)
|
|
m.queryLatencies.WithLabelValues("UpdateUserQuietHoursSchedule").Observe(time.Since(start).Seconds())
|
|
return r0, r1
|
|
}
|
|
|
|
func (m queryMetricsStore) UpdateUserRoles(ctx context.Context, arg database.UpdateUserRolesParams) (database.User, error) {
|
|
start := time.Now()
|
|
user, err := m.s.UpdateUserRoles(ctx, arg)
|
|
m.queryLatencies.WithLabelValues("UpdateUserRoles").Observe(time.Since(start).Seconds())
|
|
return user, err
|
|
}
|
|
|
|
func (m queryMetricsStore) UpdateUserStatus(ctx context.Context, arg database.UpdateUserStatusParams) (database.User, error) {
|
|
start := time.Now()
|
|
user, err := m.s.UpdateUserStatus(ctx, arg)
|
|
m.queryLatencies.WithLabelValues("UpdateUserStatus").Observe(time.Since(start).Seconds())
|
|
return user, err
|
|
}
|
|
|
|
func (m queryMetricsStore) UpdateVolumeResourceMonitor(ctx context.Context, arg database.UpdateVolumeResourceMonitorParams) error {
|
|
start := time.Now()
|
|
r0 := m.s.UpdateVolumeResourceMonitor(ctx, arg)
|
|
m.queryLatencies.WithLabelValues("UpdateVolumeResourceMonitor").Observe(time.Since(start).Seconds())
|
|
return r0
|
|
}
|
|
|
|
func (m queryMetricsStore) UpdateWorkspace(ctx context.Context, arg database.UpdateWorkspaceParams) (database.WorkspaceTable, error) {
|
|
start := time.Now()
|
|
workspace, err := m.s.UpdateWorkspace(ctx, arg)
|
|
m.queryLatencies.WithLabelValues("UpdateWorkspace").Observe(time.Since(start).Seconds())
|
|
return workspace, err
|
|
}
|
|
|
|
func (m queryMetricsStore) UpdateWorkspaceAgentConnectionByID(ctx context.Context, arg database.UpdateWorkspaceAgentConnectionByIDParams) error {
|
|
start := time.Now()
|
|
err := m.s.UpdateWorkspaceAgentConnectionByID(ctx, arg)
|
|
m.queryLatencies.WithLabelValues("UpdateWorkspaceAgentConnectionByID").Observe(time.Since(start).Seconds())
|
|
return err
|
|
}
|
|
|
|
func (m queryMetricsStore) UpdateWorkspaceAgentLifecycleStateByID(ctx context.Context, arg database.UpdateWorkspaceAgentLifecycleStateByIDParams) error {
|
|
start := time.Now()
|
|
r0 := m.s.UpdateWorkspaceAgentLifecycleStateByID(ctx, arg)
|
|
m.queryLatencies.WithLabelValues("UpdateWorkspaceAgentLifecycleStateByID").Observe(time.Since(start).Seconds())
|
|
return r0
|
|
}
|
|
|
|
func (m queryMetricsStore) UpdateWorkspaceAgentLogOverflowByID(ctx context.Context, arg database.UpdateWorkspaceAgentLogOverflowByIDParams) error {
|
|
start := time.Now()
|
|
r0 := m.s.UpdateWorkspaceAgentLogOverflowByID(ctx, arg)
|
|
m.queryLatencies.WithLabelValues("UpdateWorkspaceAgentLogOverflowByID").Observe(time.Since(start).Seconds())
|
|
return r0
|
|
}
|
|
|
|
func (m queryMetricsStore) UpdateWorkspaceAgentMetadata(ctx context.Context, arg database.UpdateWorkspaceAgentMetadataParams) error {
|
|
start := time.Now()
|
|
err := m.s.UpdateWorkspaceAgentMetadata(ctx, arg)
|
|
m.queryLatencies.WithLabelValues("UpdateWorkspaceAgentMetadata").Observe(time.Since(start).Seconds())
|
|
return err
|
|
}
|
|
|
|
func (m queryMetricsStore) UpdateWorkspaceAgentStartupByID(ctx context.Context, arg database.UpdateWorkspaceAgentStartupByIDParams) error {
|
|
start := time.Now()
|
|
err := m.s.UpdateWorkspaceAgentStartupByID(ctx, arg)
|
|
m.queryLatencies.WithLabelValues("UpdateWorkspaceAgentStartupByID").Observe(time.Since(start).Seconds())
|
|
return err
|
|
}
|
|
|
|
func (m queryMetricsStore) UpdateWorkspaceAppHealthByID(ctx context.Context, arg database.UpdateWorkspaceAppHealthByIDParams) error {
|
|
start := time.Now()
|
|
err := m.s.UpdateWorkspaceAppHealthByID(ctx, arg)
|
|
m.queryLatencies.WithLabelValues("UpdateWorkspaceAppHealthByID").Observe(time.Since(start).Seconds())
|
|
return err
|
|
}
|
|
|
|
func (m queryMetricsStore) UpdateWorkspaceAutomaticUpdates(ctx context.Context, arg database.UpdateWorkspaceAutomaticUpdatesParams) error {
|
|
start := time.Now()
|
|
r0 := m.s.UpdateWorkspaceAutomaticUpdates(ctx, arg)
|
|
m.queryLatencies.WithLabelValues("UpdateWorkspaceAutomaticUpdates").Observe(time.Since(start).Seconds())
|
|
return r0
|
|
}
|
|
|
|
func (m queryMetricsStore) UpdateWorkspaceAutostart(ctx context.Context, arg database.UpdateWorkspaceAutostartParams) error {
|
|
start := time.Now()
|
|
err := m.s.UpdateWorkspaceAutostart(ctx, arg)
|
|
m.queryLatencies.WithLabelValues("UpdateWorkspaceAutostart").Observe(time.Since(start).Seconds())
|
|
return err
|
|
}
|
|
|
|
func (m queryMetricsStore) UpdateWorkspaceBuildCostByID(ctx context.Context, arg database.UpdateWorkspaceBuildCostByIDParams) error {
|
|
start := time.Now()
|
|
err := m.s.UpdateWorkspaceBuildCostByID(ctx, arg)
|
|
m.queryLatencies.WithLabelValues("UpdateWorkspaceBuildCostByID").Observe(time.Since(start).Seconds())
|
|
return err
|
|
}
|
|
|
|
func (m queryMetricsStore) UpdateWorkspaceBuildDeadlineByID(ctx context.Context, arg database.UpdateWorkspaceBuildDeadlineByIDParams) error {
|
|
start := time.Now()
|
|
r0 := m.s.UpdateWorkspaceBuildDeadlineByID(ctx, arg)
|
|
m.queryLatencies.WithLabelValues("UpdateWorkspaceBuildDeadlineByID").Observe(time.Since(start).Seconds())
|
|
return r0
|
|
}
|
|
|
|
func (m queryMetricsStore) UpdateWorkspaceBuildProvisionerStateByID(ctx context.Context, arg database.UpdateWorkspaceBuildProvisionerStateByIDParams) error {
|
|
start := time.Now()
|
|
r0 := m.s.UpdateWorkspaceBuildProvisionerStateByID(ctx, arg)
|
|
m.queryLatencies.WithLabelValues("UpdateWorkspaceBuildProvisionerStateByID").Observe(time.Since(start).Seconds())
|
|
return r0
|
|
}
|
|
|
|
func (m queryMetricsStore) UpdateWorkspaceDeletedByID(ctx context.Context, arg database.UpdateWorkspaceDeletedByIDParams) error {
|
|
start := time.Now()
|
|
err := m.s.UpdateWorkspaceDeletedByID(ctx, arg)
|
|
m.queryLatencies.WithLabelValues("UpdateWorkspaceDeletedByID").Observe(time.Since(start).Seconds())
|
|
return err
|
|
}
|
|
|
|
func (m queryMetricsStore) UpdateWorkspaceDormantDeletingAt(ctx context.Context, arg database.UpdateWorkspaceDormantDeletingAtParams) (database.WorkspaceTable, error) {
|
|
start := time.Now()
|
|
ws, r0 := m.s.UpdateWorkspaceDormantDeletingAt(ctx, arg)
|
|
m.queryLatencies.WithLabelValues("UpdateWorkspaceDormantDeletingAt").Observe(time.Since(start).Seconds())
|
|
return ws, r0
|
|
}
|
|
|
|
func (m queryMetricsStore) UpdateWorkspaceLastUsedAt(ctx context.Context, arg database.UpdateWorkspaceLastUsedAtParams) error {
|
|
start := time.Now()
|
|
err := m.s.UpdateWorkspaceLastUsedAt(ctx, arg)
|
|
m.queryLatencies.WithLabelValues("UpdateWorkspaceLastUsedAt").Observe(time.Since(start).Seconds())
|
|
return err
|
|
}
|
|
|
|
func (m queryMetricsStore) UpdateWorkspaceNextStartAt(ctx context.Context, arg database.UpdateWorkspaceNextStartAtParams) error {
|
|
start := time.Now()
|
|
r0 := m.s.UpdateWorkspaceNextStartAt(ctx, arg)
|
|
m.queryLatencies.WithLabelValues("UpdateWorkspaceNextStartAt").Observe(time.Since(start).Seconds())
|
|
return r0
|
|
}
|
|
|
|
func (m queryMetricsStore) UpdateWorkspaceProxy(ctx context.Context, arg database.UpdateWorkspaceProxyParams) (database.WorkspaceProxy, error) {
|
|
start := time.Now()
|
|
proxy, err := m.s.UpdateWorkspaceProxy(ctx, arg)
|
|
m.queryLatencies.WithLabelValues("UpdateWorkspaceProxy").Observe(time.Since(start).Seconds())
|
|
return proxy, err
|
|
}
|
|
|
|
func (m queryMetricsStore) UpdateWorkspaceProxyDeleted(ctx context.Context, arg database.UpdateWorkspaceProxyDeletedParams) error {
|
|
start := time.Now()
|
|
r0 := m.s.UpdateWorkspaceProxyDeleted(ctx, arg)
|
|
m.queryLatencies.WithLabelValues("UpdateWorkspaceProxyDeleted").Observe(time.Since(start).Seconds())
|
|
return r0
|
|
}
|
|
|
|
func (m queryMetricsStore) UpdateWorkspaceTTL(ctx context.Context, arg database.UpdateWorkspaceTTLParams) error {
|
|
start := time.Now()
|
|
r0 := m.s.UpdateWorkspaceTTL(ctx, arg)
|
|
m.queryLatencies.WithLabelValues("UpdateWorkspaceTTL").Observe(time.Since(start).Seconds())
|
|
return r0
|
|
}
|
|
|
|
func (m queryMetricsStore) UpdateWorkspacesDormantDeletingAtByTemplateID(ctx context.Context, arg database.UpdateWorkspacesDormantDeletingAtByTemplateIDParams) ([]database.WorkspaceTable, error) {
|
|
start := time.Now()
|
|
r0, r1 := m.s.UpdateWorkspacesDormantDeletingAtByTemplateID(ctx, arg)
|
|
m.queryLatencies.WithLabelValues("UpdateWorkspacesDormantDeletingAtByTemplateID").Observe(time.Since(start).Seconds())
|
|
return r0, r1
|
|
}
|
|
|
|
func (m queryMetricsStore) UpdateWorkspacesTTLByTemplateID(ctx context.Context, arg database.UpdateWorkspacesTTLByTemplateIDParams) error {
|
|
start := time.Now()
|
|
r0 := m.s.UpdateWorkspacesTTLByTemplateID(ctx, arg)
|
|
m.queryLatencies.WithLabelValues("UpdateWorkspacesTTLByTemplateID").Observe(time.Since(start).Seconds())
|
|
return r0
|
|
}
|
|
|
|
func (m queryMetricsStore) UpsertAnnouncementBanners(ctx context.Context, value string) error {
|
|
start := time.Now()
|
|
r0 := m.s.UpsertAnnouncementBanners(ctx, value)
|
|
m.queryLatencies.WithLabelValues("UpsertAnnouncementBanners").Observe(time.Since(start).Seconds())
|
|
return r0
|
|
}
|
|
|
|
func (m queryMetricsStore) UpsertAppSecurityKey(ctx context.Context, value string) error {
|
|
start := time.Now()
|
|
r0 := m.s.UpsertAppSecurityKey(ctx, value)
|
|
m.queryLatencies.WithLabelValues("UpsertAppSecurityKey").Observe(time.Since(start).Seconds())
|
|
return r0
|
|
}
|
|
|
|
func (m queryMetricsStore) UpsertApplicationName(ctx context.Context, value string) error {
|
|
start := time.Now()
|
|
r0 := m.s.UpsertApplicationName(ctx, value)
|
|
m.queryLatencies.WithLabelValues("UpsertApplicationName").Observe(time.Since(start).Seconds())
|
|
return r0
|
|
}
|
|
|
|
func (m queryMetricsStore) UpsertCoordinatorResumeTokenSigningKey(ctx context.Context, value string) error {
|
|
start := time.Now()
|
|
r0 := m.s.UpsertCoordinatorResumeTokenSigningKey(ctx, value)
|
|
m.queryLatencies.WithLabelValues("UpsertCoordinatorResumeTokenSigningKey").Observe(time.Since(start).Seconds())
|
|
return r0
|
|
}
|
|
|
|
func (m queryMetricsStore) UpsertDefaultProxy(ctx context.Context, arg database.UpsertDefaultProxyParams) error {
|
|
start := time.Now()
|
|
r0 := m.s.UpsertDefaultProxy(ctx, arg)
|
|
m.queryLatencies.WithLabelValues("UpsertDefaultProxy").Observe(time.Since(start).Seconds())
|
|
return r0
|
|
}
|
|
|
|
func (m queryMetricsStore) UpsertHealthSettings(ctx context.Context, value string) error {
|
|
start := time.Now()
|
|
r0 := m.s.UpsertHealthSettings(ctx, value)
|
|
m.queryLatencies.WithLabelValues("UpsertHealthSettings").Observe(time.Since(start).Seconds())
|
|
return r0
|
|
}
|
|
|
|
func (m queryMetricsStore) UpsertJFrogXrayScanByWorkspaceAndAgentID(ctx context.Context, arg database.UpsertJFrogXrayScanByWorkspaceAndAgentIDParams) error {
|
|
start := time.Now()
|
|
r0 := m.s.UpsertJFrogXrayScanByWorkspaceAndAgentID(ctx, arg)
|
|
m.queryLatencies.WithLabelValues("UpsertJFrogXrayScanByWorkspaceAndAgentID").Observe(time.Since(start).Seconds())
|
|
return r0
|
|
}
|
|
|
|
func (m queryMetricsStore) UpsertLastUpdateCheck(ctx context.Context, value string) error {
|
|
start := time.Now()
|
|
r0 := m.s.UpsertLastUpdateCheck(ctx, value)
|
|
m.queryLatencies.WithLabelValues("UpsertLastUpdateCheck").Observe(time.Since(start).Seconds())
|
|
return r0
|
|
}
|
|
|
|
func (m queryMetricsStore) UpsertLogoURL(ctx context.Context, value string) error {
|
|
start := time.Now()
|
|
r0 := m.s.UpsertLogoURL(ctx, value)
|
|
m.queryLatencies.WithLabelValues("UpsertLogoURL").Observe(time.Since(start).Seconds())
|
|
return r0
|
|
}
|
|
|
|
func (m queryMetricsStore) UpsertNotificationReportGeneratorLog(ctx context.Context, arg database.UpsertNotificationReportGeneratorLogParams) error {
|
|
start := time.Now()
|
|
r0 := m.s.UpsertNotificationReportGeneratorLog(ctx, arg)
|
|
m.queryLatencies.WithLabelValues("UpsertNotificationReportGeneratorLog").Observe(time.Since(start).Seconds())
|
|
return r0
|
|
}
|
|
|
|
func (m queryMetricsStore) UpsertNotificationsSettings(ctx context.Context, value string) error {
|
|
start := time.Now()
|
|
r0 := m.s.UpsertNotificationsSettings(ctx, value)
|
|
m.queryLatencies.WithLabelValues("UpsertNotificationsSettings").Observe(time.Since(start).Seconds())
|
|
return r0
|
|
}
|
|
|
|
func (m queryMetricsStore) UpsertOAuth2GithubDefaultEligible(ctx context.Context, eligible bool) error {
|
|
start := time.Now()
|
|
r0 := m.s.UpsertOAuth2GithubDefaultEligible(ctx, eligible)
|
|
m.queryLatencies.WithLabelValues("UpsertOAuth2GithubDefaultEligible").Observe(time.Since(start).Seconds())
|
|
return r0
|
|
}
|
|
|
|
func (m queryMetricsStore) UpsertOAuthSigningKey(ctx context.Context, value string) error {
|
|
start := time.Now()
|
|
r0 := m.s.UpsertOAuthSigningKey(ctx, value)
|
|
m.queryLatencies.WithLabelValues("UpsertOAuthSigningKey").Observe(time.Since(start).Seconds())
|
|
return r0
|
|
}
|
|
|
|
func (m queryMetricsStore) UpsertProvisionerDaemon(ctx context.Context, arg database.UpsertProvisionerDaemonParams) (database.ProvisionerDaemon, error) {
|
|
start := time.Now()
|
|
r0, r1 := m.s.UpsertProvisionerDaemon(ctx, arg)
|
|
m.queryLatencies.WithLabelValues("UpsertProvisionerDaemon").Observe(time.Since(start).Seconds())
|
|
return r0, r1
|
|
}
|
|
|
|
func (m queryMetricsStore) UpsertRuntimeConfig(ctx context.Context, arg database.UpsertRuntimeConfigParams) error {
|
|
start := time.Now()
|
|
r0 := m.s.UpsertRuntimeConfig(ctx, arg)
|
|
m.queryLatencies.WithLabelValues("UpsertRuntimeConfig").Observe(time.Since(start).Seconds())
|
|
return r0
|
|
}
|
|
|
|
func (m queryMetricsStore) UpsertTailnetAgent(ctx context.Context, arg database.UpsertTailnetAgentParams) (database.TailnetAgent, error) {
|
|
start := time.Now()
|
|
r0, r1 := m.s.UpsertTailnetAgent(ctx, arg)
|
|
m.queryLatencies.WithLabelValues("UpsertTailnetAgent").Observe(time.Since(start).Seconds())
|
|
return r0, r1
|
|
}
|
|
|
|
func (m queryMetricsStore) UpsertTailnetClient(ctx context.Context, arg database.UpsertTailnetClientParams) (database.TailnetClient, error) {
|
|
start := time.Now()
|
|
r0, r1 := m.s.UpsertTailnetClient(ctx, arg)
|
|
m.queryLatencies.WithLabelValues("UpsertTailnetClient").Observe(time.Since(start).Seconds())
|
|
return r0, r1
|
|
}
|
|
|
|
func (m queryMetricsStore) UpsertTailnetClientSubscription(ctx context.Context, arg database.UpsertTailnetClientSubscriptionParams) error {
|
|
start := time.Now()
|
|
r0 := m.s.UpsertTailnetClientSubscription(ctx, arg)
|
|
m.queryLatencies.WithLabelValues("UpsertTailnetClientSubscription").Observe(time.Since(start).Seconds())
|
|
return r0
|
|
}
|
|
|
|
func (m queryMetricsStore) UpsertTailnetCoordinator(ctx context.Context, id uuid.UUID) (database.TailnetCoordinator, error) {
|
|
start := time.Now()
|
|
r0, r1 := m.s.UpsertTailnetCoordinator(ctx, id)
|
|
m.queryLatencies.WithLabelValues("UpsertTailnetCoordinator").Observe(time.Since(start).Seconds())
|
|
return r0, r1
|
|
}
|
|
|
|
func (m queryMetricsStore) UpsertTailnetPeer(ctx context.Context, arg database.UpsertTailnetPeerParams) (database.TailnetPeer, error) {
|
|
start := time.Now()
|
|
r0, r1 := m.s.UpsertTailnetPeer(ctx, arg)
|
|
m.queryLatencies.WithLabelValues("UpsertTailnetPeer").Observe(time.Since(start).Seconds())
|
|
return r0, r1
|
|
}
|
|
|
|
func (m queryMetricsStore) UpsertTailnetTunnel(ctx context.Context, arg database.UpsertTailnetTunnelParams) (database.TailnetTunnel, error) {
|
|
start := time.Now()
|
|
r0, r1 := m.s.UpsertTailnetTunnel(ctx, arg)
|
|
m.queryLatencies.WithLabelValues("UpsertTailnetTunnel").Observe(time.Since(start).Seconds())
|
|
return r0, r1
|
|
}
|
|
|
|
func (m queryMetricsStore) UpsertTelemetryItem(ctx context.Context, arg database.UpsertTelemetryItemParams) error {
|
|
start := time.Now()
|
|
r0 := m.s.UpsertTelemetryItem(ctx, arg)
|
|
m.queryLatencies.WithLabelValues("UpsertTelemetryItem").Observe(time.Since(start).Seconds())
|
|
return r0
|
|
}
|
|
|
|
func (m queryMetricsStore) UpsertTemplateUsageStats(ctx context.Context) error {
|
|
start := time.Now()
|
|
r0 := m.s.UpsertTemplateUsageStats(ctx)
|
|
m.queryLatencies.WithLabelValues("UpsertTemplateUsageStats").Observe(time.Since(start).Seconds())
|
|
return r0
|
|
}
|
|
|
|
func (m queryMetricsStore) UpsertWorkspaceAgentPortShare(ctx context.Context, arg database.UpsertWorkspaceAgentPortShareParams) (database.WorkspaceAgentPortShare, error) {
|
|
start := time.Now()
|
|
r0, r1 := m.s.UpsertWorkspaceAgentPortShare(ctx, arg)
|
|
m.queryLatencies.WithLabelValues("UpsertWorkspaceAgentPortShare").Observe(time.Since(start).Seconds())
|
|
return r0, r1
|
|
}
|
|
|
|
func (m queryMetricsStore) GetAuthorizedTemplates(ctx context.Context, arg database.GetTemplatesWithFilterParams, prepared rbac.PreparedAuthorized) ([]database.Template, error) {
|
|
start := time.Now()
|
|
templates, err := m.s.GetAuthorizedTemplates(ctx, arg, prepared)
|
|
m.queryLatencies.WithLabelValues("GetAuthorizedTemplates").Observe(time.Since(start).Seconds())
|
|
return templates, err
|
|
}
|
|
|
|
func (m queryMetricsStore) GetTemplateGroupRoles(ctx context.Context, id uuid.UUID) ([]database.TemplateGroup, error) {
|
|
start := time.Now()
|
|
roles, err := m.s.GetTemplateGroupRoles(ctx, id)
|
|
m.queryLatencies.WithLabelValues("GetTemplateGroupRoles").Observe(time.Since(start).Seconds())
|
|
return roles, err
|
|
}
|
|
|
|
func (m queryMetricsStore) GetTemplateUserRoles(ctx context.Context, id uuid.UUID) ([]database.TemplateUser, error) {
|
|
start := time.Now()
|
|
roles, err := m.s.GetTemplateUserRoles(ctx, id)
|
|
m.queryLatencies.WithLabelValues("GetTemplateUserRoles").Observe(time.Since(start).Seconds())
|
|
return roles, err
|
|
}
|
|
|
|
func (m queryMetricsStore) GetAuthorizedWorkspaces(ctx context.Context, arg database.GetWorkspacesParams, prepared rbac.PreparedAuthorized) ([]database.GetWorkspacesRow, error) {
|
|
start := time.Now()
|
|
workspaces, err := m.s.GetAuthorizedWorkspaces(ctx, arg, prepared)
|
|
m.queryLatencies.WithLabelValues("GetAuthorizedWorkspaces").Observe(time.Since(start).Seconds())
|
|
return workspaces, err
|
|
}
|
|
|
|
func (m queryMetricsStore) GetAuthorizedWorkspacesAndAgentsByOwnerID(ctx context.Context, ownerID uuid.UUID, prepared rbac.PreparedAuthorized) ([]database.GetWorkspacesAndAgentsByOwnerIDRow, error) {
|
|
start := time.Now()
|
|
r0, r1 := m.s.GetAuthorizedWorkspacesAndAgentsByOwnerID(ctx, ownerID, prepared)
|
|
m.queryLatencies.WithLabelValues("GetAuthorizedWorkspacesAndAgentsByOwnerID").Observe(time.Since(start).Seconds())
|
|
return r0, r1
|
|
}
|
|
|
|
func (m queryMetricsStore) GetAuthorizedUsers(ctx context.Context, arg database.GetUsersParams, prepared rbac.PreparedAuthorized) ([]database.GetUsersRow, error) {
|
|
start := time.Now()
|
|
r0, r1 := m.s.GetAuthorizedUsers(ctx, arg, prepared)
|
|
m.queryLatencies.WithLabelValues("GetAuthorizedUsers").Observe(time.Since(start).Seconds())
|
|
return r0, r1
|
|
}
|
|
|
|
func (m queryMetricsStore) GetAuthorizedAuditLogsOffset(ctx context.Context, arg database.GetAuditLogsOffsetParams, prepared rbac.PreparedAuthorized) ([]database.GetAuditLogsOffsetRow, error) {
|
|
start := time.Now()
|
|
r0, r1 := m.s.GetAuthorizedAuditLogsOffset(ctx, arg, prepared)
|
|
m.queryLatencies.WithLabelValues("GetAuthorizedAuditLogsOffset").Observe(time.Since(start).Seconds())
|
|
return r0, r1
|
|
}
|