Versions in this module Expand all Collapse all v1 v1.0.1 Aug 15, 2024 Changes in this version + const BranchPrefix + const CreateProjectPipelineNamePreCheckLocaleKey + const CreateProjectPipelineSourcePreCheckLocaleKey + const DefaultCategory + const InitCommitID + const StarCategory + func MakeProjectPipelineName(pipelineYml string, fileName string) string + type AutoRunParams struct + type CategoryType string + func (c CategoryType) String() string + type ErdaProjectSourceType struct + PipelineCreateRequestV2 string + func (s *ErdaProjectSourceType) GeneratePipelineCreateRequestV2(ctx context.Context, p *ProjectPipelineService, ...) (*pipelinepb.PipelineCreateRequestV2, error) + func (s *ErdaProjectSourceType) GenerateReq(ctx context.Context, p *ProjectPipelineService, ...) (*spb.PipelineSourceCreateRequest, error) + func (s *ErdaProjectSourceType) GetPipelineCreateRequestV2() string + type GithubProjectSourceType struct + PipelineCreateRequestV2 string + func (s *GithubProjectSourceType) GeneratePipelineCreateRequestV2(ctx context.Context, p *ProjectPipelineService, ...) (*pipelinepb.PipelineCreateRequestV2, error) + func (s *GithubProjectSourceType) GenerateReq(ctx context.Context, p *ProjectPipelineService, ...) (*spb.PipelineSourceCreateRequest, error) + func (s *GithubProjectSourceType) GetPipelineCreateRequestV2() string + type PipelineStatisticsByCategory struct + Category string + Key apistructs.PipelineCategory + Rules []string + type PipelineStatisticsNums struct + FailedNum uint64 + RunningNum uint64 + TotalNum uint64 + type ProjectPipelineService struct + GuideSvc guidepb.GuideServiceServer + Permission *permission.Permission + PipelineCms cmspb.CmsServiceServer + PipelineCron cronpb.CronServiceServer + PipelineDefinition dpb.DefinitionServiceServer + PipelineSource sourcepb.SourceServiceServer + func (e *ProjectPipelineService) UpdateCmsNsConfigs(userID string, orgID uint64) error + func (p *ProjectPipelineService) BatchCreateByGittarPushHook(ctx context.Context, params *pb.GittarPushPayloadEvent) (*pb.BatchCreateProjectPipelineResponse, error) + func (p *ProjectPipelineService) BatchRun(ctx context.Context, params deftype.ProjectPipelineBatchRun) (*deftype.ProjectPipelineBatchRunResult, error) + func (p *ProjectPipelineService) Cancel(ctx context.Context, params *pb.CancelProjectPipelineRequest) (*pb.CancelProjectPipelineResponse, error) + func (p *ProjectPipelineService) CheckBranchRule(branch string, projectID int64) (bool, error) + func (p *ProjectPipelineService) Create(ctx context.Context, params *pb.CreateProjectPipelineRequest) (*pb.CreateProjectPipelineResponse, error) + func (p *ProjectPipelineService) CreateNamePreCheck(ctx context.Context, req *pb.CreateProjectPipelineNamePreCheckRequest) (*pb.CreateProjectPipelineNamePreCheckResponse, error) + func (p *ProjectPipelineService) CreateOne(ctx context.Context, params *pb.CreateProjectPipelineRequest) (*pb.ProjectPipeline, error) + func (p *ProjectPipelineService) CreateSourcePreCheck(ctx context.Context, params *pb.CreateProjectPipelineSourcePreCheckRequest) (*pb.CreateProjectPipelineSourcePreCheckResponse, error) + func (p *ProjectPipelineService) Delete(ctx context.Context, params deftype.ProjectPipelineDelete) (*deftype.ProjectPipelineDeleteResult, error) + func (p *ProjectPipelineService) DeleteByApp(ctx context.Context, params *pb.DeleteByAppRequest) (*pb.DeleteByAppResponse, error) + func (p *ProjectPipelineService) EndCron(ctx context.Context, params deftype.ProjectPipelineEndCron) (*deftype.ProjectPipelineEndCronResult, error) + func (p *ProjectPipelineService) GetRemotesByAppID(appID uint64, orgName, projectName string) ([]string, error) + func (p *ProjectPipelineService) IdempotentCreateOne(ctx context.Context, params *pb.CreateProjectPipelineRequest) (*pb.ProjectPipeline, error) + func (p *ProjectPipelineService) List(ctx context.Context, params deftype.ProjectPipelineList) ([]*dpb.PipelineDefinition, int64, error) + func (p *ProjectPipelineService) ListApp(ctx context.Context, params *pb.ListAppRequest) (*pb.ListAppResponse, error) + func (p *ProjectPipelineService) ListExecHistory(ctx context.Context, params *pb.ListPipelineExecHistoryRequest) (*pb.ListPipelineExecHistoryResponse, error) + func (p *ProjectPipelineService) ListPipelineCategory(ctx context.Context, params *pb.ListPipelineCategoryRequest) (*pb.ListPipelineCategoryResponse, error) + func (p *ProjectPipelineService) ListPipelineStatisticsByCategory(ctx context.Context) []PipelineStatisticsByCategory + func (p *ProjectPipelineService) ListUsedRefs(ctx context.Context, params deftype.ProjectPipelineUsedRefList) ([]string, error) + func (p *ProjectPipelineService) OneClickCreate(ctx context.Context, params *pb.OneClickCreateProjectPipelineRequest) (*pb.OneClickCreateProjectPipelineResponse, error) + func (p *ProjectPipelineService) Rerun(ctx context.Context, params *pb.RerunProjectPipelineRequest) (*pb.RerunProjectPipelineResponse, error) + func (p *ProjectPipelineService) RerunFailed(ctx context.Context, params *pb.RerunFailedProjectPipelineRequest) (*pb.RerunFailedProjectPipelineResponse, error) + func (p *ProjectPipelineService) Run(ctx context.Context, params *pb.RunProjectPipelineRequest) (*pb.RunProjectPipelineResponse, error) + func (p *ProjectPipelineService) SetPrimary(ctx context.Context, params deftype.ProjectPipelineCategory) (*dpb.PipelineDefinitionUpdateResponse, error) + func (p *ProjectPipelineService) StartCron(ctx context.Context, params deftype.ProjectPipelineStartCron) (*deftype.ProjectPipelineStartCronResult, error) + func (p *ProjectPipelineService) TryAddRunningPipelineLinkToErr(orgName string, projectID uint64, appID uint64, err error) (error, bool) + func (p *ProjectPipelineService) UnSetPrimary(ctx context.Context, params deftype.ProjectPipelineCategory) (*dpb.PipelineDefinitionUpdateResponse, error) + func (p *ProjectPipelineService) Update(ctx context.Context, params *pb.UpdateProjectPipelineRequest) (*pb.UpdateProjectPipelineResponse, error) + func (p *ProjectPipelineService) WithBranchRuleSve(svc *branchrule.BranchRule) + func (p *ProjectPipelineService) WithPermissionSvc(permission *permission.Permission) + func (p *ProjectPipelineService) WithPipelineService(svc pipelinepb.PipelineServiceServer) + func (p *ProjectPipelineService) WithPipelineSvc(svc *pipeline.Pipeline) + func (s *ProjectPipelineService) GetPipelineYml(app *apistructs.ApplicationDTO, userID string, branch string, findPath string) ([]*pb.PipelineYmlList, error) + func (s *ProjectPipelineService) ListPipelineYml(ctx context.Context, req *pb.ListAppPipelineYmlRequest) (*pb.ListAppPipelineYmlResponse, error) + func (s *ProjectPipelineService) ListPipelineYmlByApp(app *apistructs.ApplicationDTO, branch, userID string) ([]*pb.PipelineYmlList, error) + type ProjectSourceType interface + GeneratePipelineCreateRequestV2 func(ctx context.Context, p *ProjectPipelineService, ...) (*pipelinepb.PipelineCreateRequestV2, error) + GenerateReq func(ctx context.Context, p *ProjectPipelineService, ...) (*spb.PipelineSourceCreateRequest, error) + GetPipelineCreateRequestV2 func() string + func NewProjectSourceType(t string) ProjectSourceType + type RemoteName struct + AppName string + OrgName string + ProjectName string + type Service interface + BatchCreateByGittarPushHook func(ctx context.Context, params *pb.GittarPushPayloadEvent) (*pb.BatchCreateProjectPipelineResponse, error) + BatchRun func(ctx context.Context, params deftype.ProjectPipelineBatchRun) (*deftype.ProjectPipelineBatchRunResult, error) + Cancel func(ctx context.Context, params *pb.CancelProjectPipelineRequest) (*pb.CancelProjectPipelineResponse, error) + Create func(ctx context.Context, params *pb.CreateProjectPipelineRequest) (*pb.CreateProjectPipelineResponse, error) + CreateNamePreCheck func(ctx context.Context, req *pb.CreateProjectPipelineNamePreCheckRequest) (*pb.CreateProjectPipelineNamePreCheckResponse, error) + CreateSourcePreCheck func(ctx context.Context, req *pb.CreateProjectPipelineSourcePreCheckRequest) (*pb.CreateProjectPipelineSourcePreCheckResponse, error) + Delete func(ctx context.Context, params deftype.ProjectPipelineDelete) (*deftype.ProjectPipelineDeleteResult, error) + DeleteByApp func(ctx context.Context, params *pb.DeleteByAppRequest) (*pb.DeleteByAppResponse, error) + EndCron func(ctx context.Context, params deftype.ProjectPipelineEndCron) (*deftype.ProjectPipelineEndCronResult, error) + List func(ctx context.Context, params deftype.ProjectPipelineList) ([]*dpb.PipelineDefinition, int64, error) + ListApp func(ctx context.Context, params *pb.ListAppRequest) (*pb.ListAppResponse, error) + ListExecHistory func(ctx context.Context, params *pb.ListPipelineExecHistoryRequest) (*pb.ListPipelineExecHistoryResponse, error) + ListPipelineYml func(ctx context.Context, req *pb.ListAppPipelineYmlRequest) (*pb.ListAppPipelineYmlResponse, error) + ListUsedRefs func(ctx context.Context, params deftype.ProjectPipelineUsedRefList) ([]string, error) + OneClickCreate func(ctx context.Context, params *pb.OneClickCreateProjectPipelineRequest) (*pb.OneClickCreateProjectPipelineResponse, error) + Rerun func(ctx context.Context, params *pb.RerunProjectPipelineRequest) (*pb.RerunProjectPipelineResponse, error) + RerunFailed func(ctx context.Context, params *pb.RerunFailedProjectPipelineRequest) (*pb.RerunFailedProjectPipelineResponse, error) + Run func(ctx context.Context, params *pb.RunProjectPipelineRequest) (*pb.RunProjectPipelineResponse, error) + SetPrimary func(ctx context.Context, params deftype.ProjectPipelineCategory) (*dpb.PipelineDefinitionUpdateResponse, error) + StartCron func(ctx context.Context, params deftype.ProjectPipelineStartCron) (*deftype.ProjectPipelineStartCronResult, error) + UnSetPrimary func(ctx context.Context, params deftype.ProjectPipelineCategory) (*dpb.PipelineDefinitionUpdateResponse, error) + Update func(ctx context.Context, params *pb.UpdateProjectPipelineRequest) (*pb.UpdateProjectPipelineResponse, error)
Go to main page