repository

package
v0.0.0-...-d535874 Latest Latest
Warning

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

 Go to latest Published: Apr 26, 2024 License: Apache-2.0 Imports: 20 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func Map 

func Map(src interface{}, dst interface{}) error

Types

type AppGroupRepository 

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

func (*AppGroupRepository) Create 

func (r *AppGroupRepository) Create(ctx context.Context, dto model.AppGroup) (appGroupId domain.AppGroupId, err error)

func (*AppGroupRepository) Delete 

func (r *AppGroupRepository) Delete(ctx context.Context, id domain.AppGroupId) error

func (*AppGroupRepository) Fetch 

func (r *AppGroupRepository) Fetch(ctx context.Context, clusterId domain.ClusterId, pg *pagination.Pagination) (out []model.AppGroup, err error)

Logics

func (*AppGroupRepository) Get 

func (r *AppGroupRepository) Get(ctx context.Context, id domain.AppGroupId) (out model.AppGroup, err error)

func (*AppGroupRepository) GetApplications 

func (r *AppGroupRepository) GetApplications(ctx context.Context, id domain.AppGroupId, applicationType domain.ApplicationType) (out []model.Application, err error)

func (*AppGroupRepository) InitWorkflow 

func (r *AppGroupRepository) InitWorkflow(ctx context.Context, appGroupId domain.AppGroupId, workflowId string, status domain.AppGroupStatus) error

func (*AppGroupRepository) InitWorkflowDescription 

func (r *AppGroupRepository) InitWorkflowDescription(ctx context.Context, clusterId domain.ClusterId) error

func (*AppGroupRepository) Update 

func (r *AppGroupRepository) Update(ctx context.Context, dto model.AppGroup) (err error)

func (*AppGroupRepository) UpsertApplication 

func (r *AppGroupRepository) UpsertApplication(ctx context.Context, dto model.Application) error

type AppServeAppRepository 

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

func (*AppServeAppRepository) CreateAppServeApp 

func (r *AppServeAppRepository) CreateAppServeApp(ctx context.Context, app *model.AppServeApp) (appId string, taskId string, err error)

func (*AppServeAppRepository) CreateTask 

func (r *AppServeAppRepository) CreateTask(ctx context.Context, task *model.AppServeAppTask) (string, error)

Update creates new appServeApp task for existing appServeApp.

func (*AppServeAppRepository) GetAppServeAppById 

func (r *AppServeAppRepository) GetAppServeAppById(ctx context.Context, appId string) (*model.AppServeApp, error)

//////////////////////////////////////////////////////////////////////////////////////// TODO: this API will'be deprecated soon once the new task-related API's are verified. Until then, this is available (except for stage info) just for backward compatibility. ////////////////////////////////////////////////////////////////////////////////////////

func (*AppServeAppRepository) GetAppServeAppLatestTask 

func (r *AppServeAppRepository) GetAppServeAppLatestTask(ctx context.Context, appId string) (*model.AppServeAppTask, error)

func (*AppServeAppRepository) GetAppServeAppTaskById 

func (r *AppServeAppRepository) GetAppServeAppTaskById(ctx context.Context, taskId string) (*model.AppServeAppTask, *model.AppServeApp, error)

Return single task info along with its parent app info

func (*AppServeAppRepository) GetAppServeAppTasksByAppId 

func (r *AppServeAppRepository) GetAppServeAppTasksByAppId(ctx context.Context, appId string, pg *pagination.Pagination) (tasks []model.AppServeAppTask, err error)

func (*AppServeAppRepository) GetAppServeApps 

func (r *AppServeAppRepository) GetAppServeApps(ctx context.Context, organizationId string, projectId string, showAll bool, pg *pagination.Pagination) (apps []model.AppServeApp, err error)

func (*AppServeAppRepository) GetNumOfAppsOnStack 

func (r *AppServeAppRepository) GetNumOfAppsOnStack(ctx context.Context, organizationId string, clusterId string) (int64, error)

func (*AppServeAppRepository) GetTaskCountById 

func (r *AppServeAppRepository) GetTaskCountById(ctx context.Context, appId string) (int64, error)

func (*AppServeAppRepository) IsAppServeAppExist 

func (r *AppServeAppRepository) IsAppServeAppExist(ctx context.Context, appId string) (int64, error)

func (*AppServeAppRepository) IsAppServeAppNameExist 

func (r *AppServeAppRepository) IsAppServeAppNameExist(ctx context.Context, orgId string, appName string) (int64, error)

func (*AppServeAppRepository) UpdateEndpoint 

func (r *AppServeAppRepository) UpdateEndpoint(ctx context.Context, appId string, taskId string, endpoint string, previewEndpoint string, helmRevision int32) error

func (*AppServeAppRepository) UpdateStatus 

func (r *AppServeAppRepository) UpdateStatus(ctx context.Context, appId string, taskId string, status string, output string) error

type AuditRepository 

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

func (*AuditRepository) Create 

func (r *AuditRepository) Create(ctx context.Context, dto model.Audit) (auditId uuid.UUID, err error)

func (*AuditRepository) Delete 

func (r *AuditRepository) Delete(ctx context.Context, auditId uuid.UUID) (err error)

func (*AuditRepository) Fetch 

func (r *AuditRepository) Fetch(ctx context.Context, pg *pagination.Pagination) (out []model.Audit, err error)

func (*AuditRepository) Get 

func (r *AuditRepository) Get(ctx context.Context, auditId uuid.UUID) (out model.Audit, err error)

Logics

type AuthRepository 

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

func (*AuthRepository) CreateEmailCode 

func (r *AuthRepository) CreateEmailCode(ctx context.Context, userId uuid.UUID, code string) error

func (*AuthRepository) DeleteEmailCode 

func (r *AuthRepository) DeleteEmailCode(ctx context.Context, userId uuid.UUID) error

func (*AuthRepository) GetEmailCode 

func (r *AuthRepository) GetEmailCode(ctx context.Context, userId uuid.UUID) (model.CacheEmailCode, error)

func (*AuthRepository) GetExpiredTimeOnToken 

func (r *AuthRepository) GetExpiredTimeOnToken(ctx context.Context, organizationId string, userId string) (*model.ExpiredTokenTime, error)

func (*AuthRepository) UpdateEmailCode 

func (r *AuthRepository) UpdateEmailCode(ctx context.Context, userId uuid.UUID, code string) error

func (*AuthRepository) UpdateExpiredTimeOnToken 

func (r *AuthRepository) UpdateExpiredTimeOnToken(ctx context.Context, organizationId string, userId string) error

type CloudAccountRepository 

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

func (*CloudAccountRepository) Create 

func (r *CloudAccountRepository) Create(ctx context.Context, dto model.CloudAccount) (cloudAccountId uuid.UUID, err error)

func (*CloudAccountRepository) Delete 

func (r *CloudAccountRepository) Delete(ctx context.Context, cloudAccountId uuid.UUID) (err error)

func (*CloudAccountRepository) Fetch 

func (r *CloudAccountRepository) Fetch(ctx context.Context, organizationId string, pg *pagination.Pagination) (out []model.CloudAccount, err error)

func (*CloudAccountRepository) Get 

func (r *CloudAccountRepository) Get(ctx context.Context, cloudAccountId uuid.UUID) (out model.CloudAccount, err error)

Logics

func (*CloudAccountRepository) GetByAwsAccountId 

func (r *CloudAccountRepository) GetByAwsAccountId(ctx context.Context, awsAccountId string) (out model.CloudAccount, err error)

func (*CloudAccountRepository) GetByName 

func (r *CloudAccountRepository) GetByName(ctx context.Context, organizationId string, name string) (out model.CloudAccount, err error)

func (*CloudAccountRepository) InitWorkflow 

func (r *CloudAccountRepository) InitWorkflow(ctx context.Context, cloudAccountId uuid.UUID, workflowId string, status domain.CloudAccountStatus) error

func (*CloudAccountRepository) Update 

func (r *CloudAccountRepository) Update(ctx context.Context, dto model.CloudAccount) (err error)

type ClusterRepository 

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

func (*ClusterRepository) Create 

func (r *ClusterRepository) Create(ctx context.Context, dto model.Cluster) (clusterId domain.ClusterId, err error)

func (*ClusterRepository) Delete 

func (r *ClusterRepository) Delete(ctx context.Context, clusterId domain.ClusterId) error

func (*ClusterRepository) DeleteFavorite 

func (r *ClusterRepository) DeleteFavorite(ctx context.Context, clusterId domain.ClusterId, userId uuid.UUID) error

func (*ClusterRepository) Fetch 

func (r *ClusterRepository) Fetch(ctx context.Context, pg *pagination.Pagination) (out []model.Cluster, err error)

func (*ClusterRepository) FetchByCloudAccountId 

func (r *ClusterRepository) FetchByCloudAccountId(ctx context.Context, cloudAccountId uuid.UUID, pg *pagination.Pagination) (out []model.Cluster, err error)

func (*ClusterRepository) FetchByOrganizationId 

func (r *ClusterRepository) FetchByOrganizationId(ctx context.Context, organizationId string, userId uuid.UUID, pg *pagination.Pagination) (out []model.Cluster, err error)

func (*ClusterRepository) Get 

func (r *ClusterRepository) Get(ctx context.Context, id domain.ClusterId) (out model.Cluster, err error)

func (*ClusterRepository) GetByName 

func (r *ClusterRepository) GetByName(ctx context.Context, organizationId string, name string) (out model.Cluster, err error)

func (*ClusterRepository) InitWorkflow 

func (r *ClusterRepository) InitWorkflow(ctx context.Context, clusterId domain.ClusterId, workflowId string, status domain.ClusterStatus) error

func (*ClusterRepository) InitWorkflowDescription 

func (r *ClusterRepository) InitWorkflowDescription(ctx context.Context, clusterId domain.ClusterId) error

func (*ClusterRepository) SetFavorite 

func (r *ClusterRepository) SetFavorite(ctx context.Context, clusterId domain.ClusterId, userId uuid.UUID) error

func (*ClusterRepository) Update 

func (r *ClusterRepository) Update(ctx context.Context, dto model.Cluster) error

func (*ClusterRepository) WithTrx 

func (r *ClusterRepository) WithTrx(trxHandle *gorm.DB) IClusterRepository

Logics

type ConverterMap 

type ConverterMap map[compositeKey]func(interface{}) (interface{}, error)

type DashboardRepository 

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

func (DashboardRepository) CreateDashboard 

func (dr DashboardRepository) CreateDashboard(ctx context.Context, d *model.Dashboard) (string, error)

func (DashboardRepository) GetDashboardById 

func (dr DashboardRepository) GetDashboardById(ctx context.Context, organizationId string, dashboardId string) (d *model.Dashboard, err error)

func (DashboardRepository) GetDashboardByUserId 

func (dr DashboardRepository) GetDashboardByUserId(ctx context.Context, organizationId string, userId string, dashboardKey string) (d *model.Dashboard, err error)

func (DashboardRepository) UpdateDashboard 

func (dr DashboardRepository) UpdateDashboard(ctx context.Context, d *model.Dashboard) error

type EndpointRepository 

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

func NewEndpointRepository 

func NewEndpointRepository(db *gorm.DB) *EndpointRepository

func (*EndpointRepository) Create 

func (e *EndpointRepository) Create(ctx context.Context, endpoint *model.Endpoint) error

func (*EndpointRepository) Get 

func (e *EndpointRepository) Get(ctx context.Context, id uint) (*model.Endpoint, error)

func (*EndpointRepository) List 

func (e *EndpointRepository) List(ctx context.Context, pg *pagination.Pagination) ([]*model.Endpoint, error)

type FilterFunc 

type FilterFunc func(user *gorm.DB) *gorm.DB

type IAppGroupRepository 

type IAppGroupRepository interface {
	Fetch(ctx context.Context, clusterId domain.ClusterId, pg *pagination.Pagination) (res []model.AppGroup, err error)
	Get(ctx context.Context, id domain.AppGroupId) (model.AppGroup, error)
	Create(ctx context.Context, dto model.AppGroup) (id domain.AppGroupId, err error)
	Update(ctx context.Context, dto model.AppGroup) (err error)
	Delete(ctx context.Context, id domain.AppGroupId) error
	GetApplications(ctx context.Context, id domain.AppGroupId, applicationType domain.ApplicationType) (applications []model.Application, err error)
	UpsertApplication(ctx context.Context, dto model.Application) error
	InitWorkflow(ctx context.Context, appGroupId domain.AppGroupId, workflowId string, status domain.AppGroupStatus) error
	InitWorkflowDescription(ctx context.Context, clusterId domain.ClusterId) error
}

Interfaces

func NewAppGroupRepository 

func NewAppGroupRepository(db *gorm.DB) IAppGroupRepository

type IAppServeAppRepository 

type IAppServeAppRepository interface {
	CreateAppServeApp(ctx context.Context, app *model.AppServeApp) (appId string, taskId string, err error)
	GetAppServeApps(ctx context.Context, organizationId string, projectId string, showAll bool, pg *pagination.Pagination) ([]model.AppServeApp, error)
	GetAppServeAppById(ctx context.Context, appId string) (*model.AppServeApp, error)

	GetAppServeAppTasksByAppId(ctx context.Context, appId string, pg *pagination.Pagination) ([]model.AppServeAppTask, error)
	GetAppServeAppTaskById(ctx context.Context, taskId string) (*model.AppServeAppTask, *model.AppServeApp, error)

	GetAppServeAppLatestTask(ctx context.Context, appId string) (*model.AppServeAppTask, error)
	GetNumOfAppsOnStack(ctx context.Context, organizationId string, clusterId string) (int64, error)

	IsAppServeAppExist(ctx context.Context, appId string) (int64, error)
	IsAppServeAppNameExist(ctx context.Context, orgId string, appName string) (int64, error)
	CreateTask(ctx context.Context, task *model.AppServeAppTask) (taskId string, err error)
	UpdateStatus(ctx context.Context, appId string, taskId string, status string, output string) error
	UpdateEndpoint(ctx context.Context, appId string, taskId string, endpoint string, previewEndpoint string, helmRevision int32) error
	GetTaskCountById(ctx context.Context, appId string) (int64, error)
}

func NewAppServeAppRepository 

func NewAppServeAppRepository(db *gorm.DB) IAppServeAppRepository

type IAuditRepository 

type IAuditRepository interface {
	Get(ctx context.Context, auditId uuid.UUID) (model.Audit, error)
	Fetch(ctx context.Context, pg *pagination.Pagination) ([]model.Audit, error)
	Create(ctx context.Context, dto model.Audit) (auditId uuid.UUID, err error)
	Delete(ctx context.Context, auditId uuid.UUID) (err error)
}

Interfaces

func NewAuditRepository 

func NewAuditRepository(db *gorm.DB) IAuditRepository

type IAuthRepository 

type IAuthRepository interface {
	CreateEmailCode(ctx context.Context, userId uuid.UUID, code string) error
	GetEmailCode(ctx context.Context, userId uuid.UUID) (model.CacheEmailCode, error)
	UpdateEmailCode(ctx context.Context, userId uuid.UUID, code string) error
	DeleteEmailCode(ctx context.Context, userId uuid.UUID) error
	GetExpiredTimeOnToken(ctx context.Context, organizationId string, userId string) (*model.ExpiredTokenTime, error)
	UpdateExpiredTimeOnToken(ctx context.Context, organizationId string, userId string) error
}

func NewAuthRepository 

func NewAuthRepository(db *gorm.DB) IAuthRepository

type ICloudAccountRepository 

type ICloudAccountRepository interface {
	Get(ctx context.Context, cloudAccountId uuid.UUID) (model.CloudAccount, error)
	GetByName(ctx context.Context, organizationId string, name string) (model.CloudAccount, error)
	GetByAwsAccountId(ctx context.Context, awsAccountId string) (model.CloudAccount, error)
	Fetch(ctx context.Context, organizationId string, pg *pagination.Pagination) ([]model.CloudAccount, error)
	Create(ctx context.Context, dto model.CloudAccount) (cloudAccountId uuid.UUID, err error)
	Update(ctx context.Context, dto model.CloudAccount) (err error)
	Delete(ctx context.Context, cloudAccountId uuid.UUID) (err error)
	InitWorkflow(ctx context.Context, cloudAccountId uuid.UUID, workflowId string, status domain.CloudAccountStatus) (err error)
}

Interfaces

func NewCloudAccountRepository 

func NewCloudAccountRepository(db *gorm.DB) ICloudAccountRepository

type IClusterRepository 

type IClusterRepository interface {
	WithTrx(*gorm.DB) IClusterRepository
	Fetch(ctx context.Context, pg *pagination.Pagination) (res []model.Cluster, err error)
	FetchByCloudAccountId(ctx context.Context, cloudAccountId uuid.UUID, pg *pagination.Pagination) (res []model.Cluster, err error)
	FetchByOrganizationId(ctx context.Context, organizationId string, userId uuid.UUID, pg *pagination.Pagination) (res []model.Cluster, err error)
	Get(ctx context.Context, id domain.ClusterId) (model.Cluster, error)
	GetByName(ctx context.Context, organizationId string, name string) (model.Cluster, error)
	Create(ctx context.Context, dto model.Cluster) (clusterId domain.ClusterId, err error)
	Update(ctx context.Context, dto model.Cluster) (err error)
	Delete(ctx context.Context, id domain.ClusterId) error

	InitWorkflow(ctx context.Context, clusterId domain.ClusterId, workflowId string, status domain.ClusterStatus) error
	InitWorkflowDescription(ctx context.Context, clusterId domain.ClusterId) error

	SetFavorite(ctx context.Context, clusterId domain.ClusterId, userId uuid.UUID) error
	DeleteFavorite(ctx context.Context, clusterId domain.ClusterId, userId uuid.UUID) error
}

Interfaces

func NewClusterRepository 

func NewClusterRepository(db *gorm.DB) IClusterRepository

type IDashboardRepository 

type IDashboardRepository interface {
	CreateDashboard(ctx context.Context, d *model.Dashboard) (string, error)
	GetDashboardById(ctx context.Context, organizationId string, dashboardId string) (*model.Dashboard, error)
	GetDashboardByUserId(ctx context.Context, organizationId string, userId string, dashboardKey string) (*model.Dashboard, error)
	UpdateDashboard(ctx context.Context, d *model.Dashboard) error
}

func NewDashboardRepository 

func NewDashboardRepository(db *gorm.DB) IDashboardRepository

type IEndpointRepository 

type IEndpointRepository interface {
	Create(ctx context.Context, endpoint *model.Endpoint) error
	List(ctx context.Context, pg *pagination.Pagination) ([]*model.Endpoint, error)
	Get(ctx context.Context, id uint) (*model.Endpoint, error)
}

type IOrganizationRepository 

type IOrganizationRepository interface {
	Create(ctx context.Context, dto *model.Organization) (model.Organization, error)
	Fetch(ctx context.Context, pg *pagination.Pagination) (res *[]model.Organization, err error)
	Get(ctx context.Context, organizationId string) (res model.Organization, err error)
	Update(ctx context.Context, organizationId string, in model.Organization) (model.Organization, error)
	UpdatePrimaryClusterId(ctx context.Context, organizationId string, primaryClusterId string) error
	UpdateAdminId(ctx context.Context, organizationId string, adminId uuid.UUID) error
	AddStackTemplates(ctx context.Context, organizationId string, stackTemplates []model.StackTemplate) (err error)
	RemoveStackTemplates(ctx context.Context, organizationId string, stackTemplates []model.StackTemplate) (err error)
	AddSystemNotificationTemplates(ctx context.Context, organizationId string, systemNotificationTemplates []model.SystemNotificationTemplate) (err error)
	RemoveSystemNotificationTemplates(ctx context.Context, organizationId string, systemNotificationTemplates []model.SystemNotificationTemplate) (err error)
	Delete(ctx context.Context, organizationId string) (err error)
	InitWorkflow(ctx context.Context, organizationId string, workflowId string, status domain.OrganizationStatus) error
	AddPermittedPolicyTemplatesByID(ctx context.Context, organizationId string, policyTemplates []model.PolicyTemplate) (err error)
	UpdatePermittedPolicyTemplatesByID(ctx context.Context, organizationId string, policyTemplates []model.PolicyTemplate) (err error)
	DeletePermittedPolicyTemplatesByID(ctx context.Context, organizationId string, policyTemplateids []uuid.UUID) (err error)
}

Interfaces

func NewOrganizationRepository 

func NewOrganizationRepository(db *gorm.DB) IOrganizationRepository

type IPermissionRepository 

type IPermissionRepository interface {
	Create(ctx context.Context, permission *model.Permission) error
	List(ctx context.Context, roleId string) ([]*model.Permission, error)
	Get(ctx context.Context, id uuid.UUID) (*model.Permission, error)
	Delete(ctx context.Context, id uuid.UUID) error
	Update(ctx context.Context, permission *model.Permission) error
}

type IPolicyRepository 

type IPolicyRepository interface {
	Create(ctx context.Context, dto model.Policy) (policyId uuid.UUID, err error)
	Update(ctx context.Context, organizationId string, policyId uuid.UUID,
		updateMap map[string]interface{}, TargetClusters *[]model.Cluster) (err error)
	Fetch(ctx context.Context, organizationId string, pg *pagination.Pagination) (out *[]model.Policy, err error)
	FetchByClusterId(ctx context.Context, clusterId string, pg *pagination.Pagination) (out *[]model.Policy, err error)
	FetchByClusterIdAndTemplaeId(ctx context.Context, clusterId string, templateId uuid.UUID) (out *[]model.Policy, err error)
	ExistByName(ctx context.Context, organizationId string, policyName string) (exist bool, err error)
	ExistByResourceName(ctx context.Context, organizationId string, policyName string) (exist bool, err error)
	ExistByID(ctx context.Context, organizationId string, policyId uuid.UUID) (exist bool, err error)
	GetByName(ctx context.Context, organizationId string, policyName string) (out *model.Policy, err error)
	GetByID(ctx context.Context, organizationId string, policyId uuid.UUID) (out *model.Policy, err error)
	Delete(ctx context.Context, organizationId string, policyId uuid.UUID) (err error)
	UpdatePolicyTargetClusters(ctx context.Context, organizationId string, policyId uuid.UUID, currentClusterIds []string, targetClusters []model.Cluster) (err error)
	SetMandatoryPolicies(ctx context.Context, organizationId string, mandatoryPolicyIds []uuid.UUID, nonMandatoryPolicyIds []uuid.UUID) (err error)
	GetUsageCountByTemplateId(ctx context.Context, organizationId *string, policyTemplateId uuid.UUID) (usageCounts []model.UsageCount, err error)
	CountPolicyByEnforcementAction(ctx context.Context, organizationId string) (policyCount []model.PolicyCount, err error)
	AddPoliciesForClusterID(ctx context.Context, organizationId string, clusterId domain.ClusterId, policies []model.Policy) (err error)
	UpdatePoliciesForClusterID(ctx context.Context, organizationId string, clusterId domain.ClusterId, policies []model.Policy) (err error)
	DeletePoliciesForClusterID(ctx context.Context, organizationId string, clusterId domain.ClusterId, policyIds []uuid.UUID) (err error)
	GetPolicyIDsByClusterID(ctx context.Context, clusterId domain.ClusterId) (out *[]uuid.UUID, err error)
}

func NewPolicyRepository 

func NewPolicyRepository(db *gorm.DB) IPolicyRepository

type IPolicyTemplateRepository 

type IPolicyTemplateRepository interface {
	Create(ctx context.Context, policyTemplate model.PolicyTemplate) (policyTemplateId uuid.UUID, err error)
	Update(ctx context.Context, policyTemplateId uuid.UUID, updateMap map[string]interface{}, permittedOrganizations *[]model.Organization) (err error)
	Fetch(ctx context.Context, pg *pagination.Pagination) (out []model.PolicyTemplate, err error)
	FetchForOrganization(ctx context.Context, organizationId string, pg *pagination.Pagination) (out []model.PolicyTemplate, err error)
	GetByName(ctx context.Context, policyTemplateName string) (out *model.PolicyTemplate, err error)
	GetByKind(ctx context.Context, policyTemplateKind string) (out *model.PolicyTemplate, err error)
	GetByID(ctx context.Context, policyTemplateId uuid.UUID) (out *model.PolicyTemplate, err error)
	Delete(ctx context.Context, policyTemplateId uuid.UUID) (err error)
	ExistByName(ctx context.Context, policyTemplateName string) (exist bool, err error)
	ExistByKind(ctx context.Context, policyTemplateKind string) (exist bool, err error)
	ExistByNameInOrganization(ctx context.Context, organizationId string, policyTemplateName string) (exist bool, err error)
	ExistByKindInOrganization(ctx context.Context, organizationId string, policyTemplateKind string) (exist bool, err error)
	ExistByID(ctx context.Context, policyTemplateId uuid.UUID) (exist bool, err error)
	ListPolicyTemplateVersions(ctx context.Context, policyTemplateId uuid.UUID) (policyTemplateVersionsReponse *domain.ListPolicyTemplateVersionsResponse, err error)
	GetPolicyTemplateVersion(ctx context.Context, policyTemplateId uuid.UUID, version string) (policyTemplateVersionsReponse *model.PolicyTemplate, err error)
	DeletePolicyTemplateVersion(ctx context.Context, policyTemplateId uuid.UUID, version string) (err error)
	CreatePolicyTemplateVersion(ctx context.Context, policyTemplateId uuid.UUID, newVersion string, schema []*domain.ParameterDef, rego string, libs []string) (version string, err error)
	GetLatestTemplateVersion(ctx context.Context, policyTemplateId uuid.UUID) (version string, err error)
	CountTksTemplateByOrganization(ctx context.Context, organizationId string) (count int64, err error)
	CountOrganizationTemplate(ctx context.Context, organizationId string) (count int64, err error)
	CountPolicyFromOrganizationTemplate(ctx context.Context, organizationId string) (count int64, err error)
}

func NewPolicyTemplateRepository 

func NewPolicyTemplateRepository(db *gorm.DB) IPolicyTemplateRepository

type IProjectRepository 

type IProjectRepository interface {
	CreateProject(ctx context.Context, p *model.Project) (string, error)
	GetProjects(ctx context.Context, organizationId string, userId uuid.UUID, projectName string, pg *pagination.Pagination) ([]domain.ProjectResponse, error)
	GetProjectsByUserId(ctx context.Context, organizationId string, userId uuid.UUID, projectName string, pg *pagination.Pagination) ([]domain.ProjectResponse, error)
	GetAllProjects(ctx context.Context, organizationId string, projectName string, pg *pagination.Pagination) (pr []domain.ProjectResponse, err error)
	GetProjectById(ctx context.Context, organizationId string, projectId string) (*model.Project, error)
	GetProjectByIdAndLeader(ctx context.Context, organizationId string, projectId string) (*model.Project, error)
	GetProjectByName(ctx context.Context, organizationId string, projectName string) (*model.Project, error)
	UpdateProject(ctx context.Context, p *model.Project) error
	GetAllProjectRoles(ctx context.Context) ([]model.ProjectRole, error)
	GetProjectRoleByName(ctx context.Context, name string) (*model.ProjectRole, error)
	GetProjectRoleById(ctx context.Context, id string) (*model.ProjectRole, error)
	AddProjectMember(context.Context, *model.ProjectMember) (string, error)
	GetProjectMembersByProjectId(ctx context.Context, projectId string, pg *pagination.Pagination) ([]model.ProjectMember, error)
	GetProjectMembersByProjectIdAndRoleName(ctx context.Context, projectId string, memberRole string, pg *pagination.Pagination) ([]model.ProjectMember, error)
	GetProjectMemberCountByProjectId(ctx context.Context, projectId string) (*domain.GetProjectMemberCountResponse, error)
	GetProjectMemberById(ctx context.Context, projectMemberId string) (*model.ProjectMember, error)
	GetProjectMemberByUserId(ctx context.Context, projectId string, projectUserId string) (pm *model.ProjectMember, err error)
	RemoveProjectMember(ctx context.Context, projectMemberId string) error
	UpdateProjectMemberRole(ctx context.Context, pm *model.ProjectMember) error
	CreateProjectNamespace(ctx context.Context, organizationId string, pn *model.ProjectNamespace) error
	GetProjectNamespaceByName(ctx context.Context, organizationId string, projectId string, stackId string, projectNamespace string) (*model.ProjectNamespace, error)
	GetProjectNamespaces(ctx context.Context, organizationId string, projectId string, pg *pagination.Pagination) ([]model.ProjectNamespace, error)
	GetProjectNamespaceByPrimaryKey(ctx context.Context, organizationId string, projectId string, projectNamespace string, stackId string) (*model.ProjectNamespace, error)
	UpdateProjectNamespace(ctx context.Context, pn *model.ProjectNamespace) error
	DeleteProjectNamespace(ctx context.Context, organizationId string, projectId string, projectNamespace string, stackId string) error
	GetAppCountByProjectId(ctx context.Context, organizationId string, projectId string) (int, error)
	GetAppCountByNamespace(ctx context.Context, organizationId string, projectId string, namespace string) (int, error)
}

func NewProjectRepository 

func NewProjectRepository(db *gorm.DB) IProjectRepository

type IRoleRepository 

type IRoleRepository interface {
	Create(ctx context.Context, roleObj *model.Role) (string, error)
	ListTksRoles(ctx context.Context, organizationId string, pg *pagination.Pagination) ([]*model.Role, error)
	GetTksRole(ctx context.Context, organizationId string, id string) (*model.Role, error)
	GetTksRoleByRoleName(ctx context.Context, organizationId string, roleName string) (*model.Role, error)
	Delete(ctx context.Context, id string) error
	Update(ctx context.Context, roleObj *model.Role) error
}

func NewRoleRepository 

func NewRoleRepository(db *gorm.DB) IRoleRepository

type IStackTemplateRepository 

type IStackTemplateRepository interface {
	Get(ctx context.Context, stackTemplateId uuid.UUID) (model.StackTemplate, error)
	GetByName(ctx context.Context, name string) (model.StackTemplate, error)
	Fetch(ctx context.Context, pg *pagination.Pagination) ([]model.StackTemplate, error)
	FetchWithOrganization(ctx context.Context, organizationId string, pg *pagination.Pagination) (out []model.StackTemplate, err error)
	Create(ctx context.Context, dto model.StackTemplate) (stackTemplateId uuid.UUID, err error)
	Update(ctx context.Context, dto model.StackTemplate) (err error)
	Delete(ctx context.Context, dto model.StackTemplate) (err error)
	UpdateOrganizations(ctx context.Context, stackTemplateId uuid.UUID, organizationIds []model.Organization) (err error)
}

Interfaces

func NewStackTemplateRepository 

func NewStackTemplateRepository(db *gorm.DB) IStackTemplateRepository

type ISystemNotificationRepository 

type ISystemNotificationRepository interface {
	Get(ctx context.Context, systemNotificationId uuid.UUID) (model.SystemNotification, error)
	GetByName(ctx context.Context, organizationId string, name string) (model.SystemNotification, error)
	FetchSystemNotifications(ctx context.Context, organizationId string, pg *pagination.Pagination) ([]model.SystemNotification, error)
	FetchPolicyNotifications(ctx context.Context, organizationId string, pg *pagination.Pagination) ([]model.SystemNotification, error)
	FetchPodRestart(ctx context.Context, organizationId string, start time.Time, end time.Time) ([]model.SystemNotification, error)
	Create(ctx context.Context, dto model.SystemNotification) (systemNotificationId uuid.UUID, err error)
	Update(ctx context.Context, dto model.SystemNotification) (err error)
	Delete(ctx context.Context, dto model.SystemNotification) (err error)
	CreateSystemNotificationAction(ctx context.Context, dto model.SystemNotificationAction) (systemNotificationActionId uuid.UUID, err error)
	UpdateRead(ctx context.Context, systemNotificationId uuid.UUID, user model.User) (err error)
}

Interfaces

func NewSystemNotificationRepository 

func NewSystemNotificationRepository(db *gorm.DB) ISystemNotificationRepository

type ISystemNotificationRuleRepository 

type ISystemNotificationRuleRepository interface {
	Get(ctx context.Context, systemNotificationRuleId uuid.UUID) (model.SystemNotificationRule, error)
	GetByName(ctx context.Context, name string) (model.SystemNotificationRule, error)
	Fetch(ctx context.Context, pg *pagination.Pagination) ([]model.SystemNotificationRule, error)
	FetchWithOrganization(ctx context.Context, organizationId string, pg *pagination.Pagination) (out []model.SystemNotificationRule, err error)
	Create(ctx context.Context, dto model.SystemNotificationRule) (systemNotificationRuleId uuid.UUID, err error)
	Creates(ctx context.Context, dto []model.SystemNotificationRule) (err error)
	Update(ctx context.Context, dto model.SystemNotificationRule) (err error)
	UpdateStatus(ctx context.Context, systemNotificationRuleId uuid.UUID, status domain.SystemNotificationRuleStatus) (err error)
	Delete(ctx context.Context, dto model.SystemNotificationRule) (err error)
}

Interfaces

func NewSystemNotificationRuleRepository 

func NewSystemNotificationRuleRepository(db *gorm.DB) ISystemNotificationRuleRepository

type ISystemNotificationTemplateRepository 

type ISystemNotificationTemplateRepository interface {
	Get(ctx context.Context, systemNotificationTemplateId uuid.UUID) (model.SystemNotificationTemplate, error)
	GetByName(ctx context.Context, name string) (model.SystemNotificationTemplate, error)
	Fetch(ctx context.Context, pg *pagination.Pagination) ([]model.SystemNotificationTemplate, error)
	FetchWithOrganization(ctx context.Context, organizationId string, pg *pagination.Pagination) (out []model.SystemNotificationTemplate, err error)
	Create(ctx context.Context, dto model.SystemNotificationTemplate) (systemNotificationTemplateId uuid.UUID, err error)
	Update(ctx context.Context, dto model.SystemNotificationTemplate) (err error)
	Delete(ctx context.Context, dto model.SystemNotificationTemplate) (err error)
	UpdateOrganizations(ctx context.Context, systemNotificationTemplateId uuid.UUID, organizations []model.Organization) (err error)
}

Interfaces

func NewSystemNotificationTemplateRepository 

func NewSystemNotificationTemplateRepository(db *gorm.DB) ISystemNotificationTemplateRepository

type IUserRepository 

type IUserRepository interface {
	Create(ctx context.Context, user *model.User) (*model.User, error)
	List(ctx context.Context, filters ...FilterFunc) (out *[]model.User, err error)
	ListWithPagination(ctx context.Context, pg *pagination.Pagination, organizationId string) (out *[]model.User, err error)
	Get(ctx context.Context, accountId string, organizationId string) (model.User, error)
	GetByUuid(ctx context.Context, userId uuid.UUID) (model.User, error)
	Update(ctx context.Context, user *model.User) (*model.User, error)
	UpdatePasswordAt(ctx context.Context, userId uuid.UUID, organizationId string, isTemporary bool) error
	DeleteWithUuid(ctx context.Context, uuid uuid.UUID) error
	Flush(ctx context.Context, organizationId string) error

	ListUsersByRole(ctx context.Context, organizationId string, roleId string, pg *pagination.Pagination) (*[]model.User, error)

	AccountIdFilter(accountId string) FilterFunc
	OrganizationFilter(organization string) FilterFunc
	EmailFilter(email string) FilterFunc
	NameFilter(name string) FilterFunc
}

Interface

func NewUserRepository 

func NewUserRepository(db *gorm.DB) IUserRepository

type OrganizationRepository 

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

func (*OrganizationRepository) AddPermittedPolicyTemplatesByID 

func (r *OrganizationRepository) AddPermittedPolicyTemplatesByID(ctx context.Context, organizationId string, policyTemplates []model.PolicyTemplate) (err error)

func (*OrganizationRepository) AddStackTemplates 

func (r *OrganizationRepository) AddStackTemplates(ctx context.Context, organizationId string, stackTemplates []model.StackTemplate) (err error)

func (*OrganizationRepository) AddSystemNotificationTemplates 

func (r *OrganizationRepository) AddSystemNotificationTemplates(ctx context.Context, organizationId string, templates []model.SystemNotificationTemplate) (err error)

func (*OrganizationRepository) Create 

func (r *OrganizationRepository) Create(ctx context.Context, dto *model.Organization) (model.Organization, error)

func (*OrganizationRepository) Delete 

func (r *OrganizationRepository) Delete(ctx context.Context, organizationId string) error

func (*OrganizationRepository) DeletePermittedPolicyTemplatesByID 

func (r *OrganizationRepository) DeletePermittedPolicyTemplatesByID(ctx context.Context, organizationId string, policyTemplateids []uuid.UUID) (err error)

func (*OrganizationRepository) Fetch 

func (r *OrganizationRepository) Fetch(ctx context.Context, pg *pagination.Pagination) (out *[]model.Organization, err error)

func (*OrganizationRepository) Get 

func (r *OrganizationRepository) Get(ctx context.Context, id string) (out model.Organization, err error)

func (*OrganizationRepository) InitWorkflow 

func (r *OrganizationRepository) InitWorkflow(ctx context.Context, organizationId string, workflowId string, status domain.OrganizationStatus) error

func (*OrganizationRepository) RemoveStackTemplates 

func (r *OrganizationRepository) RemoveStackTemplates(ctx context.Context, organizationId string, stackTemplates []model.StackTemplate) (err error)

func (*OrganizationRepository) RemoveSystemNotificationTemplates 

func (r *OrganizationRepository) RemoveSystemNotificationTemplates(ctx context.Context, organizationId string, templates []model.SystemNotificationTemplate) (err error)

func (*OrganizationRepository) Update 

func (r *OrganizationRepository) Update(ctx context.Context, organizationId string, in model.Organization) (out model.Organization, err error)

func (*OrganizationRepository) UpdateAdminId 

func (r *OrganizationRepository) UpdateAdminId(ctx context.Context, organizationId string, adminId uuid.UUID) (err error)

func (*OrganizationRepository) UpdatePermittedPolicyTemplatesByID 

func (r *OrganizationRepository) UpdatePermittedPolicyTemplatesByID(ctx context.Context, organizationId string, policyTemplates []model.PolicyTemplate) (err error)

func (*OrganizationRepository) UpdatePrimaryClusterId 

func (r *OrganizationRepository) UpdatePrimaryClusterId(ctx context.Context, organizationId string, primaryClusterId string) error

type PermissionRepository 

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

func NewPermissionRepository 

func NewPermissionRepository(db *gorm.DB) *PermissionRepository

func (PermissionRepository) Create 

func (r PermissionRepository) Create(ctx context.Context, p *model.Permission) error

func (PermissionRepository) Delete 

func (r PermissionRepository) Delete(ctx context.Context, id uuid.UUID) error

func (PermissionRepository) Get 

func (r PermissionRepository) Get(ctx context.Context, id uuid.UUID) (*model.Permission, error)

func (PermissionRepository) List 

func (r PermissionRepository) List(ctx context.Context, roleId string) ([]*model.Permission, error)

func (PermissionRepository) Update 

func (r PermissionRepository) Update(ctx context.Context, p *model.Permission) error

type PolicyRepository 

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

func (*PolicyRepository) AddPoliciesForClusterID 

func (r *PolicyRepository) AddPoliciesForClusterID(ctx context.Context, organizationId string, clusterId domain.ClusterId, policies []model.Policy) (err error)

func (*PolicyRepository) CountPolicyByEnforcementAction 

func (r *PolicyRepository) CountPolicyByEnforcementAction(ctx context.Context, organizationId string) (policyCount []model.PolicyCount, err error)

func (*PolicyRepository) Create 

func (r *PolicyRepository) Create(ctx context.Context, dto model.Policy) (policyId uuid.UUID, err error)

func (*PolicyRepository) Delete 

func (r *PolicyRepository) Delete(ctx context.Context, organizationId string, policyId uuid.UUID) (err error)

func (*PolicyRepository) DeletePoliciesForClusterID 

func (r *PolicyRepository) DeletePoliciesForClusterID(ctx context.Context, organizationId string, clusterId domain.ClusterId, policyIds []uuid.UUID) (err error)

func (*PolicyRepository) ExistBy 

func (r *PolicyRepository) ExistBy(ctx context.Context, organizationId string, key string, value interface{}) (exists bool, err error)

func (*PolicyRepository) ExistByID 

func (r *PolicyRepository) ExistByID(ctx context.Context, organizationId string, policyId uuid.UUID) (exist bool, err error)

func (*PolicyRepository) ExistByName 

func (r *PolicyRepository) ExistByName(ctx context.Context, organizationId string, policyName string) (exist bool, err error)

func (*PolicyRepository) ExistByResourceName 

func (r *PolicyRepository) ExistByResourceName(ctx context.Context, organizationId string, policyName string) (exist bool, err error)

func (*PolicyRepository) Fetch 

func (r *PolicyRepository) Fetch(ctx context.Context, organizationId string, pg *pagination.Pagination) (out *[]model.Policy, err error)

func (*PolicyRepository) FetchByClusterId 

func (r *PolicyRepository) FetchByClusterId(ctx context.Context, clusterId string, pg *pagination.Pagination) (out *[]model.Policy, err error)

func (*PolicyRepository) FetchByClusterIdAndTemplaeId 

func (r *PolicyRepository) FetchByClusterIdAndTemplaeId(ctx context.Context, clusterId string, templateId uuid.UUID) (out *[]model.Policy, err error)

func (*PolicyRepository) GetBy 

func (r *PolicyRepository) GetBy(ctx context.Context, organizationId string, key string, value interface{}) (out *model.Policy, err error)

func (*PolicyRepository) GetByID 

func (r *PolicyRepository) GetByID(ctx context.Context, organizationId string, policyId uuid.UUID) (out *model.Policy, err error)

func (*PolicyRepository) GetByName 

func (r *PolicyRepository) GetByName(ctx context.Context, organizationId string, policyName string) (out *model.Policy, err error)

func (*PolicyRepository) GetPolicyIDsByClusterID 

func (r *PolicyRepository) GetPolicyIDsByClusterID(ctx context.Context, clusterId domain.ClusterId) (*[]uuid.UUID, error)

func (*PolicyRepository) GetUsageCountByTemplateId 

func (r *PolicyRepository) GetUsageCountByTemplateId(ctx context.Context, organizationId *string, policyTemplateId uuid.UUID) (usageCounts []model.UsageCount, err error)

func (*PolicyRepository) SetMandatoryPolicies 

func (r *PolicyRepository) SetMandatoryPolicies(ctx context.Context, organizationId string, mandatoryPolicyIds []uuid.UUID, nonMandatoryPolicyIds []uuid.UUID) (err error)

func (*PolicyRepository) Update 

func (r *PolicyRepository) Update(ctx context.Context, organizationId string, policyId uuid.UUID,
	updateMap map[string]interface{}, targetClusters *[]model.Cluster) (err error)

func (*PolicyRepository) UpdatePoliciesForClusterID 

func (r *PolicyRepository) UpdatePoliciesForClusterID(ctx context.Context, organizationId string, clusterId domain.ClusterId, policies []model.Policy) (err error)

func (*PolicyRepository) UpdatePolicyTargetClusters 

func (r *PolicyRepository) UpdatePolicyTargetClusters(ctx context.Context, organizationId string, policyId uuid.UUID, currentClusterIds []string, targetClusters []model.Cluster) (err error)

type PolicyTemplateRepository 

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

func (*PolicyTemplateRepository) CountOrganizationTemplate 

func (r *PolicyTemplateRepository) CountOrganizationTemplate(ctx context.Context, organizationId string) (count int64, err error)

func (*PolicyTemplateRepository) CountPolicyFromOrganizationTemplate 

func (r *PolicyTemplateRepository) CountPolicyFromOrganizationTemplate(ctx context.Context, organizationId string) (count int64, err error)

func (*PolicyTemplateRepository) CountTksTemplateByOrganization 

func (r *PolicyTemplateRepository) CountTksTemplateByOrganization(ctx context.Context, organizationId string) (count int64, err error)

func (*PolicyTemplateRepository) Create 

func (r *PolicyTemplateRepository) Create(ctx context.Context, dto model.PolicyTemplate) (policyTemplateId uuid.UUID, err error)

func (*PolicyTemplateRepository) CreatePolicyTemplateVersion 

func (r *PolicyTemplateRepository) CreatePolicyTemplateVersion(ctx context.Context, policyTemplateId uuid.UUID, newVersion string, schema []*domain.ParameterDef, rego string, libs []string) (version string, err error)

func (*PolicyTemplateRepository) Delete 

func (r *PolicyTemplateRepository) Delete(ctx context.Context, policyTemplateId uuid.UUID) (err error)

func (*PolicyTemplateRepository) DeletePolicyTemplateVersion 

func (r *PolicyTemplateRepository) DeletePolicyTemplateVersion(ctx context.Context, policyTemplateId uuid.UUID, version string) (err error)

func (*PolicyTemplateRepository) ExistByID 

func (r *PolicyTemplateRepository) ExistByID(ctx context.Context, policyTemplateId uuid.UUID) (exist bool, err error)

func (*PolicyTemplateRepository) ExistByKind 

func (r *PolicyTemplateRepository) ExistByKind(ctx context.Context, policyTemplateKind string) (exist bool, err error)

func (*PolicyTemplateRepository) ExistByKindInOrganization 

func (r *PolicyTemplateRepository) ExistByKindInOrganization(ctx context.Context, organizationId string, policyTemplateKind string) (exist bool, err error)

func (*PolicyTemplateRepository) ExistByName 

func (r *PolicyTemplateRepository) ExistByName(ctx context.Context, policyTemplateName string) (exist bool, err error)

func (*PolicyTemplateRepository) ExistByNameInOrganization 

func (r *PolicyTemplateRepository) ExistByNameInOrganization(ctx context.Context, organizationId string, policyTemplateName string) (exist bool, err error)

func (*PolicyTemplateRepository) ExistsBy 

func (r *PolicyTemplateRepository) ExistsBy(ctx context.Context, key string, value interface{}) (exists bool, err error)

func (*PolicyTemplateRepository) ExistsByInOrganization 

func (r *PolicyTemplateRepository) ExistsByInOrganization(ctx context.Context, organizationId string, key string, value interface{}) (exists bool, err error)

func (*PolicyTemplateRepository) Fetch 

func (r *PolicyTemplateRepository) Fetch(ctx context.Context, pg *pagination.Pagination) (out []model.PolicyTemplate, err error)

func (*PolicyTemplateRepository) FetchForOrganization 

func (r *PolicyTemplateRepository) FetchForOrganization(ctx context.Context, organizationId string, pg *pagination.Pagination) (out []model.PolicyTemplate, err error)

func (*PolicyTemplateRepository) GetBy 

func (r *PolicyTemplateRepository) GetBy(ctx context.Context, key string, value interface{}) (out *model.PolicyTemplate, err error)

func (*PolicyTemplateRepository) GetByID 

func (r *PolicyTemplateRepository) GetByID(ctx context.Context, policyTemplateId uuid.UUID) (out *model.PolicyTemplate, err error)

func (*PolicyTemplateRepository) GetByKind 

func (r *PolicyTemplateRepository) GetByKind(ctx context.Context, policyTemplateKind string) (out *model.PolicyTemplate, err error)

func (*PolicyTemplateRepository) GetByName 

func (r *PolicyTemplateRepository) GetByName(ctx context.Context, policyTemplateName string) (out *model.PolicyTemplate, err error)

func (*PolicyTemplateRepository) GetLatestTemplateVersion 

func (r *PolicyTemplateRepository) GetLatestTemplateVersion(ctx context.Context, policyTemplateId uuid.UUID) (version string, err error)

func (*PolicyTemplateRepository) GetPolicyTemplateVersion 

func (r *PolicyTemplateRepository) GetPolicyTemplateVersion(ctx context.Context, policyTemplateId uuid.UUID, version string) (policyTemplateVersionsReponse *model.PolicyTemplate, err error)

func (*PolicyTemplateRepository) ListPolicyTemplateVersions 

func (r *PolicyTemplateRepository) ListPolicyTemplateVersions(ctx context.Context, policyTemplateId uuid.UUID) (policyTemplateVersionsReponse *domain.ListPolicyTemplateVersionsResponse, err error)

func (*PolicyTemplateRepository) Update 

func (r *PolicyTemplateRepository) Update(ctx context.Context, policyTemplateId uuid.UUID,
	updateMap map[string]interface{}, permittedOrganizations *[]model.Organization) (err error)

type ProjectRepository 

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

func (*ProjectRepository) AddProjectMember 

func (r *ProjectRepository) AddProjectMember(ctx context.Context, pm *model.ProjectMember) (string, error)

func (*ProjectRepository) CreateProject 

func (r *ProjectRepository) CreateProject(ctx context.Context, p *model.Project) (string, error)

func (*ProjectRepository) CreateProjectNamespace 

func (r *ProjectRepository) CreateProjectNamespace(ctx context.Context, organizationId string, pn *model.ProjectNamespace) error

func (*ProjectRepository) DeleteProjectNamespace 

func (r *ProjectRepository) DeleteProjectNamespace(ctx context.Context, organizationId string, projectId string, projectNamespace string,
	stackId string) error

func (*ProjectRepository) GetAllProjectRoles 

func (r *ProjectRepository) GetAllProjectRoles(ctx context.Context) (prs []model.ProjectRole, err error)

func (*ProjectRepository) GetAllProjects 

func (r *ProjectRepository) GetAllProjects(ctx context.Context, organizationId string, projectName string, pg *pagination.Pagination) (pr []domain.ProjectResponse, err error)

func (*ProjectRepository) GetAppCountByNamespace 

func (r *ProjectRepository) GetAppCountByNamespace(ctx context.Context, organizationId string, projectId string, namespace string) (appCount int, err error)

func (*ProjectRepository) GetAppCountByProjectId 

func (r *ProjectRepository) GetAppCountByProjectId(ctx context.Context, organizationId string, projectId string) (appCount int, err error)

func (*ProjectRepository) GetProjectById 

func (r *ProjectRepository) GetProjectById(ctx context.Context, organizationId string, projectId string) (p *model.Project, err error)

func (*ProjectRepository) GetProjectByIdAndLeader 

func (r *ProjectRepository) GetProjectByIdAndLeader(ctx context.Context, organizationId string, projectId string) (p *model.Project, err error)

func (*ProjectRepository) GetProjectByName 

func (r *ProjectRepository) GetProjectByName(ctx context.Context, organizationId string, projectName string) (p *model.Project, err error)

func (*ProjectRepository) GetProjectMemberById 

func (r *ProjectRepository) GetProjectMemberById(ctx context.Context, projectMemberId string) (pm *model.ProjectMember, err error)

func (*ProjectRepository) GetProjectMemberByUserId 

func (r *ProjectRepository) GetProjectMemberByUserId(ctx context.Context, projectId string, projectUserId string) (pm *model.ProjectMember, err error)

func (*ProjectRepository) GetProjectMemberCountByProjectId 

func (r *ProjectRepository) GetProjectMemberCountByProjectId(ctx context.Context, projectId string) (pmcr *domain.GetProjectMemberCountResponse, err error)

func (*ProjectRepository) GetProjectMembersByProjectId 

func (r *ProjectRepository) GetProjectMembersByProjectId(ctx context.Context, projectId string, pg *pagination.Pagination) (pms []model.ProjectMember, err error)

func (*ProjectRepository) GetProjectMembersByProjectIdAndRoleName 

func (r *ProjectRepository) GetProjectMembersByProjectIdAndRoleName(ctx context.Context, projectId string, memberRole string, pg *pagination.Pagination) (pms []model.ProjectMember, err error)

func (*ProjectRepository) GetProjectNamespaceByName 

func (r *ProjectRepository) GetProjectNamespaceByName(ctx context.Context, organizationId string, projectId string, stackId string,
	projectNamespace string) (pn *model.ProjectNamespace, err error)

func (*ProjectRepository) GetProjectNamespaceByPrimaryKey 

func (r *ProjectRepository) GetProjectNamespaceByPrimaryKey(ctx context.Context, organizationId string, projectId string,
	projectNamespace string, stackId string) (pn *model.ProjectNamespace, err error)

func (*ProjectRepository) GetProjectNamespaces 

func (r *ProjectRepository) GetProjectNamespaces(ctx context.Context, organizationId string, projectId string, pg *pagination.Pagination) (pns []model.ProjectNamespace, err error)

func (*ProjectRepository) GetProjectRoleById 

func (r *ProjectRepository) GetProjectRoleById(ctx context.Context, id string) (*model.ProjectRole, error)

func (*ProjectRepository) GetProjectRoleByName 

func (r *ProjectRepository) GetProjectRoleByName(ctx context.Context, name string) (pr *model.ProjectRole, err error)

func (*ProjectRepository) GetProjects 

func (r *ProjectRepository) GetProjects(ctx context.Context, organizationId string, userId uuid.UUID, projectName string, pg *pagination.Pagination) (pr []domain.ProjectResponse, err error)

func (*ProjectRepository) GetProjectsByUserId 

func (r *ProjectRepository) GetProjectsByUserId(ctx context.Context, organizationId string, userId uuid.UUID, projectName string, pg *pagination.Pagination) (pr []domain.ProjectResponse, err error)

func (*ProjectRepository) RemoveProjectMember 

func (r *ProjectRepository) RemoveProjectMember(ctx context.Context, projectMemberId string) error

func (*ProjectRepository) UpdateProject 

func (r *ProjectRepository) UpdateProject(ctx context.Context, p *model.Project) error

func (*ProjectRepository) UpdateProjectMemberRole 

func (r *ProjectRepository) UpdateProjectMemberRole(ctx context.Context, pm *model.ProjectMember) error

func (*ProjectRepository) UpdateProjectNamespace 

func (r *ProjectRepository) UpdateProjectNamespace(ctx context.Context, pn *model.ProjectNamespace) error

type Repository 

type Repository struct {
	Auth                       IAuthRepository
	User                       IUserRepository
	Cluster                    IClusterRepository
	Organization               IOrganizationRepository
	AppGroup                   IAppGroupRepository
	AppServeApp                IAppServeAppRepository
	CloudAccount               ICloudAccountRepository
	StackTemplate              IStackTemplateRepository
	Role                       IRoleRepository
	Permission                 IPermissionRepository
	Endpoint                   IEndpointRepository
	Project                    IProjectRepository
	Audit                      IAuditRepository
	PolicyTemplate             IPolicyTemplateRepository
	Policy                     IPolicyRepository
	SystemNotification         ISystemNotificationRepository
	SystemNotificationTemplate ISystemNotificationTemplateRepository
	SystemNotificationRule     ISystemNotificationRuleRepository
	Dashboard                  IDashboardRepository
}

type RoleRepository 

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

func (RoleRepository) Create 

func (r RoleRepository) Create(ctx context.Context, roleObj *model.Role) (string, error)

func (RoleRepository) Delete 

func (r RoleRepository) Delete(ctx context.Context, id string) error

func (RoleRepository) GetTksRole 

func (r RoleRepository) GetTksRole(ctx context.Context, organizationId string, id string) (*model.Role, error)

func (RoleRepository) GetTksRoleByRoleName 

func (r RoleRepository) GetTksRoleByRoleName(ctx context.Context, oragnizationId string, roleName string) (*model.Role, error)

func (RoleRepository) ListTksRoles 

func (r RoleRepository) ListTksRoles(ctx context.Context, organizationId string, pg *pagination.Pagination) ([]*model.Role, error)

func (RoleRepository) Update 

func (r RoleRepository) Update(ctx context.Context, roleObj *model.Role) error

type StackTemplateRepository 

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

func (*StackTemplateRepository) Create 

func (r *StackTemplateRepository) Create(ctx context.Context, dto model.StackTemplate) (stackTemplateId uuid.UUID, err error)

func (*StackTemplateRepository) Delete 

func (r *StackTemplateRepository) Delete(ctx context.Context, dto model.StackTemplate) (err error)

func (*StackTemplateRepository) Fetch 

func (r *StackTemplateRepository) Fetch(ctx context.Context, pg *pagination.Pagination) (out []model.StackTemplate, err error)

func (*StackTemplateRepository) FetchWithOrganization 

func (r *StackTemplateRepository) FetchWithOrganization(ctx context.Context, organizationId string, pg *pagination.Pagination) (out []model.StackTemplate, err error)

func (*StackTemplateRepository) Get 

func (r *StackTemplateRepository) Get(ctx context.Context, stackTemplateId uuid.UUID) (out model.StackTemplate, err error)

Logics

func (*StackTemplateRepository) GetByName 

func (r *StackTemplateRepository) GetByName(ctx context.Context, name string) (out model.StackTemplate, err error)

func (*StackTemplateRepository) Update 

func (r *StackTemplateRepository) Update(ctx context.Context, dto model.StackTemplate) (err error)

func (*StackTemplateRepository) UpdateOrganizations 

func (r *StackTemplateRepository) UpdateOrganizations(ctx context.Context, stackTemplateId uuid.UUID, organizations []model.Organization) (err error)

type SystemNotificationRepository 

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

func (*SystemNotificationRepository) Create 

func (r *SystemNotificationRepository) Create(ctx context.Context, dto model.SystemNotification) (systemNotificationId uuid.UUID, err error)

func (*SystemNotificationRepository) CreateSystemNotificationAction 

func (r *SystemNotificationRepository) CreateSystemNotificationAction(ctx context.Context, dto model.SystemNotificationAction) (systemNotificationActionId uuid.UUID, err error)

func (*SystemNotificationRepository) Delete 

func (r *SystemNotificationRepository) Delete(ctx context.Context, dto model.SystemNotification) (err error)

func (*SystemNotificationRepository) FetchPodRestart 

func (r *SystemNotificationRepository) FetchPodRestart(ctx context.Context, organizationId string, start time.Time, end time.Time) (out []model.SystemNotification, err error)

func (*SystemNotificationRepository) FetchPolicyNotifications 

func (r *SystemNotificationRepository) FetchPolicyNotifications(ctx context.Context, organizationId string, pg *pagination.Pagination) (out []model.SystemNotification, err error)

func (*SystemNotificationRepository) FetchSystemNotifications 

func (r *SystemNotificationRepository) FetchSystemNotifications(ctx context.Context, organizationId string, pg *pagination.Pagination) (out []model.SystemNotification, err error)

func (*SystemNotificationRepository) Get 

func (r *SystemNotificationRepository) Get(ctx context.Context, systemNotificationId uuid.UUID) (out model.SystemNotification, err error)

Logics

func (*SystemNotificationRepository) GetByName 

func (r *SystemNotificationRepository) GetByName(ctx context.Context, organizationId string, name string) (out model.SystemNotification, err error)

func (*SystemNotificationRepository) Update 

func (r *SystemNotificationRepository) Update(ctx context.Context, dto model.SystemNotification) (err error)

func (*SystemNotificationRepository) UpdateRead 

func (r *SystemNotificationRepository) UpdateRead(ctx context.Context, systemNotificationId uuid.UUID, user model.User) (err error)

type SystemNotificationRuleRepository 

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

func (*SystemNotificationRuleRepository) Create 

func (r *SystemNotificationRuleRepository) Create(ctx context.Context, dto model.SystemNotificationRule) (systemNotificationRuleId uuid.UUID, err error)

func (*SystemNotificationRuleRepository) Creates 

func (r *SystemNotificationRuleRepository) Creates(ctx context.Context, rules []model.SystemNotificationRule) (err error)

func (*SystemNotificationRuleRepository) Delete 

func (r *SystemNotificationRuleRepository) Delete(ctx context.Context, dto model.SystemNotificationRule) (err error)

func (*SystemNotificationRuleRepository) Fetch 

func (r *SystemNotificationRuleRepository) Fetch(ctx context.Context, pg *pagination.Pagination) (out []model.SystemNotificationRule, err error)

func (*SystemNotificationRuleRepository) FetchWithOrganization 

func (r *SystemNotificationRuleRepository) FetchWithOrganization(ctx context.Context, organizationId string, pg *pagination.Pagination) (out []model.SystemNotificationRule, err error)

func (*SystemNotificationRuleRepository) Get 

func (r *SystemNotificationRuleRepository) Get(ctx context.Context, systemNotificationRuleId uuid.UUID) (out model.SystemNotificationRule, err error)

Logics

func (*SystemNotificationRuleRepository) GetByName 

func (r *SystemNotificationRuleRepository) GetByName(ctx context.Context, name string) (out model.SystemNotificationRule, err error)

func (*SystemNotificationRuleRepository) Update 

func (r *SystemNotificationRuleRepository) Update(ctx context.Context, dto model.SystemNotificationRule) (err error)

func (*SystemNotificationRuleRepository) UpdateStatus 

func (r *SystemNotificationRuleRepository) UpdateStatus(ctx context.Context, systemNotificationRuleId uuid.UUID, status domain.SystemNotificationRuleStatus) error

type SystemNotificationTemplateRepository 

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

func (*SystemNotificationTemplateRepository) Create 

func (r *SystemNotificationTemplateRepository) Create(ctx context.Context, dto model.SystemNotificationTemplate) (systemNotificationTemplateId uuid.UUID, err error)

func (*SystemNotificationTemplateRepository) Delete 

func (r *SystemNotificationTemplateRepository) Delete(ctx context.Context, dto model.SystemNotificationTemplate) (err error)

func (*SystemNotificationTemplateRepository) Fetch 

func (r *SystemNotificationTemplateRepository) Fetch(ctx context.Context, pg *pagination.Pagination) (out []model.SystemNotificationTemplate, err error)

func (*SystemNotificationTemplateRepository) FetchWithOrganization 

func (r *SystemNotificationTemplateRepository) FetchWithOrganization(ctx context.Context, organizationId string, pg *pagination.Pagination) (out []model.SystemNotificationTemplate, err error)

func (*SystemNotificationTemplateRepository) Get 

func (r *SystemNotificationTemplateRepository) Get(ctx context.Context, systemNotificationTemplateId uuid.UUID) (out model.SystemNotificationTemplate, err error)

Logics

func (*SystemNotificationTemplateRepository) GetByName 

func (r *SystemNotificationTemplateRepository) GetByName(ctx context.Context, name string) (out model.SystemNotificationTemplate, err error)

func (*SystemNotificationTemplateRepository) Update 

func (r *SystemNotificationTemplateRepository) Update(ctx context.Context, dto model.SystemNotificationTemplate) (err error)

func (*SystemNotificationTemplateRepository) UpdateOrganizations 

func (r *SystemNotificationTemplateRepository) UpdateOrganizations(ctx context.Context, systemNotificationTemplateId uuid.UUID, organizations []model.Organization) (err error)

type UserRepository 

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

func (*UserRepository) AccountIdFilter 

func (r *UserRepository) AccountIdFilter(accountId string) FilterFunc

func (*UserRepository) Create 

func (r *UserRepository) Create(ctx context.Context, user *model.User) (*model.User, error)

func (r *UserRepository) CreateWithUuid(ctx context.Context, uuid uuid.UUID, accountId string, name string, email string, 

department string, description string, organizationId string, roleId string) (model.User, error) {

func (*UserRepository) DeleteWithUuid 

func (r *UserRepository) DeleteWithUuid(ctx context.Context, uuid uuid.UUID) error

func (*UserRepository) EmailFilter 

func (r *UserRepository) EmailFilter(email string) FilterFunc

func (*UserRepository) Flush 

func (r *UserRepository) Flush(ctx context.Context, organizationId string) error

func (*UserRepository) Get 

func (r *UserRepository) Get(ctx context.Context, accountId string, organizationId string) (model.User, error)

func (*UserRepository) GetByUuid 

func (r *UserRepository) GetByUuid(ctx context.Context, userId uuid.UUID) (respUser model.User, err error)

func (*UserRepository) GetRoleByName 

func (r *UserRepository) GetRoleByName(ctx context.Context, roleName string) (model.Role, error)

func (*UserRepository) List 

func (r *UserRepository) List(ctx context.Context, filters ...FilterFunc) (*[]model.User, error)

func (*UserRepository) ListUsersByRole 

func (r *UserRepository) ListUsersByRole(ctx context.Context, organizationId string, roleId string, pg *pagination.Pagination) (*[]model.User, error)

func (*UserRepository) ListWithPagination 

func (r *UserRepository) ListWithPagination(ctx context.Context, pg *pagination.Pagination, organizationId string) (*[]model.User, error)

func (*UserRepository) NameFilter 

func (r *UserRepository) NameFilter(name string) FilterFunc

func (*UserRepository) OrganizationFilter 

func (r *UserRepository) OrganizationFilter(organization string) FilterFunc

func (*UserRepository) Update 

func (r *UserRepository) Update(ctx context.Context, user *model.User) (*model.User, error)

func (*UserRepository) UpdatePasswordAt 

func (r *UserRepository) UpdatePasswordAt(ctx context.Context, userId uuid.UUID, organizationId string, isTemporary bool) error

Source Files

View all Source files

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.