dao

package
v1.5.0 Latest Latest
Warning

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

 Go to latest Published: Apr 29, 2022 License: Apache-2.0 Imports: 13 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func AddGroupUserConstraintValues 

func AddGroupUserConstraintValues(group, user, constraint string, conValues []string) error

func AddGroupUsers 

func AddGroupUsers(groupUsers []*models.GroupRoleUser) error

func AddResourceConstraint 

func AddResourceConstraint(resourceType, resourceConstraint, description string) error

func AddResourceOperation 

func AddResourceOperation(resourceType, resourceOperation, description string) error

func AddRoleOperation 

func AddRoleOperation(req *models.GroupRoleOperationReq) error

func AuditInsert 

func AuditInsert(audit *models.Audit) error

func AuditList 

func AuditList() ([]*models.Audit, error)

func BatchCreateResourceType 

func BatchCreateResourceType(req models.BatchResourceTypeReq) error

func CreateGatewayRoute 

func CreateGatewayRoute(router, method, backend, resourceType, resourceOperation string) error

func CreateGroupRole 

func CreateGroupRole(req *models.GroupRoleReq) (*models.GroupRole, error)

func CreateResourceType 

func CreateResourceType(resourceType, description string) (*models.ResourceType, error)

func CreateUser 

func CreateUser(user *models.User) (int64, error)

func DeleteCasbinrules 

func DeleteCasbinrules(role string, operations []int64) error

func DeleteGatewayRouteByBackend 

func DeleteGatewayRouteByBackend(backend string) error

func DeleteGroup 

func DeleteGroup(groupName string) error

func DeleteGroupRole 

func DeleteGroupRole(group, role string) error

func DeleteGroupRolePolicy 

func DeleteGroupRolePolicy(req *models.GroupRoleOperationReq) error

func DeleteGroupUserConstraint 

func DeleteGroupUserConstraint(group, user, constraint string) error

func DeleteGroupUserConstraintValues 

func DeleteGroupUserConstraintValues(group, user, constraint string, conValues []string) error

func DeleteResourceConstraint 

func DeleteResourceConstraint(resourceType, resourceConstraint string) error

func DeleteResourceOperation 

func DeleteResourceOperation(resourceType, resourceOperation string) error

func DeleteResourceType 

func DeleteResourceType(resourceType string) error

func DeleteUser 

func DeleteUser(user *models.User) error

func GatewayRouteListByBackend 

func GatewayRouteListByBackend(backend string) ([]*models.GatewayRouter, error)

func GenerateCasbinrules 

func GenerateCasbinrules(role string, operations []int64) error

func GetGatewayRoute 

func GetGatewayRoute(router, method string) (*models.GatewayRouter, error)

func GetGroupById 

func GetGroupById(id int64) (*models.Group, error)

func GetGroupByName 

func GetGroupByName(groupName string) (*models.Group, error)

func GetGroupDetailByName 

func GetGroupDetailByName(groupName string) (*models.Group, error)

func GetGroupRoleByName 

func GetGroupRoleByName(group, role string) (*models.GroupRole, error)

func GetGroupUserConstraint 

func GetGroupUserConstraint(group, user string) (map[string][]string, error)

func GetGroupUserConstraintWithFilter 

func GetGroupUserConstraintWithFilter(group, user string, constraintList []string) (map[string][]string, error)

func GetGroupUserRoles 

func GetGroupUserRoles(group, user string) ([]*models.UserGroupRole, error)

func GetOrmer 

func GetOrmer() orm.Ormer

GetOrmer :set ormer singleton

func GetProjectMemberByConstraint added in v1.5.0 

func GetProjectMemberByConstraint(projectId int64) ([]models.GroupUserConstraint, error)

GetProjectMemberByConstraint ..

func GetResourceConstraintList 

func GetResourceConstraintList(resourceType string) ([]string, error)

func GetResourceOperation 

func GetResourceOperation(resourceType, resourceOperation string) (*models.ResourceOperation, error)

func GetResourceOperationByIDs 

func GetResourceOperationByIDs(resourceItemIDs []int64) ([]*models.ResourceOperation, error)

func GetResourceOperationByResourceOperations 

func GetResourceOperationByResourceOperations(resourceOperations []string) ([]*models.ResourceOperation, error)

func GetResourceOperationByResourceTypes 

func GetResourceOperationByResourceTypes(resourceTypes []string) ([]*models.ResourceOperation, error)

func GetResourceOperationList 

func GetResourceOperationList() ([]*models.ResourceOperation, error)

func GetResourceRouterItems 

func GetResourceRouterItems(resourceType string, resourceOperations []string) ([]*models.GatewayRouter, error)

GetResourceRouterItems ..

func GetResourceType 

func GetResourceType(rt string) (*models.ResourceType, error)

func GetResourceTypeDetail 

func GetResourceTypeDetail(rt string, op, con []string) (*models.ResourceType, error)

func GetRoleOperationsByRoleName 

func GetRoleOperationsByRoleName(role string) ([]*models.GroupRoleOperation, error)

func GetUser 

func GetUser(userName string) (*models.User, error)

func GetUserByToken 

func GetUserByToken(token string) (*models.User, error)

func GetUserConstraintByKey 

func GetUserConstraintByKey(user string, constraintKey []string) (map[string][]string, error)

GetUserConstraintByKey ..

func GetUserDetail 

func GetUserDetail(userName string) (*models.User, error)

func GetUserList 

func GetUserList(userReq *models.UserReq) []*models.User

func GroupList 

func GroupList() ([]*models.Group, error)

func GroupListByFilter 

func GroupListByFilter(groups []string) ([]*models.Group, error)

func GroupListByUserId 

func GroupListByUserId(userId int64) ([]*models.Group, error)

func GroupRoleBundling 

func GroupRoleBundling(req *models.GroupRoleBundlingReq) error

func GroupRoleBundlingList 

func GroupRoleBundlingList(group, role string) ([]*models.GroupRoleBundlingUser, error)

组角色绑定用户

func GroupRoleList 

func GroupRoleList(group string) ([]*models.GroupRole, error)

组角色

func GroupRoleUnbundling 

func GroupRoleUnbundling(req *models.GroupRoleBundlingReq) error

func GroupUserList 

func GroupUserList(group string) ([]*models.GroupRoleUserRsp, error)

用户组关联用户

func InitGroupUser 

func InitGroupUser(user *models.User, group *models.Group, role string) error

InitGroupUser init user and role

func InitSystemMember 

func InitSystemMember(user *models.User) error

InitSystemMember create system user and role

func InsertGroup 

func InsertGroup(group *models.Group) (int64, error)

func InsertGroupUserRel 

func InsertGroupUserRel(groupId int64, userId int64) (int64, error)

func RemoveGroupUsers 

func RemoveGroupUsers(group string, users []string) error

func ResourceTypeList 

func ResourceTypeList() ([]*models.ResourceType, error)

资源类型

func ResourceTypeListFilter 

func ResourceTypeListFilter(resourceTypes []string) ([]*models.ResourceType, error)

func Transactional 

func Transactional(ormer orm.Ormer, handle func() error) (err error)

Transactional invoke lambda function within transaction

func UpdateGroup 

func UpdateGroup(groupName, description string) error

func UpdateGroupRole 

func UpdateGroupRole(req *models.GroupRoleReq) error

func UpdateGroupUserConstraintValues 

func UpdateGroupUserConstraintValues(group, user, constraint string, conValues []string) error

func UpdateResourceConstraint 

func UpdateResourceConstraint(resourceType, resourceConstraint, description string) error

func UpdateResourceOperation 

func UpdateResourceOperation(resourceType, resourceOperation, description string) error

func UpdateResourceType 

func UpdateResourceType(resourceType, description string) error

func UpdateUser 

func UpdateUser(user *models.User) error

func UserExist 

func UserExist(user string) bool

func UserIsAdmin 

func UserIsAdmin(userName string) bool

func UserList 

func UserList() ([]*models.User, error)

用户

Types

type AppArrangeModel 

type AppArrangeModel struct {
	AppArrangeTableName      string
	AppImageMappingTableName string
	// contains filtered or unexported fields
}

AppArrangeModel ...

func NewAppArrangeModel 

func NewAppArrangeModel() (model *AppArrangeModel)

NewAppArrangeModel ...

func (*AppArrangeModel) AppArrangeIsExisted 

func (model *AppArrangeModel) AppArrangeIsExisted(AppID int64, arrangeEnv string) bool

AppArrangeIsExisted check

func (*AppArrangeModel) DeleteAppArrange 

func (model *AppArrangeModel) DeleteAppArrange(AppID, envID int64) error

DeleteAppArrange ...

func (*AppArrangeModel) DeleteAppImageMapping 

func (model *AppArrangeModel) DeleteAppImageMapping(appImageMappingItem *models.AppImageMapping) error

DeleteAppImageMapping ...

func (*AppArrangeModel) GetAppArrange 

func (model *AppArrangeModel) GetAppArrange(appID, envID int64) (*models.AppArrange, error)

GetAppArrange ...

func (*AppArrangeModel) GetAppImageMappingByArrangeID 

func (model *AppArrangeModel) GetAppImageMappingByArrangeID(arrangeID int64) ([]*models.AppImageMapping, error)

GetAppImageMappingByArrangeID ...

func (*AppArrangeModel) GetAppImageMappingByArrangeIDAndProjectAppID 

func (model *AppArrangeModel) GetAppImageMappingByArrangeIDAndProjectAppID(arrangeID, projectAppID int64) (*models.AppImageMapping, error)

GetAppImageMappingByArrangeIDAndProjectAppID ...

func (*AppArrangeModel) GetAppImageMappingItemByID 

func (model *AppArrangeModel) GetAppImageMappingItemByID(id int64) (*models.AppImageMapping, error)

GetAppImageMappingItemByID ...

func (*AppArrangeModel) GetAppImageMappingItemByImage 

func (model *AppArrangeModel) GetAppImageMappingItemByImage(arrangeID int64, image string) (*models.AppImageMapping, error)

GetAppImageMappingItemByImage ..

func (*AppArrangeModel) GetInvalidAppImageMappingItems 

func (model *AppArrangeModel) GetInvalidAppImageMappingItems(arrangeID, projectAppID int64, validIDs []int64) ([]*models.AppImageMapping, error)

GetInvalidAppImageMappingItems ..

func (*AppArrangeModel) InsertAppArrange 

func (model *AppArrangeModel) InsertAppArrange(arrange *models.AppArrange) error

InsertOrUpdateAppArrange ...

func (*AppArrangeModel) InsertAppImageMapping 

func (model *AppArrangeModel) InsertAppImageMapping(appImageMappingItem *models.AppImageMapping) (int64, error)

InsertAppImageMapping ...

func (*AppArrangeModel) UpdateAppArrange 

func (model *AppArrangeModel) UpdateAppArrange(arrange *models.AppArrange) error

UpdateAppArrange ...

func (*AppArrangeModel) UpdateAppImageMapping 

func (model *AppArrangeModel) UpdateAppImageMapping(appImageMappingItem *models.AppImageMapping) error

UpdateAppImageMapping ...

type AppModel 

type AppModel struct {
	TableName string
	// contains filtered or unexported fields
}

func NewAppModel 

func NewAppModel() *AppModel

func (*AppModel) AppExist 

func (am *AppModel) AppExist(cluster, namespace, name string) bool

func (*AppModel) CreateApp 

func (am *AppModel) CreateApp(ins models.CaasApplication) error

func (*AppModel) DeleteApp 

func (am *AppModel) DeleteApp(app models.CaasApplication) error

func (*AppModel) GetAppByName 

func (am *AppModel) GetAppByName(cluster, namespace, name string) (*models.CaasApplication, error)

func (*AppModel) GetAppList 

func (am *AppModel) GetAppList(filterQuery *query.FilterQuery, projectID int64, cluster, namespace string) (*query.QueryResult, error)

func (*AppModel) GetImage 

func (am *AppModel) GetImage(cluster, namespace, name string) (string, error)

func (*AppModel) InsertApp 

func (am *AppModel) InsertApp(ins models.CaasApplication) error

func (*AppModel) SetDeployStatus 

func (am *AppModel) SetDeployStatus(cluster, namespace, name, status string) error

func (*AppModel) SetLabels 

func (am *AppModel) SetLabels(cluster, namespace, name, labels string) error

func (*AppModel) UpdateApp 

func (am *AppModel) UpdateApp(ins *models.CaasApplication, updateTime bool) error

type K8sClusterModel 

type K8sClusterModel struct {
	ApplicationTableName string
	NamespaceTableName   string
	// contains filtered or unexported fields
}

K8sClusterModel ...

func NewK8sClusterModel 

func NewK8sClusterModel() (model *K8sClusterModel)

NewK8sClusterModel ...

func (*K8sClusterModel) GetApplication 

func (model *K8sClusterModel) GetApplication(cluster, department, svcName string) ([]*models.CaasApplication, error)

GetApplication ...

func (*K8sClusterModel) GetApplicationsByProjectID 

func (model *K8sClusterModel) GetApplicationsByProjectID(projectID int64) ([]*models.CaasApplication, error)

GetApplicationsByProjectID ...

type PipelineStageModel 

type PipelineStageModel struct {
	PipelineTableName         string
	PipelineInstanceTableName string
	FlowComponentTableName    string
	TaskTmplTableName         string
	// contains filtered or unexported fields
}

PipelineStageModel ...

func NewPipelineStageModel 

func NewPipelineStageModel() (model *PipelineStageModel)

NewPipelineStageModel ...

func (*PipelineStageModel) CreateFlowComponent 

func (model *PipelineStageModel) CreateFlowComponent(comp *models.FlowComponent) error

CreateFlowComponent ...

func (*PipelineStageModel) CreatePipelineInstance 

func (model *PipelineStageModel) CreatePipelineInstance(pipeline *models.PipelineInstance) (int64, error)

CreatePipelineInstance ...

func (*PipelineStageModel) CreateTaskTmpl 

func (model *PipelineStageModel) CreateTaskTmpl(step *models.TaskTmpl) error

CreateTaskTmpl ...

func (*PipelineStageModel) DeleteTaskTmpl 

func (model *PipelineStageModel) DeleteTaskTmpl(stepID int64) error

DeleteTaskTmpl ..

func (*PipelineStageModel) GetFlowComponentByType 

func (model *PipelineStageModel) GetFlowComponentByType(componentType string) (*models.FlowComponent, error)

GetFlowComponentByType ..

func (*PipelineStageModel) GetFlowComponents 

func (model *PipelineStageModel) GetFlowComponents() ([]*models.FlowComponent, error)

GetFlowComponents ...

func (*PipelineStageModel) GetPipelineInstanceConfigByID 

func (model *PipelineStageModel) GetPipelineInstanceConfigByID(id int64) (*models.PipelineInstance, error)

GetPipelineInstanceConfigByID ..

func (*PipelineStageModel) GetTaskTmplByID 

func (model *PipelineStageModel) GetTaskTmplByID(stepID int64) (*models.TaskTmpl, error)

GetTaskTmplByID ...

func (*PipelineStageModel) GetTaskTmplByName 

func (model *PipelineStageModel) GetTaskTmplByName(name string) (*models.TaskTmpl, error)

GetTaskTmplByName ...

func (*PipelineStageModel) GetTaskTmpls 

func (model *PipelineStageModel) GetTaskTmpls() ([]*models.TaskTmpl, error)

GetTaskTmpls ...

func (*PipelineStageModel) GetTaskTmplsByPagination 

func (model *PipelineStageModel) GetTaskTmplsByPagination(filter *query.FilterQuery) ([]*models.TaskTmpl, int64, error)

GetTaskTmplsByPagination ..

func (*PipelineStageModel) UpdateTaskTmpl 

func (model *PipelineStageModel) UpdateTaskTmpl(step *models.TaskTmpl) error

UpdateTaskTmpl ..

type ProjectModel 

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

ProjectModel ...

func NewProjectModel 

func NewProjectModel() (model *ProjectModel)

NewProjectModel ...

func (*ProjectModel) CreatePipeline 

func (model *ProjectModel) CreatePipeline(pipeline *models.ProjectPipeline) (int64, error)

CreatePipeline ...

func (*ProjectModel) CreateProjectAppIfNotExist 

func (model *ProjectModel) CreateProjectAppIfNotExist(app *models.ProjectApp) (int64, error)

CreateProjectAppIfNotExist ...

func (*ProjectModel) CreateProjectEnv 

func (model *ProjectModel) CreateProjectEnv(stage *models.ProjectEnv) error

CreateProjectEnv ...

func (*ProjectModel) CreateProjectUserIfNotExist 

func (model *ProjectModel) CreateProjectUserIfNotExist(user *models.ProjectUser) (int64, error)

CreateProjectUserIfNotExist ...

func (*ProjectModel) CreateProjectifNotExist 

func (model *ProjectModel) CreateProjectifNotExist(project *models.Project) (int64, error)

CreateProjectifNotExist ...

func (*ProjectModel) DeleteProject 

func (model *ProjectModel) DeleteProject(projectID int64) error

DeleteProject ...

func (*ProjectModel) DeleteProjectApp 

func (model *ProjectModel) DeleteProjectApp(projectAppID int64) error

DeleteProjectApp ...

func (*ProjectModel) DeleteProjectEnv 

func (model *ProjectModel) DeleteProjectEnv(stageID int64) error

DeleteProjectEnv ..

func (*ProjectModel) DeleteProjectUser 

func (model *ProjectModel) DeleteProjectUser(user *models.ProjectUser) error

DeleteProjectUser ...

func (*ProjectModel) GetDefaultPipeline 

func (model *ProjectModel) GetDefaultPipeline(projectID int64) (*models.ProjectPipeline, error)

GetDefaultPipeline ..

func (*ProjectModel) GetPipelinesByPagination 

func (model *ProjectModel) GetPipelinesByPagination(filter *query.FilterQuery, projectID int64) (*query.QueryResult, error)

GetPipelinesByPagination ..

func (*ProjectModel) GetProjectApp 

func (model *ProjectModel) GetProjectApp(projectAppID int64) (*models.ProjectApp, error)

GetProjectApp ...

func (*ProjectModel) GetProjectAppByScmID added in v1.5.0 

func (model *ProjectModel) GetProjectAppByScmID(projectID, scmID int64) (*models.ProjectApp, error)

GetProjectApp ...

func (*ProjectModel) GetProjectAppCounts 

func (model *ProjectModel) GetProjectAppCounts(projectID int64) (int64, error)

GetProjectAppCounts ..

func (*ProjectModel) GetProjectApps 

func (model *ProjectModel) GetProjectApps(projectID int64) ([]*models.ProjectApp, error)

GetProjectApps ...

func (*ProjectModel) GetProjectAppsByIDs 

func (model *ProjectModel) GetProjectAppsByIDs(projectID int64, projectAppIDs []int64) ([]*models.ProjectApp, error)

GetProjectAppsByIDs ...

func (*ProjectModel) GetProjectAppsList 

func (model *ProjectModel) GetProjectAppsList(projectID int64, filter *models.ProejctAppFilterQuery) (*query.QueryResult, []*models.ProjectApp, error)

GetProjectAppsList ..

func (*ProjectModel) GetProjectByID 

func (model *ProjectModel) GetProjectByID(projectID int64) (*models.Project, error)

GetProjectByID ...

func (*ProjectModel) GetProjectByProjectName 

func (model *ProjectModel) GetProjectByProjectName(name string) (*models.Project, error)

GetProjectByProjectName ...

func (*ProjectModel) GetProjectEnvByID 

func (model *ProjectModel) GetProjectEnvByID(stageID int64) (*models.ProjectEnv, error)

func (*ProjectModel) GetProjectEnvBycIDAndEnvTag 

func (model *ProjectModel) GetProjectEnvBycIDAndEnvTag(env string, projectID int64) (*models.ProjectEnv, error)

GetProjectEnvBycIDAndEnvTag ..

func (*ProjectModel) GetProjectEnvs 

func (model *ProjectModel) GetProjectEnvs(projectID int64) ([]*models.ProjectEnv, error)

GetProjectEnvs ...

func (*ProjectModel) GetProjectEnvsByPagination 

func (model *ProjectModel) GetProjectEnvsByPagination(filter *query.FilterQuery, projectID int64) (*query.QueryResult, error)

GetProjectEnvsByPagination ..

func (*ProjectModel) GetProjectPipelineByID 

func (model *ProjectModel) GetProjectPipelineByID(pipelineID int64) (*models.ProjectPipeline, error)

GetProjectPipelineByID ...

func (*ProjectModel) GetProjectPipelines 

func (model *ProjectModel) GetProjectPipelines(projectID int64) ([]*models.ProjectPipeline, error)

GetProjectPipelines ...

func (*ProjectModel) GetProjectUserByID 

func (model *ProjectModel) GetProjectUserByID(nubmerID int64) (*models.ProjectUser, error)

GetProjectUserByID ..

func (*ProjectModel) GetProjectUserByRoleType 

func (model *ProjectModel) GetProjectUserByRoleType(projectID int64, roleType string) ([]*models.ProjectUser, error)

GetProjectUserByRoleType ..

func (*ProjectModel) GetProjectUsers 

func (model *ProjectModel) GetProjectUsers(projectID int64) ([]*models.ProjectUser, error)

GetProjectUsers ..

func (*ProjectModel) GetProjectUsersByRoleTypeAndUserName 

func (model *ProjectModel) GetProjectUsersByRoleTypeAndUserName(projectID int64, roleType string, userNames []string) ([]*models.ProjectUser, error)

GetProjectUsersByRoleTypeAndUserName ..

func (*ProjectModel) GetProjectUsersByRoles 

func (model *ProjectModel) GetProjectUsersByRoles(projectID int64, roleTypes []string) ([]*models.ProjectUser, error)

GetProjectUsersByRoles ..

func (*ProjectModel) GetProjects 

func (model *ProjectModel) GetProjects() ([]*models.Project, error)

GetProjects ...

func (*ProjectModel) ProjectListByIDs 

func (model *ProjectModel) ProjectListByIDs(projectID []int64, filter *models.ProejctFilterQuery) (*query.QueryResult, []*models.Project, error)

ProjectListByIDs ...

func (*ProjectModel) UpdateProject 

func (model *ProjectModel) UpdateProject(project *models.Project) error

UpdateProject ...

func (*ProjectModel) UpdateProjectApp 

func (model *ProjectModel) UpdateProjectApp(projectApp *models.ProjectApp) error

UpdateProjectApp ...

func (*ProjectModel) UpdateProjectEnv 

func (model *ProjectModel) UpdateProjectEnv(stage *models.ProjectEnv) error

UpdateProjectEnv ..

func (*ProjectModel) UpdateProjectPipeline 

func (model *ProjectModel) UpdateProjectPipeline(pp *models.ProjectPipeline) error

UpdateProjectPipeline ...

func (*ProjectModel) UpdateProjectUser 

func (model *ProjectModel) UpdateProjectUser(user *models.ProjectUser) error

UpdateProjectUser ..

type PublishJobModel 

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

PublishJobModel ...

func NewPublishJobModel 

func NewPublishJobModel() (model *PublishJobModel)

NewPublishJobModel ...

func (*PublishJobModel) CreateJobAppIfNotExist 

func (model *PublishJobModel) CreateJobAppIfNotExist(app *models.PublishJobApp) (int64, error)

CreateJobAppIfNotExist ...

func (*PublishJobModel) CreatePublishJobifNotExist 

func (model *PublishJobModel) CreatePublishJobifNotExist(publishJob *models.PublishJob) (int64, error)

CreatePublishJobifNotExist ...

func (*PublishJobModel) GetCurrentRunningBuildJob 

func (model *PublishJobModel) GetCurrentRunningBuildJob(projectID, stageID, publishID int64, status []string, jobType string) ([]*models.PublishJob, error)

GetCurrentRunningBuildJob For Trigger publishOrder build verify, running job include init and running

func (*PublishJobModel) GetCurrentRunningJob 

func (model *PublishJobModel) GetCurrentRunningJob(projectID, stageID int64, status []string, jobType string) ([]*models.PublishJob, error)

GetCurrentRunningJob For Trigger publishOrder publish verify, running job include init and running

func (*PublishJobModel) GetLastPublishJobByPublishID 

func (model *PublishJobModel) GetLastPublishJobByPublishID(publishID int64) (*models.PublishJob, error)

GetLastPublishJobByPublishID ..

func (*PublishJobModel) GetPublishJobApp 

func (model *PublishJobModel) GetPublishJobApp(publishJobID, AppID int64) (*models.PublishJobApp, error)

GetPublishJobApp ..

func (*PublishJobModel) GetPublishJobAppByID 

func (model *PublishJobModel) GetPublishJobAppByID(ID int64) (*models.PublishJobApp, error)

GetPublishJobAppByID ..

func (*PublishJobModel) GetPublishJobApps 

func (model *PublishJobModel) GetPublishJobApps(publishJobID int64) ([]*models.PublishJobApp, error)

GetPublishJobApps ..

func (*PublishJobModel) GetPublishJobByID 

func (model *PublishJobModel) GetPublishJobByID(ID int64) (*models.PublishJob, error)

GetPublishJobByID ..

func (*PublishJobModel) GetPublishJobByProjectIDFilters 

func (model *PublishJobModel) GetPublishJobByProjectIDFilters(projectID int64, appIDs, envIDs []int64) (orm.QuerySeter, error)

GetPublishJobByProjectIDFilters ..

func (*PublishJobModel) GetPublishJobByStageID 

func (model *PublishJobModel) GetPublishJobByStageID(projectID, stageID int64) ([]*models.PublishJob, error)

GetPublishJobByStageID ..

func (*PublishJobModel) GetPublishJobsByFilter 

func (model *PublishJobModel) GetPublishJobsByFilter(status []string, jobType []string) ([]*models.PublishJob, error)

GetPublishJobsByFilter For PublishJob Serer sync publish/publish job status

func (*PublishJobModel) UpdatePublishJob 

func (model *PublishJobModel) UpdatePublishJob(publishjob *models.PublishJob) error

UpdatePublishJob ...

func (*PublishJobModel) UpdatePublishJobApp 

func (model *PublishJobModel) UpdatePublishJobApp(publishJobApp *models.PublishJobApp) error

UpdatePublishJobApp ...

type PublishModel 

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

PublishModel ...

func NewPublishModel 

func NewPublishModel() (model *PublishModel)

NewPublishModel ...

func (*PublishModel) CreatePublishAppIfNotExist 

func (model *PublishModel) CreatePublishAppIfNotExist(app *models.PublishApp) (int64, error)

CreatePublishAppIfNotExist ...

func (*PublishModel) CreatePublishOperation 

func (model *PublishModel) CreatePublishOperation(item *models.PublishOperationLog) error

CreatePublishOperation ...

func (*PublishModel) CreatePublishifNotExist 

func (model *PublishModel) CreatePublishifNotExist(publish *models.Publish) (int64, error)

CreatePublishifNotExist ...

func (*PublishModel) DeletePublish 

func (model *PublishModel) DeletePublish(publishID int64) error

DeletePublish ...

func (*PublishModel) DeletePublishApp 

func (model *PublishModel) DeletePublishApp(publishAppID int64) error

DeletePublishApp ...

func (*PublishModel) GetOperationLogByInstanceIDAndStageIDStepType 

func (model *PublishModel) GetOperationLogByInstanceIDAndStageIDStepType(instanceID, stageID int64, stepType int) ([]*models.PublishOperationLog, error)

GetOperationLogByInstanceIDAndStageIDStepType ...

func (*PublishModel) GetOperationLogsByPublishID 

func (model *PublishModel) GetOperationLogsByPublishID(publishID int64, filter *query.FilterQuery) (*query.QueryResult, error)

GetOperationLogsByPublishID ...

func (*PublishModel) GetPublishApp 

func (model *PublishModel) GetPublishApp(publishAppID int64) (*models.PublishApp, error)

GetPublishApp ...

func (*PublishModel) GetPublishAppByPublishIDAndAppID 

func (model *PublishModel) GetPublishAppByPublishIDAndAppID(publishID, appID int64) (*models.PublishApp, error)

GetPublishAppByPublishIDAndAppID ..

func (*PublishModel) GetPublishAppsByID 

func (model *PublishModel) GetPublishAppsByID(publishID int64) ([]*models.PublishApp, error)

GetPublishAppsByID ..

func (*PublishModel) GetPublishByID 

func (model *PublishModel) GetPublishByID(publishID int64) (*models.Publish, error)

GetPublishByID ...

func (*PublishModel) GetPublishByPipelineInstanceID 

func (model *PublishModel) GetPublishByPipelineInstanceID(pipelineInstanceID int64) (*models.Publish, error)

GetPublishByPipelineInstanceID ...

func (*PublishModel) GetPublishReleasesByProjectID 

func (model *PublishModel) GetPublishReleasesByProjectID(projectID int64) (interface{}, error)

GetPublishReleasesByProjectID ..

func (*PublishModel) GetPublishUnEndBystatus 

func (model *PublishModel) GetPublishUnEndBystatus(status []int64, projectIDs []int64) ([]*models.Publish, error)

GetPublishUnEndBystatus ...

func (*PublishModel) GetPublishesList 

func (model *PublishModel) GetPublishesList(projectID int64, filter *models.ProejctReleaseFilterQuery) (*query.QueryResult, []*models.Publish, error)

GetPublishesList ...

func (*PublishModel) GetRunninbPublishesByProjectID 

func (model *PublishModel) GetRunninbPublishesByProjectID(projectID int64) ([]*models.Publish, error)

GetRunninbPublishesByProjectID ..

func (*PublishModel) UpdatePublish 

func (model *PublishModel) UpdatePublish(publish *models.Publish) error

UpdatePublish ...

func (*PublishModel) UpdatePublishApp 

func (model *PublishModel) UpdatePublishApp(publishApp *models.PublishApp) error

UpdatePublishApp ...

type ScmAppModel added in v1.5.0 

type ScmAppModel struct {
	AppBranchTableName string
	// contains filtered or unexported fields
}

ScmAppModel ...

func NewScmAppModel added in v1.5.0 

func NewScmAppModel() (model *ScmAppModel)

NewGitAppModel ...

func (*ScmAppModel) CreateAppBranchIfNotExist added in v1.5.0 

func (model *ScmAppModel) CreateAppBranchIfNotExist(branch *models.AppBranch) (int64, error)

CreateAppBranchIfNotExist ...

func (*ScmAppModel) CreateScmAppIfNotExist added in v1.5.0 

func (model *ScmAppModel) CreateScmAppIfNotExist(app *models.ScmApp) (int64, error)

CreateProjectAppIfNotExist ...

func (*ScmAppModel) DeleteSCMApp added in v1.5.0 

func (model *ScmAppModel) DeleteSCMApp(scmAppID int64) error

DeleteProjectApp ...

func (*ScmAppModel) GetAppBranchByName added in v1.5.0 

func (model *ScmAppModel) GetAppBranchByName(appID int64, branchName string) (*models.AppBranch, error)

GetAppBranchByName ...

func (*ScmAppModel) GetAppBranches added in v1.5.0 

func (model *ScmAppModel) GetAppBranches(appID int64) ([]*models.AppBranch, error)

GetAppBranches ...

func (*ScmAppModel) GetAppBranchesByPagination added in v1.5.0 

func (model *ScmAppModel) GetAppBranchesByPagination(appID int64, filter *query.FilterQuery) (*query.QueryResult, error)

GetAppBranchesByPagination ...

func (*ScmAppModel) GetScmAppByID added in v1.5.0 

func (model *ScmAppModel) GetScmAppByID(appID int64) (*models.ScmApp, error)

func (*ScmAppModel) GetScmApps added in v1.5.0 

func (model *ScmAppModel) GetScmApps() ([]*models.ScmApp, error)

func (*ScmAppModel) GetScmAppsByPagination added in v1.5.0 

func (model *ScmAppModel) GetScmAppsByPagination(filter *query.FilterQuery) (*query.QueryResult, error)

GetCompileEnvsByPagination ..

func (*ScmAppModel) SoftDeleteAppBranch added in v1.5.0 

func (model *ScmAppModel) SoftDeleteAppBranch(branch *models.AppBranch) error

SoftDeleteAppBranch ...

func (*ScmAppModel) UpdateAppBranch added in v1.5.0 

func (model *ScmAppModel) UpdateAppBranch(branch *models.AppBranch) error

UpdateAppBranch ...

func (*ScmAppModel) UpdateSCMApp added in v1.5.0 

func (model *ScmAppModel) UpdateSCMApp(scmApp *models.ScmApp) error

UpdateProjectApp ...

type SysSettingModel 

type SysSettingModel struct {
	IntegrateSettingTableName string
	CompileEnvTableName       string
	// contains filtered or unexported fields
}

SysSettingModel ...

func NewSysSettingModel 

func NewSysSettingModel() (model *SysSettingModel)

NewSysSettingModel ...

func (*SysSettingModel) CreateCompileEnv 

func (model *SysSettingModel) CreateCompileEnv(integrateSetting *models.CompileEnv) error

CreateCompileEnv ...

func (*SysSettingModel) CreateIntegrateSetting 

func (model *SysSettingModel) CreateIntegrateSetting(integrateSetting *models.IntegrateSetting) error

CreateIntegrateSetting ...

func (*SysSettingModel) DeleteCompileEnv 

func (model *SysSettingModel) DeleteCompileEnv(integrateSettingID int64) error

DeleteCompileEnv ..

func (*SysSettingModel) DeleteIntegrateSetting 

func (model *SysSettingModel) DeleteIntegrateSetting(integrateSettingID int64) error

DeleteIntegrateSetting ..

func (*SysSettingModel) GetCompileEnvByID 

func (model *SysSettingModel) GetCompileEnvByID(integrateSettingID int64) (*models.CompileEnv, error)

GetCompileEnvByID ...

func (*SysSettingModel) GetCompileEnvByName 

func (model *SysSettingModel) GetCompileEnvByName(compileEnvItem string) (*models.CompileEnv, error)

GetCompileEnvByName ...

func (*SysSettingModel) GetCompileEnvs 

func (model *SysSettingModel) GetCompileEnvs(integrateType string) ([]*models.CompileEnv, error)

GetCompileEnvs ...

func (*SysSettingModel) GetCompileEnvsByPagination 

func (model *SysSettingModel) GetCompileEnvsByPagination(filter *query.FilterQuery) (*query.QueryResult, []*models.CompileEnv, error)

GetCompileEnvsByPagination ..

func (*SysSettingModel) GetIntegrateSettingByID 

func (model *SysSettingModel) GetIntegrateSettingByID(integrateSettingID int64) (*models.IntegrateSetting, error)

GetIntegrateSettingByID ...

func (*SysSettingModel) GetIntegrateSettingByName added in v1.5.0 

func (model *SysSettingModel) GetIntegrateSettingByName(name, integrateType string) (*models.IntegrateSetting, error)

func (*SysSettingModel) GetIntegrateSettings 

func (model *SysSettingModel) GetIntegrateSettings(integrateTypes []string) ([]*models.IntegrateSetting, error)

GetIntegrateSettings ...

func (*SysSettingModel) GetIntegrateSettingsByPagination 

func (model *SysSettingModel) GetIntegrateSettingsByPagination(filter *query.FilterQuery, intergrateTypes []string) (*query.QueryResult, []*models.IntegrateSetting, error)

GetIntegrateSettingsByPagination ..

func (*SysSettingModel) UpdateCompileEnv 

func (model *SysSettingModel) UpdateCompileEnv(integrateSetting *models.CompileEnv) error

UpdateCompileEnv ..

func (*SysSettingModel) UpdateIntegrateSetting 

func (model *SysSettingModel) UpdateIntegrateSetting(integrateSetting *models.IntegrateSetting) error

UpdateIntegrateSetting ..

type TemplateModel 

type TemplateModel struct {
	TableName string
	// contains filtered or unexported fields
}

func NewTemplateModel 

func NewTemplateModel() *TemplateModel

func (*TemplateModel) CreateTemplate 

func (tm *TemplateModel) CreateTemplate(template models.CaasTemplate) (*models.CaasTemplate, error)

func (*TemplateModel) DeleteTemplate 

func (tm *TemplateModel) DeleteTemplate(namespace, name string) error

func (*TemplateModel) GetTemplate 

func (tm *TemplateModel) GetTemplate(namespace, name string) (*models.CaasTemplate, error)

func (*TemplateModel) GetTemplateByID 

func (tm *TemplateModel) GetTemplateByID(templateId int64) (*models.CaasTemplate, error)

func (*TemplateModel) UpdateTemplate 

func (tm *TemplateModel) UpdateTemplate(template models.CaasTemplate) error

type UserResourceConstraintValues 

type UserResourceConstraintValues struct {
	Values []map[string][]string `json:"values"`
}

func GetUserResourceConstraintValues 

func GetUserResourceConstraintValues(resourceType, user string) (UserResourceConstraintValues, error)

GetUserResourceConstraintValues ..

type UserRolesModel 

type UserRolesModel struct {
	GroupRoleTableName string
	UserName           string
	// contains filtered or unexported fields
}

UserRolesModel ...

func NewUserRolesModel 

func NewUserRolesModel() (model *UserRolesModel)

NewUserRolesModel ...

func (*UserRolesModel) GetRoleByID 

func (model *UserRolesModel) GetRoleByID(roleID int64) (*models.GroupRole, error)

GetRoleByID ...

func (*UserRolesModel) GetRoleByName 

func (model *UserRolesModel) GetRoleByName(group, name string) (*models.GroupRole, error)

GetRoleByName ...

func (*UserRolesModel) GetUserByName 

func (model *UserRolesModel) GetUserByName(name string) (*models.User, error)

GetUserByName ...

func (*UserRolesModel) GetUserByToken 

func (model *UserRolesModel) GetUserByToken(token string) (*models.User, error)

GetUserByToken ...

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.