gorm

package
v0.1.0-alpha.2 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: May 31, 2023 License: MIT Imports: 10 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func NewGithubAppInstallationRepository 

func NewGithubAppInstallationRepository(db *gorm.DB) repository.GithubAppInstallationRepository

NewGithubAppInstallationRepository returns a DefaultGithubAppInstallationRepository which uses gorm.DB for querying the database

func NewGithubAppOAuthRepository 

func NewGithubAppOAuthRepository(db *gorm.DB, key *[32]byte) repository.GithubAppOAuthRepository

NewGithubAppOAuthRepository returns a DefaultGithubAppOAuthRepository which uses gorm.DB for querying the database

func NewGithubPullRequestRepository 

func NewGithubPullRequestRepository(db *gorm.DB) repository.GithubPullRequestRepository

NewGithubPullRequestRepository returns a DefaultGithubPullRequestRepository which uses gorm.DB for querying the database

func NewGithubWebhookRepository 

func NewGithubWebhookRepository(db *gorm.DB, key *[32]byte) repository.GithubWebhookRepository

NewGithubWebhookRepository returns a DefaultGithubWebhookRepository which uses gorm.DB for querying the database

func NewModuleEnvVarsRepository 

func NewModuleEnvVarsRepository(db *gorm.DB, key *[32]byte) repository.ModuleEnvVarsRepository

func NewModuleMonitorRepository 

func NewModuleMonitorRepository(db *gorm.DB) repository.ModuleMonitorRepository

func NewModuleRepository 

func NewModuleRepository(db *gorm.DB) repository.ModuleRepository

NewModuleRepository returns a DefaultModuleRepository which uses gorm.DB for querying the database

func NewModuleRunQueueRepository 

func NewModuleRunQueueRepository(db *gorm.DB) repository.ModuleRunQueueRepository

NewModuleRunQueueRepository returns a DefaultModuleRunQueueRepository which uses gorm.DB for querying the database

func NewModuleValuesRepository 

func NewModuleValuesRepository(db *gorm.DB, key *[32]byte) repository.ModuleValuesRepository

func NewNotificationRepository 

func NewNotificationRepository(db *gorm.DB) repository.NotificationRepository

NewNotificationRepository returns a DefaultNotificationRepository which uses gorm.DB for querying the database

func NewOrgRepository 

func NewOrgRepository(db *gorm.DB) repository.OrgRepository

NewOrgRepository returns a DefaultOrgRepository which uses gorm.DB for querying the database

func NewPasswordResetTokenRepository 

func NewPasswordResetTokenRepository(db *gorm.DB) repository.PasswordResetTokenRepository

NewPasswordResetTokenRepository returns a PasswordResetTokenRepository which uses gorm.DB for querying the database

func NewPersonalAccessTokenRepository 

func NewPersonalAccessTokenRepository(db *gorm.DB, key *[32]byte) repository.PersonalAccessTokenRepository

NewPersonalAccessTokenRepository returns a DefaultPersonalAccessTokenRepository which uses gorm.DB for querying the database

func NewRepository 

func NewRepository(db *gorm.DB, key *[32]byte) repository.Repository

NewRepository returns a Repository which persists users in memory and accepts a parameter that can trigger read/write errors

func NewTeamRepository 

func NewTeamRepository(db *gorm.DB) repository.TeamRepository

NewTeamRepository returns a TeamRepository which uses gorm.DB for querying the database

func NewUserRepository 

func NewUserRepository(db *gorm.DB) repository.UserRepository

NewUserRepository returns a DefaultUserRepository which uses gorm.DB for querying the database

func NewUserSessionRepository 

func NewUserSessionRepository(db *gorm.DB) repository.UserSessionRepository

func NewVerifyEmailTokenRepository 

func NewVerifyEmailTokenRepository(db *gorm.DB) repository.VerifyEmailTokenRepository

NewVerifyEmailTokenRepository returns a VerifyEmailTokenRepository which uses gorm.DB for querying the database

func NewWorkerTokenRepository 

func NewWorkerTokenRepository(db *gorm.DB) repository.WorkerTokenRepository

NewWorkerTokenRepository returns a DefaultWorkerTokenRepository which uses gorm.DB for querying the database

Types

type GithubAppInstallationRepository 

type GithubAppInstallationRepository struct {
	// contains filtered or unexported fields
}

GithubAppInstallationRepository uses gorm.DB for querying the database

func (*GithubAppInstallationRepository) CreateGithubAppInstallation 

func (repo *GithubAppInstallationRepository) CreateGithubAppInstallation(gai *models.GithubAppInstallation) (*models.GithubAppInstallation, repository.RepositoryError)

func (*GithubAppInstallationRepository) DeleteGithubAppInstallation 

func (repo *GithubAppInstallationRepository) DeleteGithubAppInstallation(
	gai *models.GithubAppInstallation,
) (*models.GithubAppInstallation, repository.RepositoryError)

func (*GithubAppInstallationRepository) ListGithubAppInstallationsByUserID 

func (repo *GithubAppInstallationRepository) ListGithubAppInstallationsByUserID(userID string, opts ...repository.QueryOption) ([]*models.GithubAppInstallation, *repository.PaginatedResult, repository.RepositoryError)

func (*GithubAppInstallationRepository) ReadGithubAppInstallationByID 

func (repo *GithubAppInstallationRepository) ReadGithubAppInstallationByID(gaiID string) (*models.GithubAppInstallation, repository.RepositoryError)

func (*GithubAppInstallationRepository) ReadGithubAppInstallationByInstallationAndAccountID 

func (repo *GithubAppInstallationRepository) ReadGithubAppInstallationByInstallationAndAccountID(installationID, accountID int64) (*models.GithubAppInstallation, repository.RepositoryError)

func (*GithubAppInstallationRepository) UpdateGithubAppInstallation 

func (repo *GithubAppInstallationRepository) UpdateGithubAppInstallation(
	gai *models.GithubAppInstallation,
) (*models.GithubAppInstallation, repository.RepositoryError)

type GithubAppOAuthRepository 

type GithubAppOAuthRepository struct {
	// contains filtered or unexported fields
}

GithubAppOAuthRepository uses gorm.DB for querying the database

func (*GithubAppOAuthRepository) CreateGithubAppOAuth 

func (repo *GithubAppOAuthRepository) CreateGithubAppOAuth(gao *models.GithubAppOAuth) (*models.GithubAppOAuth, repository.RepositoryError)

func (*GithubAppOAuthRepository) ReadGithubAppOAuthByGithubUserID 

func (repo *GithubAppOAuthRepository) ReadGithubAppOAuthByGithubUserID(githubUserID int64) (*models.GithubAppOAuth, repository.RepositoryError)

func (*GithubAppOAuthRepository) ReadGithubAppOAuthByUserID 

func (repo *GithubAppOAuthRepository) ReadGithubAppOAuthByUserID(userID string) (*models.GithubAppOAuth, repository.RepositoryError)

func (*GithubAppOAuthRepository) UpdateGithubAppOAuth 

func (repo *GithubAppOAuthRepository) UpdateGithubAppOAuth(
	gao *models.GithubAppOAuth,
) (*models.GithubAppOAuth, repository.RepositoryError)

type GithubPullRequestRepository 

type GithubPullRequestRepository struct {
	// contains filtered or unexported fields
}

GithubPullRequestRepository uses gorm.DB for querying the database

func (*GithubPullRequestRepository) CreateGithubPullRequest 

func (repo *GithubPullRequestRepository) CreateGithubPullRequest(gpr *models.GithubPullRequest) (*models.GithubPullRequest, repository.RepositoryError)

func (*GithubPullRequestRepository) CreateGithubPullRequestComment 

func (repo *GithubPullRequestRepository) CreateGithubPullRequestComment(gc *models.GithubPullRequestComment) (*models.GithubPullRequestComment, repository.RepositoryError)

func (*GithubPullRequestRepository) DeleteGithubPullRequest 

func (repo *GithubPullRequestRepository) DeleteGithubPullRequest(gpr *models.GithubPullRequest) (*models.GithubPullRequest, repository.RepositoryError)

func (*GithubPullRequestRepository) DeleteGithubPullRequestComment 

func (repo *GithubPullRequestRepository) DeleteGithubPullRequestComment(gc *models.GithubPullRequestComment) (*models.GithubPullRequestComment, repository.RepositoryError)

func (*GithubPullRequestRepository) ListGithubPullRequestsByHeadBranch 

func (repo *GithubPullRequestRepository) ListGithubPullRequestsByHeadBranch(teamID, repoOwner, repoName, branchName string) ([]*models.GithubPullRequest, repository.RepositoryError)

func (*GithubPullRequestRepository) ReadGithubPullRequestByGithubID 

func (repo *GithubPullRequestRepository) ReadGithubPullRequestByGithubID(teamID string, ghID int64) (*models.GithubPullRequest, repository.RepositoryError)

func (*GithubPullRequestRepository) ReadGithubPullRequestByID 

func (repo *GithubPullRequestRepository) ReadGithubPullRequestByID(teamID, id string) (*models.GithubPullRequest, repository.RepositoryError)

func (*GithubPullRequestRepository) ReadGithubPullRequestCommentByGithubID 

func (repo *GithubPullRequestRepository) ReadGithubPullRequestCommentByGithubID(moduleID string, ghID int64) (*models.GithubPullRequestComment, repository.RepositoryError)

func (*GithubPullRequestRepository) ReadGithubPullRequestCommentByID 

func (repo *GithubPullRequestRepository) ReadGithubPullRequestCommentByID(moduleID, id string) (*models.GithubPullRequestComment, repository.RepositoryError)

func (*GithubPullRequestRepository) UpdateGithubPullRequest 

func (repo *GithubPullRequestRepository) UpdateGithubPullRequest(
	gpr *models.GithubPullRequest,
) (*models.GithubPullRequest, repository.RepositoryError)

func (*GithubPullRequestRepository) UpdateGithubPullRequestComment 

func (repo *GithubPullRequestRepository) UpdateGithubPullRequestComment(
	gc *models.GithubPullRequestComment,
) (*models.GithubPullRequestComment, repository.RepositoryError)

type GithubWebhookRepository 

type GithubWebhookRepository struct {
	// contains filtered or unexported fields
}

GithubWebhookRepository uses gorm.DB for querying the database

func (*GithubWebhookRepository) AppendGithubAppInstallation 

func (repo *GithubWebhookRepository) AppendGithubAppInstallation(gw *models.GithubWebhook, gai *models.GithubAppInstallation) (*models.GithubWebhook, repository.RepositoryError)

func (*GithubWebhookRepository) CreateGithubWebhook 

func (repo *GithubWebhookRepository) CreateGithubWebhook(gw *models.GithubWebhook) (*models.GithubWebhook, repository.RepositoryError)

func (*GithubWebhookRepository) DeleteGithubWebhook 

func (repo *GithubWebhookRepository) DeleteGithubWebhook(gw *models.GithubWebhook) (*models.GithubWebhook, repository.RepositoryError)

func (*GithubWebhookRepository) ReadGithubWebhookByID 

func (repo *GithubWebhookRepository) ReadGithubWebhookByID(teamID, id string) (*models.GithubWebhook, repository.RepositoryError)

func (*GithubWebhookRepository) ReadGithubWebhookByTeamID 

func (repo *GithubWebhookRepository) ReadGithubWebhookByTeamID(teamID, repoOwner, repoName string) (*models.GithubWebhook, repository.RepositoryError)

func (*GithubWebhookRepository) RemoveGithubAppInstallation 

func (repo *GithubWebhookRepository) RemoveGithubAppInstallation(gw *models.GithubWebhook, gai *models.GithubAppInstallation) (*models.GithubWebhook, repository.RepositoryError)

func (*GithubWebhookRepository) UpdateGithubWebhook 

func (repo *GithubWebhookRepository) UpdateGithubWebhook(
	gw *models.GithubWebhook,
) (*models.GithubWebhook, repository.RepositoryError)

type GormRepository 

type GormRepository struct {
	// contains filtered or unexported fields
}

func (*GormRepository) GithubAppInstallation 

func (t *GormRepository) GithubAppInstallation() repository.GithubAppInstallationRepository

func (*GormRepository) GithubAppOAuth 

func (t *GormRepository) GithubAppOAuth() repository.GithubAppOAuthRepository

func (*GormRepository) GithubPullRequest 

func (t *GormRepository) GithubPullRequest() repository.GithubPullRequestRepository

func (*GormRepository) GithubWebhook 

func (t *GormRepository) GithubWebhook() repository.GithubWebhookRepository

func (*GormRepository) Module 

func (t *GormRepository) Module() repository.ModuleRepository

func (*GormRepository) ModuleEnvVars 

func (t *GormRepository) ModuleEnvVars() repository.ModuleEnvVarsRepository

func (*GormRepository) ModuleMonitor 

func (t *GormRepository) ModuleMonitor() repository.ModuleMonitorRepository

func (*GormRepository) ModuleRunQueue 

func (t *GormRepository) ModuleRunQueue() repository.ModuleRunQueueRepository

func (*GormRepository) ModuleValues 

func (t *GormRepository) ModuleValues() repository.ModuleValuesRepository

func (*GormRepository) Notification 

func (t *GormRepository) Notification() repository.NotificationRepository

func (*GormRepository) Org 

func (t *GormRepository) Org() repository.OrgRepository

func (*GormRepository) PasswordResetToken 

func (t *GormRepository) PasswordResetToken() repository.PasswordResetTokenRepository

func (*GormRepository) PersonalAccessToken 

func (t *GormRepository) PersonalAccessToken() repository.PersonalAccessTokenRepository

func (*GormRepository) Team 

func (t *GormRepository) Team() repository.TeamRepository

func (*GormRepository) User 

func (t *GormRepository) User() repository.UserRepository

func (*GormRepository) UserSession 

func (t *GormRepository) UserSession() repository.UserSessionRepository

func (*GormRepository) VerifyEmailToken 

func (t *GormRepository) VerifyEmailToken() repository.VerifyEmailTokenRepository

func (*GormRepository) WorkerToken 

func (t *GormRepository) WorkerToken() repository.WorkerTokenRepository

type ModuleEnvVarsRepository 

type ModuleEnvVarsRepository struct {
	// contains filtered or unexported fields
}

ModuleEnvVarsRepository uses gorm.DB for querying the database

func (*ModuleEnvVarsRepository) CreateModuleEnvVarsVersion 

func (repo *ModuleEnvVarsRepository) CreateModuleEnvVarsVersion(mev *models.ModuleEnvVarsVersion) (*models.ModuleEnvVarsVersion, repository.RepositoryError)

func (*ModuleEnvVarsRepository) DeleteModuleEnvVarsVersion 

func (repo *ModuleEnvVarsRepository) DeleteModuleEnvVarsVersion(mev *models.ModuleEnvVarsVersion) (*models.ModuleEnvVarsVersion, repository.RepositoryError)

func (*ModuleEnvVarsRepository) ListModuleValueVersionsByModuleID 

func (repo *ModuleEnvVarsRepository) ListModuleValueVersionsByModuleID(
	moduleID string,
	opts ...repository.QueryOption,
) ([]*models.ModuleEnvVarsVersion, *repository.PaginatedResult, repository.RepositoryError)

func (*ModuleEnvVarsRepository) ReadModuleEnvVarsVersionByID 

func (repo *ModuleEnvVarsRepository) ReadModuleEnvVarsVersionByID(moduleID, moduleEnvVarsVersionID string) (*models.ModuleEnvVarsVersion, repository.RepositoryError)

type ModuleMonitorRepository 

type ModuleMonitorRepository struct {
	// contains filtered or unexported fields
}

func (*ModuleMonitorRepository) CreateModuleMonitor 

func (repo *ModuleMonitorRepository) CreateModuleMonitor(monitor *models.ModuleMonitor) (*models.ModuleMonitor, repository.RepositoryError)

func (*ModuleMonitorRepository) CreateModuleMonitorResult 

func (repo *ModuleMonitorRepository) CreateModuleMonitorResult(monitor *models.ModuleMonitor, result *models.ModuleMonitorResult) (*models.ModuleMonitorResult, repository.RepositoryError)

func (*ModuleMonitorRepository) DeleteModuleMonitor 

func (repo *ModuleMonitorRepository) DeleteModuleMonitor(monitor *models.ModuleMonitor) (*models.ModuleMonitor, repository.RepositoryError)

func (*ModuleMonitorRepository) DeleteModuleMonitorResult 

func (repo *ModuleMonitorRepository) DeleteModuleMonitorResult(result *models.ModuleMonitorResult) (*models.ModuleMonitorResult, repository.RepositoryError)

func (*ModuleMonitorRepository) ListModuleMonitorResults 

func (repo *ModuleMonitorRepository) ListModuleMonitorResults(
	teamID string,
	filterOpts *repository.ListModuleMonitorResultsOpts,
	opts ...repository.QueryOption,
) ([]*models.ModuleMonitorResult, *repository.PaginatedResult, repository.RepositoryError)

func (*ModuleMonitorRepository) ListModuleMonitorsByTeamID 

func (repo *ModuleMonitorRepository) ListModuleMonitorsByTeamID(teamID string, opts ...repository.QueryOption) ([]*models.ModuleMonitor, *repository.PaginatedResult, repository.RepositoryError)

func (*ModuleMonitorRepository) ReadModuleMonitorByID 

func (repo *ModuleMonitorRepository) ReadModuleMonitorByID(teamID, moduleMonitorID string) (*models.ModuleMonitor, repository.RepositoryError)

func (*ModuleMonitorRepository) ReadModuleMonitorResultByID 

func (repo *ModuleMonitorRepository) ReadModuleMonitorResultByID(moduleID, monitorID, resultID string) (*models.ModuleMonitorResult, repository.RepositoryError)

func (*ModuleMonitorRepository) ReplaceModuleMonitorModules 

func (repo *ModuleMonitorRepository) ReplaceModuleMonitorModules(monitor *models.ModuleMonitor, modules []*models.Module) (*models.ModuleMonitor, repository.RepositoryError)

func (*ModuleMonitorRepository) UpdateModuleMonitor 

func (repo *ModuleMonitorRepository) UpdateModuleMonitor(monitor *models.ModuleMonitor) (*models.ModuleMonitor, repository.RepositoryError)

type ModuleRepository 

type ModuleRepository struct {
	// contains filtered or unexported fields
}

ModuleRepository uses gorm.DB for querying the database

func (*ModuleRepository) AppendModuleRunMonitorResult 

func (repo *ModuleRepository) AppendModuleRunMonitorResult(run *models.ModuleRun, result *models.ModuleMonitorResult) (*models.ModuleRun, repository.RepositoryError)

func (*ModuleRepository) AppendModuleRunMonitors 

func (repo *ModuleRepository) AppendModuleRunMonitors(run *models.ModuleRun, monitors []*models.ModuleMonitor) (*models.ModuleRun, repository.RepositoryError)

func (*ModuleRepository) CreateModule 

func (repo *ModuleRepository) CreateModule(mod *models.Module) (*models.Module, repository.RepositoryError)

CreateModule adds a new Module row to the Modules table in the database

func (*ModuleRepository) CreateModuleRun 

func (repo *ModuleRepository) CreateModuleRun(run *models.ModuleRun) (*models.ModuleRun, repository.RepositoryError)

func (*ModuleRepository) CreateModuleRunToken 

func (repo *ModuleRepository) CreateModuleRunToken(mrt *models.ModuleRunToken) (*models.ModuleRunToken, repository.RepositoryError)

func (*ModuleRepository) DeleteModule 

func (repo *ModuleRepository) DeleteModule(mod *models.Module) (*models.Module, repository.RepositoryError)

DeleteModule deletes a single mod by its unique id

func (*ModuleRepository) DeleteModuleRun 

func (repo *ModuleRepository) DeleteModuleRun(run *models.ModuleRun) (*models.ModuleRun, repository.RepositoryError)

func (*ModuleRepository) DeleteModuleRunToken 

func (repo *ModuleRepository) DeleteModuleRunToken(mrt *models.ModuleRunToken) (*models.ModuleRunToken, repository.RepositoryError)

func (*ModuleRepository) ListCompletedModuleRunsByLogLocation 

func (repo *ModuleRepository) ListCompletedModuleRunsByLogLocation(location string, opts ...repository.QueryOption) ([]*models.ModuleRun, *repository.PaginatedResult, repository.RepositoryError)

func (*ModuleRepository) ListModuleRunsByVCSSHA 

func (repo *ModuleRepository) ListModuleRunsByVCSSHA(moduleID, githubSHA string, kind *models.ModuleRunKind) ([]*models.ModuleRun, repository.RepositoryError)

func (*ModuleRepository) ListModulesByIDs 

func (repo *ModuleRepository) ListModulesByIDs(teamID string, ids []string, opts ...repository.QueryOption) ([]*models.Module, *repository.PaginatedResult, repository.RepositoryError)

func (*ModuleRepository) ListModulesByTeamID 

func (repo *ModuleRepository) ListModulesByTeamID(teamID string, opts ...repository.QueryOption) ([]*models.Module, *repository.PaginatedResult, repository.RepositoryError)

func (*ModuleRepository) ListRunsByModuleID 

func (repo *ModuleRepository) ListRunsByModuleID(moduleID string, filter *repository.ModuleRunsFilter, opts ...repository.QueryOption) ([]*models.ModuleRun, *repository.PaginatedResult, repository.RepositoryError)

func (*ModuleRepository) ListVCSRepositoryModules 

func (repo *ModuleRepository) ListVCSRepositoryModules(teamID, repoOwner, repoName string) ([]*models.Module, repository.RepositoryError)

func (*ModuleRepository) ReadModuleByID 

func (repo *ModuleRepository) ReadModuleByID(teamID, moduleID string) (*models.Module, repository.RepositoryError)

ReadModuleByID finds a single mod by its unique id

func (*ModuleRepository) ReadModuleRunByID 

func (repo *ModuleRepository) ReadModuleRunByID(moduleID, moduleRunID string) (*models.ModuleRun, repository.RepositoryError)

func (*ModuleRepository) ReadModuleRunToken 

func (repo *ModuleRepository) ReadModuleRunToken(userID, runID, tokenID string) (*models.ModuleRunToken, repository.RepositoryError)

func (*ModuleRepository) ReadModuleRunWithStateLock 

func (repo *ModuleRepository) ReadModuleRunWithStateLock(moduleID string) (*models.ModuleRun, repository.RepositoryError)

func (*ModuleRepository) UpdateModule 

func (repo *ModuleRepository) UpdateModule(mod *models.Module) (*models.Module, repository.RepositoryError)

UpdateModule updates an module in the database

func (*ModuleRepository) UpdateModuleDeploymentConfig 

func (repo *ModuleRepository) UpdateModuleDeploymentConfig(mod *models.Module, depl *models.ModuleDeploymentConfig) (*models.ModuleDeploymentConfig, repository.RepositoryError)

UpdateModuleDeploymentConfig updates a module's deployment config in the database

func (*ModuleRepository) UpdateModuleRun 

func (repo *ModuleRepository) UpdateModuleRun(run *models.ModuleRun) (*models.ModuleRun, repository.RepositoryError)

func (*ModuleRepository) UpdateModuleRunToken 

func (repo *ModuleRepository) UpdateModuleRunToken(mrt *models.ModuleRunToken) (*models.ModuleRunToken, repository.RepositoryError)

type ModuleRunQueueRepository 

type ModuleRunQueueRepository struct {
	// contains filtered or unexported fields
}

ModuleRunQueueRepository uses gorm.DB for querying the database

func (*ModuleRunQueueRepository) CreateModuleRunQueue 

func (repo *ModuleRunQueueRepository) CreateModuleRunQueue(mod *models.Module, queue *models.ModuleRunQueue) (*models.ModuleRunQueue, repository.RepositoryError)

func (*ModuleRunQueueRepository) CreateModuleRunQueueItem 

func (repo *ModuleRunQueueRepository) CreateModuleRunQueueItem(queue *models.ModuleRunQueue, item *models.ModuleRunQueueItem) (*models.ModuleRunQueueItem, repository.RepositoryError)

func (*ModuleRunQueueRepository) DeleteModuleRunQueueItem 

func (repo *ModuleRunQueueRepository) DeleteModuleRunQueueItem(item *models.ModuleRunQueueItem) (*models.ModuleRunQueueItem, repository.RepositoryError)

func (*ModuleRunQueueRepository) ListModulesWithQueueItems 

func (repo *ModuleRunQueueRepository) ListModulesWithQueueItems(opts ...repository.QueryOption) ([]*models.Module, *repository.PaginatedResult, repository.RepositoryError)

func (*ModuleRunQueueRepository) ReadModuleRunQueueByID 

func (repo *ModuleRunQueueRepository) ReadModuleRunQueueByID(moduleID, moduleRunQueueID, lockID string) (*models.ModuleRunQueue, repository.RepositoryError)

func (*ModuleRunQueueRepository) ReadModuleRunQueueItemByModuleRunID 

func (repo *ModuleRunQueueRepository) ReadModuleRunQueueItemByModuleRunID(moduleRunID string) (*models.ModuleRunQueueItem, repository.RepositoryError)

type ModuleValuesRepository 

type ModuleValuesRepository struct {
	// contains filtered or unexported fields
}

ModuleValuesRepository uses gorm.DB for querying the database

func (*ModuleValuesRepository) CreateModuleValues 

func (repo *ModuleValuesRepository) CreateModuleValues(mv *models.ModuleValues) (*models.ModuleValues, repository.RepositoryError)

func (*ModuleValuesRepository) CreateModuleValuesVersion 

func (repo *ModuleValuesRepository) CreateModuleValuesVersion(mvv *models.ModuleValuesVersion) (*models.ModuleValuesVersion, repository.RepositoryError)

func (*ModuleValuesRepository) DeleteModuleValues 

func (repo *ModuleValuesRepository) DeleteModuleValues(mv *models.ModuleValues) (*models.ModuleValues, repository.RepositoryError)

func (*ModuleValuesRepository) DeleteModuleValuesVersion 

func (repo *ModuleValuesRepository) DeleteModuleValuesVersion(mvv *models.ModuleValuesVersion) (*models.ModuleValuesVersion, repository.RepositoryError)

func (*ModuleValuesRepository) ListModuleValueVersionsByModuleID 

func (repo *ModuleValuesRepository) ListModuleValueVersionsByModuleID(
	moduleID string,
	opts ...repository.QueryOption,
) ([]*models.ModuleValuesVersion, *repository.PaginatedResult, repository.RepositoryError)

func (*ModuleValuesRepository) ReadModuleValuesByID 

func (repo *ModuleValuesRepository) ReadModuleValuesByID(moduleValuesID string) (*models.ModuleValues, repository.RepositoryError)

func (*ModuleValuesRepository) ReadModuleValuesByVersionID 

func (repo *ModuleValuesRepository) ReadModuleValuesByVersionID(moduleValuesVersionID string) (*models.ModuleValues, repository.RepositoryError)

func (*ModuleValuesRepository) ReadModuleValuesVersionByID 

func (repo *ModuleValuesRepository) ReadModuleValuesVersionByID(moduleID, moduleValuesVersionID string) (*models.ModuleValuesVersion, repository.RepositoryError)

ReadPersonalAccessToken reads a PAT by both the user ID and the token ID

type NotificationRepository 

type NotificationRepository struct {
	// contains filtered or unexported fields
}

NotificationRepository uses gorm.DB for querying the database

func (*NotificationRepository) AppendModuleRun 

func (repo *NotificationRepository) AppendModuleRun(notif *models.Notification, run *models.ModuleRun) (*models.Notification, repository.RepositoryError)

func (*NotificationRepository) AppendModuleRunMonitorResult 

func (repo *NotificationRepository) AppendModuleRunMonitorResult(notif *models.Notification, result *models.ModuleMonitorResult) (*models.Notification, repository.RepositoryError)

func (*NotificationRepository) CreateNotification 

func (repo *NotificationRepository) CreateNotification(notif *models.Notification) (*models.Notification, repository.RepositoryError)

func (*NotificationRepository) CreateNotificationInbox 

func (repo *NotificationRepository) CreateNotificationInbox(inbox *models.NotificationInbox) (*models.NotificationInbox, repository.RepositoryError)

func (*NotificationRepository) DeleteNotification 

func (repo *NotificationRepository) DeleteNotification(notif *models.Notification) (*models.Notification, repository.RepositoryError)

func (*NotificationRepository) ListNotifications 

func (repo *NotificationRepository) ListNotifications(
	filterOpts *repository.ListNotificationOpts,
	opts ...repository.QueryOption,
) ([]*models.Notification, *repository.PaginatedResult, repository.RepositoryError)

func (*NotificationRepository) ListNotificationsByTeamIDs 

func (repo *NotificationRepository) ListNotificationsByTeamIDs(
	teamIDs []string,
	filterOpts *repository.ListNotificationOpts,
	opts ...repository.QueryOption) ([]*models.Notification, *repository.PaginatedResult, repository.RepositoryError)

func (*NotificationRepository) ReadNotificationByID 

func (repo *NotificationRepository) ReadNotificationByID(teamID, id string) (*models.Notification, repository.RepositoryError)

func (*NotificationRepository) ReadNotificationByNotificationID 

func (repo *NotificationRepository) ReadNotificationByNotificationID(teamID, notificationID string, opts *repository.ReadNotificationOpts) (*models.Notification, repository.RepositoryError)

func (*NotificationRepository) ReadNotificationInboxByTeamID 

func (repo *NotificationRepository) ReadNotificationInboxByTeamID(teamID string) (*models.NotificationInbox, repository.RepositoryError)

func (*NotificationRepository) UpdateNotification 

func (repo *NotificationRepository) UpdateNotification(notif *models.Notification) (*models.Notification, repository.RepositoryError)

func (*NotificationRepository) UpdateNotificationInbox 

func (repo *NotificationRepository) UpdateNotificationInbox(inbox *models.NotificationInbox) (*models.NotificationInbox, repository.RepositoryError)

type OrgRepository 

type OrgRepository struct {
	// contains filtered or unexported fields
}

OrgRepository uses gorm.DB for querying the database

func (*OrgRepository) AppendOrgPolicyToOrgMember 

func (repo *OrgRepository) AppendOrgPolicyToOrgMember(orgMember *models.OrganizationMember, orgPolicy *models.OrganizationPolicy) (*models.OrganizationMember, repository.RepositoryError)

func (*OrgRepository) CreateOrg 

func (repo *OrgRepository) CreateOrg(org *models.Organization) (*models.Organization, repository.RepositoryError)

CreateOrg adds a new Org row to the Orgs table in the database

func (*OrgRepository) CreateOrgMember 

func (repo *OrgRepository) CreateOrgMember(org *models.Organization, orgMember *models.OrganizationMember) (*models.OrganizationMember, repository.RepositoryError)

func (*OrgRepository) CreateOrgPolicy 

func (repo *OrgRepository) CreateOrgPolicy(org *models.Organization, orgPolicy *models.OrganizationPolicy) (*models.OrganizationPolicy, repository.RepositoryError)

func (*OrgRepository) DeleteOrg 

func (repo *OrgRepository) DeleteOrg(org *models.Organization) (*models.Organization, repository.RepositoryError)

DeleteOrg deletes a single org by its unique id

func (*OrgRepository) DeleteOrgMember 

func (repo *OrgRepository) DeleteOrgMember(orgMember *models.OrganizationMember) (*models.OrganizationMember, repository.RepositoryError)

func (*OrgRepository) ListOrgMembersByOrgID 

func (repo *OrgRepository) ListOrgMembersByOrgID(orgID string, isSARunner bool, opts ...repository.QueryOption) ([]*models.OrganizationMember, *repository.PaginatedResult, repository.RepositoryError)

func (*OrgRepository) ListOrgPoliciesByOrgID 

func (repo *OrgRepository) ListOrgPoliciesByOrgID(orgID string, opts ...repository.QueryOption) ([]*models.OrganizationPolicy, *repository.PaginatedResult, repository.RepositoryError)

func (*OrgRepository) ListOrgsByUserID 

func (repo *OrgRepository) ListOrgsByUserID(userID string, opts ...repository.QueryOption) ([]*models.Organization, *repository.PaginatedResult, repository.RepositoryError)

func (*OrgRepository) ReadOrgByID 

func (repo *OrgRepository) ReadOrgByID(id string) (*models.Organization, repository.RepositoryError)

ReadOrgByID finds a single org by its unique id

func (*OrgRepository) ReadOrgInviteByID 

func (repo *OrgRepository) ReadOrgInviteByID(inviteID string) (*models.OrganizationInviteLink, repository.RepositoryError)

func (*OrgRepository) ReadOrgMemberByID 

func (repo *OrgRepository) ReadOrgMemberByID(orgID, memberID string, isSARunner bool) (*models.OrganizationMember, repository.RepositoryError)

func (*OrgRepository) ReadOrgMemberByUserID 

func (repo *OrgRepository) ReadOrgMemberByUserID(orgID, userID string, isSARunner bool) (*models.OrganizationMember, repository.RepositoryError)

func (*OrgRepository) ReadOrgMemberByUserOrInviteeEmail 

func (repo *OrgRepository) ReadOrgMemberByUserOrInviteeEmail(orgID, email string, isSARunner bool) (*models.OrganizationMember, repository.RepositoryError)

func (*OrgRepository) ReadPolicyByID 

func (repo *OrgRepository) ReadPolicyByID(orgID, policyID string) (*models.OrganizationPolicy, repository.RepositoryError)

func (*OrgRepository) ReadPresetPolicyByName 

func (repo *OrgRepository) ReadPresetPolicyByName(orgID string, presetName models.PresetPolicyName) (*models.OrganizationPolicy, repository.RepositoryError)

func (*OrgRepository) RemoveOrgPolicyFromOrgMember 

func (repo *OrgRepository) RemoveOrgPolicyFromOrgMember(orgMember *models.OrganizationMember, orgPolicy *models.OrganizationPolicy) (*models.OrganizationMember, repository.RepositoryError)

func (*OrgRepository) ReplaceOrgPoliciesForOrgMember 

func (repo *OrgRepository) ReplaceOrgPoliciesForOrgMember(orgMember *models.OrganizationMember, policies []*models.OrganizationPolicy) (*models.OrganizationMember, repository.RepositoryError)

func (*OrgRepository) UpdateOrg 

func (repo *OrgRepository) UpdateOrg(org *models.Organization) (*models.Organization, repository.RepositoryError)

UpdateOrg updates an organization in the database

func (*OrgRepository) UpdateOrgInvite 

func (repo *OrgRepository) UpdateOrgInvite(orgInvite *models.OrganizationInviteLink) (*models.OrganizationInviteLink, repository.RepositoryError)

func (*OrgRepository) UpdateOrgMember 

func (repo *OrgRepository) UpdateOrgMember(orgMember *models.OrganizationMember) (*models.OrganizationMember, repository.RepositoryError)

type PasswordResetTokenRepository 

type PasswordResetTokenRepository struct {
	// contains filtered or unexported fields
}

PasswordResetTokenRepository uses gorm.DB for querying the database

func (*PasswordResetTokenRepository) CreatePasswordResetToken 

func (repo *PasswordResetTokenRepository) CreatePasswordResetToken(prt *models.PasswordResetToken) (*models.PasswordResetToken, repository.RepositoryError)

CreatePasswordResetToken creates a new PRT in the database

func (*PasswordResetTokenRepository) ReadPasswordResetTokenByEmailAndTokenID 

func (repo *PasswordResetTokenRepository) ReadPasswordResetTokenByEmailAndTokenID(email, tokID string) (*models.PasswordResetToken, repository.RepositoryError)

func (*PasswordResetTokenRepository) UpdatePasswordResetToken 

func (repo *PasswordResetTokenRepository) UpdatePasswordResetToken(prt *models.PasswordResetToken) (*models.PasswordResetToken, repository.RepositoryError)

type PersonalAccessTokenRepository 

type PersonalAccessTokenRepository struct {
	// contains filtered or unexported fields
}

PersonalAccessTokenRepository uses gorm.DB for querying the database

func (*PersonalAccessTokenRepository) CreatePersonalAccessToken 

func (repo *PersonalAccessTokenRepository) CreatePersonalAccessToken(pat *models.PersonalAccessToken) (*models.PersonalAccessToken, repository.RepositoryError)

CreateUser adds a new User row to the Users table in the database

func (*PersonalAccessTokenRepository) DeletePersonalAccessToken 

func (repo *PersonalAccessTokenRepository) DeletePersonalAccessToken(
	pat *models.PersonalAccessToken,
) (*models.PersonalAccessToken, repository.RepositoryError)

func (*PersonalAccessTokenRepository) ListPersonalAccessTokensByUserID 

func (repo *PersonalAccessTokenRepository) ListPersonalAccessTokensByUserID(
	userID string,
	opts ...repository.QueryOption,
) ([]*models.PersonalAccessToken, *repository.PaginatedResult, repository.RepositoryError)

func (*PersonalAccessTokenRepository) ReadPersonalAccessToken 

func (repo *PersonalAccessTokenRepository) ReadPersonalAccessToken(userID, tokenID string) (*models.PersonalAccessToken, repository.RepositoryError)

ReadPersonalAccessToken reads a PAT by both the user ID and the token ID

func (*PersonalAccessTokenRepository) ReadPersonalAccessTokenByDisplayName 

func (repo *PersonalAccessTokenRepository) ReadPersonalAccessTokenByDisplayName(userID, displayName string) (
	*models.PersonalAccessToken,
	repository.RepositoryError,
)

func (*PersonalAccessTokenRepository) UpdatePersonalAccessToken 

func (repo *PersonalAccessTokenRepository) UpdatePersonalAccessToken(
	pat *models.PersonalAccessToken,
) (*models.PersonalAccessToken, repository.RepositoryError)

type TeamRepository 

type TeamRepository struct {
	// contains filtered or unexported fields
}

TeamRepository uses gorm.DB for querying the database

func (*TeamRepository) AppendTeamPolicyToTeamMember 

func (repo *TeamRepository) AppendTeamPolicyToTeamMember(teamMember *models.TeamMember, teamPolicy *models.TeamPolicy) (*models.TeamMember, repository.RepositoryError)

func (*TeamRepository) CreateTeam 

func (repo *TeamRepository) CreateTeam(team *models.Team) (*models.Team, repository.RepositoryError)

CreateOrg adds a new Org row to the Orgs table in the database

func (*TeamRepository) CreateTeamMember 

func (repo *TeamRepository) CreateTeamMember(team *models.Team, teamMember *models.TeamMember) (*models.TeamMember, repository.RepositoryError)

func (*TeamRepository) CreateTeamPolicy 

func (repo *TeamRepository) CreateTeamPolicy(team *models.Team, teamPolicy *models.TeamPolicy) (*models.TeamPolicy, repository.RepositoryError)

func (*TeamRepository) DeleteTeam 

func (repo *TeamRepository) DeleteTeam(team *models.Team) (*models.Team, repository.RepositoryError)

DeleteTeam soft-deletes a single team by its unique id

func (*TeamRepository) DeleteTeamMember 

func (repo *TeamRepository) DeleteTeamMember(teamMember *models.TeamMember) (*models.TeamMember, repository.RepositoryError)

func (*TeamRepository) ListTeamMembersByTeamID 

func (repo *TeamRepository) ListTeamMembersByTeamID(teamID string, isSARunner bool, opts ...repository.QueryOption) ([]*models.TeamMember, *repository.PaginatedResult, repository.RepositoryError)

func (*TeamRepository) ListTeamPoliciesByTeamID 

func (repo *TeamRepository) ListTeamPoliciesByTeamID(orgID string, opts ...repository.QueryOption) ([]*models.TeamPolicy, *repository.PaginatedResult, repository.RepositoryError)

func (*TeamRepository) ListTeamsByOrgID 

func (repo *TeamRepository) ListTeamsByOrgID(orgID string, opts ...repository.QueryOption) ([]*models.Team, *repository.PaginatedResult, repository.RepositoryError)

func (*TeamRepository) ListTeamsByUserID 

func (repo *TeamRepository) ListTeamsByUserID(userID string, orgID string, opts ...repository.QueryOption) ([]*models.Team, *repository.PaginatedResult, repository.RepositoryError)

func (*TeamRepository) ReadPolicyByID 

func (repo *TeamRepository) ReadPolicyByID(orgID, policyID string) (*models.TeamPolicy, repository.RepositoryError)

func (*TeamRepository) ReadPresetTeamPolicyByName 

func (repo *TeamRepository) ReadPresetTeamPolicyByName(orgID string, presetName models.PresetTeamPolicyName) (*models.TeamPolicy, repository.RepositoryError)

func (*TeamRepository) ReadTeamByID 

func (repo *TeamRepository) ReadTeamByID(id string) (*models.Team, repository.RepositoryError)

ReadTeamByID finds a single team by its unique id

func (*TeamRepository) ReadTeamMemberByID 

func (repo *TeamRepository) ReadTeamMemberByID(teamID, memberID string, isSARunner bool) (*models.TeamMember, repository.RepositoryError)

func (*TeamRepository) ReadTeamMemberByOrgMemberID 

func (repo *TeamRepository) ReadTeamMemberByOrgMemberID(teamID, orgMemberID string, isSARunner bool) (*models.TeamMember, repository.RepositoryError)

func (*TeamRepository) RemoveTeamPolicyFromTeamMember 

func (repo *TeamRepository) RemoveTeamPolicyFromTeamMember(teamMember *models.TeamMember, teamPolicy *models.TeamPolicy) (*models.TeamMember, repository.RepositoryError)

func (*TeamRepository) ReplaceTeamPoliciesForTeamMember 

func (repo *TeamRepository) ReplaceTeamPoliciesForTeamMember(teamMember *models.TeamMember, policies []*models.TeamPolicy) (*models.TeamMember, repository.RepositoryError)

func (*TeamRepository) UpdateTeam 

func (repo *TeamRepository) UpdateTeam(team *models.Team) (*models.Team, repository.RepositoryError)

UpdateTeam updates a team in the database

func (*TeamRepository) UpdateTeamMember 

func (repo *TeamRepository) UpdateTeamMember(teamMember *models.TeamMember) (*models.TeamMember, repository.RepositoryError)

type UserRepository 

type UserRepository struct {
	// contains filtered or unexported fields
}

UserRepository uses gorm.DB for querying the database

func (*UserRepository) CreateUser 

func (repo *UserRepository) CreateUser(user *models.User) (*models.User, repository.RepositoryError)

CreateUser adds a new User row to the Users table in the database

func (*UserRepository) DeleteUser 

func (repo *UserRepository) DeleteUser(user *models.User) (*models.User, repository.RepositoryError)

DeleteUser deletes a single user using their unique id

func (*UserRepository) ReadUserByEmail 

func (repo *UserRepository) ReadUserByEmail(email string) (*models.User, repository.RepositoryError)

ReadUserByEmail finds a single user based on their unique email

func (*UserRepository) ReadUserByID 

func (repo *UserRepository) ReadUserByID(id string) (*models.User, repository.RepositoryError)

ReadUserByID finds a single user based on their unique id

func (*UserRepository) UpdateUser 

func (repo *UserRepository) UpdateUser(user *models.User) (*models.User, repository.RepositoryError)

UpdateUser updates a user in the database

type UserSessionRepository 

type UserSessionRepository struct {
	// contains filtered or unexported fields
}

func (*UserSessionRepository) CreateUserSession 

func (s *UserSessionRepository) CreateUserSession(session *models.UserSession) (*models.UserSession, repository.RepositoryError)

func (*UserSessionRepository) DeleteUserSession 

func (s *UserSessionRepository) DeleteUserSession(session *models.UserSession) (*models.UserSession, repository.RepositoryError)

func (*UserSessionRepository) ReadUserSessionByKey 

func (s *UserSessionRepository) ReadUserSessionByKey(sessionKey string) (*models.UserSession, repository.RepositoryError)

func (*UserSessionRepository) UpdateUserSession 

func (s *UserSessionRepository) UpdateUserSession(session *models.UserSession) (*models.UserSession, repository.RepositoryError)

type VerifyEmailTokenRepository 

type VerifyEmailTokenRepository struct {
	// contains filtered or unexported fields
}

VerifyEmailTokenRepository uses gorm.DB for querying the database

func (*VerifyEmailTokenRepository) CreateVerifyEmailToken 

func (repo *VerifyEmailTokenRepository) CreateVerifyEmailToken(vet *models.VerifyEmailToken) (*models.VerifyEmailToken, repository.RepositoryError)

CreateVerifyEmailToken creates a new PRT in the database

func (*VerifyEmailTokenRepository) ReadVerifyEmailTokenByEmailAndTokenID 

func (repo *VerifyEmailTokenRepository) ReadVerifyEmailTokenByEmailAndTokenID(email, tokID string) (*models.VerifyEmailToken, repository.RepositoryError)

func (*VerifyEmailTokenRepository) UpdateVerifyEmailToken 

func (repo *VerifyEmailTokenRepository) UpdateVerifyEmailToken(vet *models.VerifyEmailToken) (*models.VerifyEmailToken, repository.RepositoryError)

type WorkerTokenRepository 

type WorkerTokenRepository struct {
	// contains filtered or unexported fields
}

WorkerTokenRepository uses gorm.DB for querying the database

func (*WorkerTokenRepository) CreateWorkerToken 

func (repo *WorkerTokenRepository) CreateWorkerToken(wt *models.WorkerToken) (*models.WorkerToken, repository.RepositoryError)

func (*WorkerTokenRepository) DeleteWorkerToken 

func (repo *WorkerTokenRepository) DeleteWorkerToken(wt *models.WorkerToken) (*models.WorkerToken, repository.RepositoryError)

func (*WorkerTokenRepository) ReadWorkerToken 

func (repo *WorkerTokenRepository) ReadWorkerToken(teamID, tokenID string) (*models.WorkerToken, repository.RepositoryError)

func (*WorkerTokenRepository) UpdateWorkerToken 

func (repo *WorkerTokenRepository) UpdateWorkerToken(wt *models.WorkerToken) (*models.WorkerToken, repository.RepositoryError)

Source Files

View all Source files

Directories

Path Synopsis
go:build test
 go:build test

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.