flow

package
v1.0.1 Latest Latest
Warning

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

 Go to latest Published: Aug 15, 2024 License: Apache-2.0 Imports: 38 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	MultiBranchBranchType  = "multi_branch"
	SingleBranchBranchType = "single_branch"
)

Variables

This section is empty.

Functions

This section is empty.

Types

type CreateFlowRequest 

type CreateFlowRequest struct {
	Data      *pb.FlowEventData
	ProjectID uint64
	AppID     uint64
	OrgID     uint64
}

type IssueMock 

type IssueMock struct{}

func (IssueMock) AfterIssueAppRelationCreate 

func (i IssueMock) AfterIssueAppRelationCreate(issueIDs []int64) error

func (IssueMock) AfterIssueInclusionRelationChange 

func (i IssueMock) AfterIssueInclusionRelationChange(id uint64) error

func (IssueMock) AfterIssueUpdate 

func (i IssueMock) AfterIssueUpdate(u *query.IssueUpdated) error

func (IssueMock) BatchGetIssue 

func (i IssueMock) BatchGetIssue(id []int64, identityInfo *commonpb.IdentityInfo) ([]*issuepb.Issue, error)

func (IssueMock) BatchGetIssuePropertyInstances 

func (i IssueMock) BatchGetIssuePropertyInstances(orgID int64, projectID uint64, issueType string, issueIDs []uint64) (map[uint64]*issuepb.IssueAndPropertyAndValue, error)

func (IssueMock) BatchGetProperties 

func (i IssueMock) BatchGetProperties(orgID int64, issuesType []string) ([]*issuepb.IssuePropertyIndex, error)

func (IssueMock) BatchUpdateIssue 

func (i IssueMock) BatchUpdateIssue(req *issuepb.BatchUpdateIssueRequest) error

func (IssueMock) CreatePropertyRelation 

func (i IssueMock) CreatePropertyRelation(req *issuepb.CreateIssuePropertyInstanceRequest) error

func (IssueMock) GetAllIssuesByProject 

func (i IssueMock) GetAllIssuesByProject(req issuepb.IssueListRequest) ([]dao.IssueItem, error)

func (IssueMock) GetBatchProperties 

func (i IssueMock) GetBatchProperties(orgID int64, issuesType []string) ([]*issuepb.IssuePropertyIndex, error)

func (IssueMock) GetIssue 

func (i IssueMock) GetIssue(id int64, identityInfo *commonpb.IdentityInfo) (*issuepb.Issue, error)

func (IssueMock) GetIssueChildren 

func (i IssueMock) GetIssueChildren(id uint64, req issuepb.PagingIssueRequest) ([]dao.IssueItem, uint64, error)

func (IssueMock) GetIssueItem 

func (i IssueMock) GetIssueItem(id uint64) (*dao.IssueItem, error)

func (IssueMock) GetIssueLabelsByProjectID 

func (i IssueMock) GetIssueLabelsByProjectID(projectID uint64) ([]dao.IssueLabel, error)

func (IssueMock) GetIssueParents 

func (i IssueMock) GetIssueParents(issueID uint64, relationType []string) ([]dao.IssueItem, error)

func (IssueMock) GetIssuePropertyInstance 

func (i IssueMock) GetIssuePropertyInstance(req *issuepb.GetIssuePropertyInstanceRequest) (*issuepb.IssueAndPropertyAndValue, error)

func (IssueMock) GetIssueRelationsByIssueIDs 

func (i IssueMock) GetIssueRelationsByIssueIDs(issueID uint64, relationType []string) ([]uint64, []uint64, error)

func (IssueMock) GetIssueStage 

func (i IssueMock) GetIssueStage(req *issuepb.IssueStageRequest) ([]*issuepb.IssueStage, error)

func (IssueMock) GetIssueStateIDs 

func (i IssueMock) GetIssueStateIDs(req *issuepb.GetIssueStatesRequest) ([]int64, error)

func (IssueMock) GetIssueStateIDsByTypes 

func (i IssueMock) GetIssueStateIDsByTypes(req *apistructs.IssueStatesRequest) ([]int64, error)

func (IssueMock) GetIssueStatesBelong 

func (i IssueMock) GetIssueStatesBelong(req *issuepb.GetIssueStateRelationRequest) ([]apistructs.IssueStateState, error)

func (IssueMock) GetIssueStatesMap 

func (i IssueMock) GetIssueStatesMap(req *issuepb.GetIssueStatesRequest) (map[string][]issuepb.IssueStatus, error)

func (IssueMock) GetIssuesByIssueIDs 

func (i IssueMock) GetIssuesByIssueIDs(issueIDs []uint64) ([]*issuepb.Issue, error)

func (IssueMock) GetIssuesStatesByProjectID 

func (i IssueMock) GetIssuesStatesByProjectID(projectID uint64, issueType string) ([]dao.IssueState, error)

func (IssueMock) GetProperties 

func (i IssueMock) GetProperties(req *issuepb.GetIssuePropertyRequest) ([]*issuepb.IssuePropertyIndex, error)

func (IssueMock) ListStatesTransByProjectID 

func (i IssueMock) ListStatesTransByProjectID(projectID uint64) ([]dao.IssueStateTransition, error)

func (IssueMock) Paging 

func (i IssueMock) Paging(req issuepb.PagingIssueRequest) ([]*issuepb.Issue, uint64, error)

func (IssueMock) SyncIssueChildrenIteration 

func (i IssueMock) SyncIssueChildrenIteration(issue *issuepb.Issue, iterationID int64) error

func (IssueMock) SyncLabels 

func (i IssueMock) SyncLabels(value *syncpb.Value, issueIDs []uint64) error

func (IssueMock) UpdateIssue 

func (i IssueMock) UpdateIssue(req *issuepb.UpdateIssueRequest) error

func (IssueMock) UpdateLabels 

func (i IssueMock) UpdateLabels(id, projectID uint64, labelNames []string) (err error)

type Service 

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

func (*Service) CreateFlowEvent 

func (s *Service) CreateFlowEvent(req *CreateFlowRequest) error

func (*Service) CreateFlowNode 

func (s *Service) CreateFlowNode(ctx context.Context, req *pb.CreateFlowNodeRequest) (*pb.CreateFlowNodeResponse, error)

CreateFlowNode currentBranch checkout from sourceBranch

func (*Service) DeleteFlowNode 

func (s *Service) DeleteFlowNode(ctx context.Context, req *pb.DeleteFlowNodeRequest) (*pb.DeleteFlowNodeResponse, error)

func (*Service) FlowCallBack 

func (s *Service) FlowCallBack(ctx context.Context, req *pb.FlowCallbackRequest) (*pb.FlowCallbackResponse, error)

func (*Service) GetDevFlowInfo 

func (s *Service) GetDevFlowInfo(ctx context.Context, req *pb.GetDevFlowInfoRequest) (*pb.GetDevFlowInfoResponse, error)

func (*Service) IdempotentCreateBranch 

func (s *Service) IdempotentCreateBranch(ctx context.Context, repoPath, sourceBranch, newBranch string) error

func (*Service) IdempotentDeleteBranch 

func (s *Service) IdempotentDeleteBranch(ctx context.Context, repoPath, branch string) error

func (*Service) IsMROpenedOrNotCreated 

func (s *Service) IsMROpenedOrNotCreated(ctx context.Context, currentBranch, targetBranch string, appID uint64) (bool, error)

func (*Service) JoinTempBranch 

func (s *Service) JoinTempBranch(ctx context.Context, tempBranch, sourceBranch string, appDto *apistructs.ApplicationDTO, devFlow *db.DevFlow) error

func (*Service) JudgeBranchIsExists 

func (s *Service) JudgeBranchIsExists(ctx context.Context, repoPath, branch string) (has bool, err error)

func (*Service) MergeToTempBranch 

func (s *Service) MergeToTempBranch(ctx context.Context, tempBranch string, appID uint64, devFlow *db.DevFlow) error

func (*Service) OperationMerge 

func (s *Service) OperationMerge(ctx context.Context, req *pb.OperationMergeRequest) (*pb.OperationMergeResponse, error)

func (*Service) Reconstruction 

func (s *Service) Reconstruction(ctx context.Context, req *pb.ReconstructionRequest) (*pb.ReconstructionResponse, error)

Reconstruction todo impl

func (*Service) RejoinTempBranch 

func (s *Service) RejoinTempBranch(ctx context.Context, tempBranch, sourceBranch, targetBranch string, devFlow *db.DevFlow, app *apistructs.ApplicationDTO) error

func (*Service) UpdateDevFlowAndDoRejoin 

func (s *Service) UpdateDevFlowAndDoRejoin(ctx context.Context, devFlow *db.DevFlow, app *apistructs.ApplicationDTO) error

func (*Service) WithBranchRule 

func (p *Service) WithBranchRule(branchRuleSvc *branchrule.BranchRule)

func (*Service) WithGittarFileTree 

func (p *Service) WithGittarFileTree(fileTree *filetree.GittarFileTree)

func (*Service) WithPermission 

func (p *Service) WithPermission(permission *permission.Permission)

Source Files

View all Source files

Directories

Path Synopsis

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.