Documentation ¶
Overview ¶
Package mock_pipelineConfig is a generated GoMock package.
Index ¶
- type CdWorkflowRepository
- func (_m *CdWorkflowRepository) ExistsByStatus(status string) (bool, error)
- func (_m *CdWorkflowRepository) FetchAllCdStagesLatestEntity(pipelineIds []int) ([]*pipelineConfig.CdWorkflowStatus, error)
- func (_m *CdWorkflowRepository) FetchAllCdStagesLatestEntityStatus(wfrIds []int) ([]*pipelineConfig.CdWorkflowRunner, error)
- func (_m *CdWorkflowRepository) FetchArtifactsByCdPipelineId(pipelineId int, runnerType bean.WorkflowType, offset int, limit int) ([]pipelineConfig.CdWorkflowRunner, error)
- func (_m *CdWorkflowRepository) FindArtifactByPipelineIdAndRunnerType(pipelineId int, runnerType bean.WorkflowType, limit int) ([]pipelineConfig.CdWorkflowRunner, error)
- func (_m *CdWorkflowRepository) FindById(wfId int) (*pipelineConfig.CdWorkflow, error)
- func (_m *CdWorkflowRepository) FindByWorkflowIdAndRunnerType(ctx context.Context, wfId int, runnerType bean.WorkflowType) (pipelineConfig.CdWorkflowRunner, error)
- func (_m *CdWorkflowRepository) FindCdWorkflowMetaByEnvironmentId(appId int, environmentId int, offset int, size int) ([]pipelineConfig.CdWorkflowRunner, error)
- func (_m *CdWorkflowRepository) FindCdWorkflowMetaByPipelineId(pipelineId int, offset int, size int) ([]pipelineConfig.CdWorkflowRunner, error)
- func (_m *CdWorkflowRepository) FindConfigByPipelineId(pipelineId int) (*pipelineConfig.CdWorkflowConfig, error)
- func (_m *CdWorkflowRepository) FindLastPreOrPostTriggeredByEnvironmentId(appId int, environmentId int) (pipelineConfig.CdWorkflowRunner, error)
- func (_m *CdWorkflowRepository) FindLastPreOrPostTriggeredByPipelineId(pipelineId int) (pipelineConfig.CdWorkflowRunner, error)
- func (_m *CdWorkflowRepository) FindLastStatusByPipelineIdAndRunnerType(pipelineId int, runnerType bean.WorkflowType) (pipelineConfig.CdWorkflowRunner, error)
- func (_m *CdWorkflowRepository) FindLatestCdWorkflowByPipelineId(pipelineIds []int) (*pipelineConfig.CdWorkflow, error)
- func (_m *CdWorkflowRepository) FindLatestCdWorkflowByPipelineIdV2(pipelineIds []int) ([]*pipelineConfig.CdWorkflow, error)
- func (_m *CdWorkflowRepository) FindLatestCdWorkflowRunnerByEnvironmentIdAndRunnerType(appId int, environmentId int, runnerType bean.WorkflowType) (pipelineConfig.CdWorkflowRunner, error)
- func (_m *CdWorkflowRepository) FindLatestWfrByAppIdAndEnvironmentId(appId int, environmentId int) (*pipelineConfig.CdWorkflowRunner, error)
- func (_m *CdWorkflowRepository) FindPreviousCdWfRunnerByStatus(pipelineId int, currentWFRunnerId int, status []string) ([]*pipelineConfig.CdWorkflowRunner, error)
- func (_m *CdWorkflowRepository) FindWorkflowRunnerByCdWorkflowId(wfIds []int) ([]*pipelineConfig.CdWorkflowRunner, error)
- func (_m *CdWorkflowRepository) FindWorkflowRunnerById(wfrId int) (*pipelineConfig.CdWorkflowRunner, error)
- func (_m *CdWorkflowRepository) GetConnection() *pg.DB
- func (_m *CdWorkflowRepository) IsLatestWf(pipelineId int, wfId int) (bool, error)
- func (_m *CdWorkflowRepository) SaveWorkFlow(ctx context.Context, wf *pipelineConfig.CdWorkflow) error
- func (_m *CdWorkflowRepository) SaveWorkFlowRunner(wfr *pipelineConfig.CdWorkflowRunner) (*pipelineConfig.CdWorkflowRunner, error)
- func (_m *CdWorkflowRepository) SaveWorkFlows(wfs ...*pipelineConfig.CdWorkflow) error
- func (_m *CdWorkflowRepository) UpdateWorkFlow(wf *pipelineConfig.CdWorkflow) error
- func (_m *CdWorkflowRepository) UpdateWorkFlowRunner(wfr *pipelineConfig.CdWorkflowRunner) error
- func (_m *CdWorkflowRepository) UpdateWorkFlowRunners(wfr []*pipelineConfig.CdWorkflowRunner) error
- func (_m *CdWorkflowRepository) UpdateWorkFlowRunnersWithTxn(wfrs []*pipelineConfig.CdWorkflowRunner, tx *pg.Tx) error
- type CiPipelineRepository
- func (_m *CiPipelineRepository) CheckIfPipelineExistsByNameAndAppId(pipelineName string, appId int) (bool, error)
- func (_m *CiPipelineRepository) CommitTx(tx *pg.Tx) error
- func (_m *CiPipelineRepository) FetchCiPipelinesForDG(parentId int, childCiPipelineIds []int) (*pipelineConfig.CiPipeline, int, error)
- func (_m *CiPipelineRepository) FetchParentCiPipelinesForDG() ([]*bean.CiPipelinesMap, error)
- func (_m *CiPipelineRepository) FinDByParentCiPipelineAndAppId(parentCiPipeline int, appIds []int) ([]*pipelineConfig.CiPipeline, error)
- func (_m *CiPipelineRepository) FindAllDeletedPipelineCountInLast24Hour() (int, error)
- func (_m *CiPipelineRepository) FindAllPipelineCreatedCountInLast24Hour() (int, error)
- func (_m *CiPipelineRepository) FindAppAndProjectByCiPipelineIds(ciPipelineIds []int) ([]*pipelineConfig.CiPipeline, error)
- func (_m *CiPipelineRepository) FindAppIdsForCiPipelineIds(pipelineIds []int) (map[int]int, error)
- func (_m *CiPipelineRepository) FindByAppId(appId int) ([]*pipelineConfig.CiPipeline, error)
- func (_m *CiPipelineRepository) FindByAppIds(appIds []int) ([]*pipelineConfig.CiPipeline, error)
- func (_m *CiPipelineRepository) FindByCiAndAppDetailsById(pipelineId int) (*pipelineConfig.CiPipeline, error)
- func (_m *CiPipelineRepository) FindById(id int) (*pipelineConfig.CiPipeline, error)
- func (_m *CiPipelineRepository) FindByIdIncludingInActive(id int) (*pipelineConfig.CiPipeline, error)
- func (_m *CiPipelineRepository) FindByIdsIn(ids []int) ([]*pipelineConfig.CiPipeline, error)
- func (_m *CiPipelineRepository) FindByName(pipelineName string) (*pipelineConfig.CiPipeline, error)
- func (_m *CiPipelineRepository) FindByParentCiPipelineId(parentCiPipelineId int) ([]*pipelineConfig.CiPipeline, error)
- func (_m *CiPipelineRepository) FindByParentCiPipelineIds(parentCiPipelineIds []int) ([]*pipelineConfig.CiPipeline, error)
- func (_m *CiPipelineRepository) FindByParentIdAndType(parentCiPipelineId int, pipelineType string) ([]*pipelineConfig.CiPipeline, error)
- func (_m *CiPipelineRepository) FindCiEnvMappingByCiPipelineId(ciPipelineId int) (*pipelineConfig.CiEnvMapping, error)
- func (_m *CiPipelineRepository) FindCiPipelineByAppIdAndEnvIds(appId int, envIds []int) ([]*pipelineConfig.CiPipeline, error)
- func (_m *CiPipelineRepository) FindCiPipelineConfigsByIds(ids []int) ([]*pipelineConfig.CiPipeline, error)
- func (_m *CiPipelineRepository) FindCiScriptsByCiPipelineId(ciPipelineId int) ([]*pipelineConfig.CiPipelineScript, error)
- func (_m *CiPipelineRepository) FindCiScriptsByCiPipelineIds(ciPipelineId []int) ([]*pipelineConfig.CiPipelineScript, error)
- func (_m *CiPipelineRepository) FindExternalCiByAppId(appId int) ([]*pipelineConfig.ExternalCiPipeline, error)
- func (_m *CiPipelineRepository) FindExternalCiByAppIds(appIds []int) ([]*pipelineConfig.ExternalCiPipeline, error)
- func (_m *CiPipelineRepository) FindExternalCiByCiPipelineId(ciPipelineId int) (*pipelineConfig.ExternalCiPipeline, error)
- func (_m *CiPipelineRepository) FindExternalCiById(id int) (*pipelineConfig.ExternalCiPipeline, error)
- func (_m *CiPipelineRepository) FindLinkedCiCount(ciPipelineId int) (int, error)
- func (_m *CiPipelineRepository) FindNumberOfAppsWithCiPipeline(appIds []int) (int, error)
- func (_m *CiPipelineRepository) FindOneWithAppData(id int) (*pipelineConfig.CiPipeline, error)
- func (_m *CiPipelineRepository) FindParentCiPipelineMapByAppId(appId int) ([]*pipelineConfig.CiPipeline, []int, error)
- func (_m *CiPipelineRepository) FindWithMinDataByCiPipelineId(id int) (*pipelineConfig.CiPipeline, error)
- func (_m *CiPipelineRepository) GetCiPipelineByArtifactId(artifactId int) (*pipelineConfig.CiPipeline, error)
- func (_m *CiPipelineRepository) GetDownStreamInfo(ctx context.Context, sourceCiPipelineId int, appNameMatch string, ...) ([]bean.LinkedCIDetails, int, error)
- func (_m *CiPipelineRepository) GetExternalCiPipelineByArtifactId(artifactId int) (*pipelineConfig.ExternalCiPipeline, error)
- func (_m *CiPipelineRepository) GetLinkedCiPipelines(ctx context.Context, ciPipelineId int) ([]*pipelineConfig.CiPipeline, error)
- func (_m *CiPipelineRepository) MarkCiPipelineScriptsInactiveByCiPipelineId(ciPipelineId int, tx *pg.Tx) error
- func (_m *CiPipelineRepository) PipelineExistsByName(names []string) ([]string, error)
- func (_m *CiPipelineRepository) RollbackTx(tx *pg.Tx) error
- func (_m *CiPipelineRepository) Save(pipeline *pipelineConfig.CiPipeline, tx *pg.Tx) error
- func (_m *CiPipelineRepository) SaveCiEnvMapping(cienvmapping *pipelineConfig.CiEnvMapping, tx *pg.Tx) error
- func (_m *CiPipelineRepository) SaveCiPipelineScript(ciPipelineScript *pipelineConfig.CiPipelineScript, tx *pg.Tx) error
- func (_m *CiPipelineRepository) SaveExternalCi(pipeline *pipelineConfig.ExternalCiPipeline, tx *pg.Tx) (*pipelineConfig.ExternalCiPipeline, error)
- func (_m *CiPipelineRepository) StartTx() (*pg.Tx, error)
- func (_m *CiPipelineRepository) Update(pipeline *pipelineConfig.CiPipeline, tx *pg.Tx) error
- func (_m *CiPipelineRepository) UpdateCiEnvMapping(cienvmapping *pipelineConfig.CiEnvMapping, tx *pg.Tx) error
- func (_m *CiPipelineRepository) UpdateCiPipelineScript(script *pipelineConfig.CiPipelineScript, tx *pg.Tx) error
- func (_m *CiPipelineRepository) UpdateExternalCi(pipeline *pipelineConfig.ExternalCiPipeline, tx *pg.Tx) (*pipelineConfig.ExternalCiPipeline, error)
- type CiWorkflowRepository
- func (_m *CiWorkflowRepository) ExistsByStatus(status string) (bool, error)
- func (_m *CiWorkflowRepository) FindBuildTypeAndStatusDataOfLast1Day() []*pipelineConfig.BuildTypeCount
- func (_m *CiWorkflowRepository) FindById(id int) (*pipelineConfig.CiWorkflow, error)
- func (_m *CiWorkflowRepository) FindByName(name string) (*pipelineConfig.CiWorkflow, error)
- func (_m *CiWorkflowRepository) FindByPipelineId(pipelineId int, offset int, size int) ([]pipelineConfig.WorkflowWithArtifact, error)
- func (_m *CiWorkflowRepository) FindByStatusesIn(activeStatuses []string) ([]*pipelineConfig.CiWorkflow, error)
- func (_m *CiWorkflowRepository) FindCiWorkflowGitTriggersById(id int) (*pipelineConfig.CiWorkflow, error)
- func (_m *CiWorkflowRepository) FindConfigByPipelineId(pipelineId int) (*pipelineConfig.CiWorkflowConfig, error)
- func (_m *CiWorkflowRepository) FindLastTriggeredWorkflow(pipelineId int) (*pipelineConfig.CiWorkflow, error)
- func (_m *CiWorkflowRepository) FindLastTriggeredWorkflowByArtifactId(ciArtifactId int) (*pipelineConfig.CiWorkflow, error)
- func (_m *CiWorkflowRepository) FindLastTriggeredWorkflowByCiIds(pipelineId []int) ([]*pipelineConfig.CiWorkflow, error)
- func (_m *CiWorkflowRepository) FindLastTriggeredWorkflowGitTriggersByArtifactId(ciArtifactId int) (*pipelineConfig.CiWorkflow, error)
- func (_m *CiWorkflowRepository) SaveWorkFlow(wf *pipelineConfig.CiWorkflow) error
- func (_m *CiWorkflowRepository) SaveWorkFlowConfig(config *pipelineConfig.CiWorkflowConfig) error
- func (_m *CiWorkflowRepository) UpdateWorkFlow(wf *pipelineConfig.CiWorkflow) error
- type MockCiPipelineMaterialRepository
- func (m *MockCiPipelineMaterialRepository) CheckRegexExistsForMaterial(id int) bool
- func (m *MockCiPipelineMaterialRepository) EXPECT() *MockCiPipelineMaterialRepositoryMockRecorder
- func (m *MockCiPipelineMaterialRepository) FindByCiPipelineIdsIn(ids []int) ([]*pipelineConfig.CiPipelineMaterial, error)
- func (m *MockCiPipelineMaterialRepository) GetById(id int) (*pipelineConfig.CiPipelineMaterial, error)
- func (m *MockCiPipelineMaterialRepository) GetByPipelineId(id int) ([]*pipelineConfig.CiPipelineMaterial, error)
- func (m *MockCiPipelineMaterialRepository) GetByPipelineIdAndGitMaterialId(id, gitMaterialId int) ([]*pipelineConfig.CiPipelineMaterial, error)
- func (m *MockCiPipelineMaterialRepository) GetByPipelineIdForRegexAndFixed(id int) ([]*pipelineConfig.CiPipelineMaterial, error)
- func (m *MockCiPipelineMaterialRepository) GetCheckoutPath(gitMaterialId int) (string, error)
- func (m *MockCiPipelineMaterialRepository) GetRegexByPipelineId(id int) ([]*pipelineConfig.CiPipelineMaterial, error)
- func (m *MockCiPipelineMaterialRepository) Save(tx *pg.Tx, pipeline ...*pipelineConfig.CiPipelineMaterial) error
- func (m *MockCiPipelineMaterialRepository) Update(tx *pg.Tx, material ...*pipelineConfig.CiPipelineMaterial) error
- func (m *MockCiPipelineMaterialRepository) UpdateNotNull(tx *pg.Tx, material ...*pipelineConfig.CiPipelineMaterial) error
- type MockCiPipelineMaterialRepositoryMockRecorder
- func (mr *MockCiPipelineMaterialRepositoryMockRecorder) CheckRegexExistsForMaterial(id interface{}) *gomock.Call
- func (mr *MockCiPipelineMaterialRepositoryMockRecorder) FindByCiPipelineIdsIn(ids interface{}) *gomock.Call
- func (mr *MockCiPipelineMaterialRepositoryMockRecorder) GetById(id interface{}) *gomock.Call
- func (mr *MockCiPipelineMaterialRepositoryMockRecorder) GetByPipelineId(id interface{}) *gomock.Call
- func (mr *MockCiPipelineMaterialRepositoryMockRecorder) GetByPipelineIdAndGitMaterialId(id, gitMaterialId interface{}) *gomock.Call
- func (mr *MockCiPipelineMaterialRepositoryMockRecorder) GetByPipelineIdForRegexAndFixed(id interface{}) *gomock.Call
- func (mr *MockCiPipelineMaterialRepositoryMockRecorder) GetCheckoutPath(gitMaterialId interface{}) *gomock.Call
- func (mr *MockCiPipelineMaterialRepositoryMockRecorder) GetRegexByPipelineId(id interface{}) *gomock.Call
- func (mr *MockCiPipelineMaterialRepositoryMockRecorder) Save(tx interface{}, pipeline ...interface{}) *gomock.Call
- func (mr *MockCiPipelineMaterialRepositoryMockRecorder) Update(tx interface{}, material ...interface{}) *gomock.Call
- func (mr *MockCiPipelineMaterialRepositoryMockRecorder) UpdateNotNull(tx interface{}, material ...interface{}) *gomock.Call
- type PipelineRepository
- func (_m *PipelineRepository) Delete(id int, userId int32, tx *pg.Tx) error
- func (_m *PipelineRepository) FilterDeploymentDeleteRequestedPipelineIds(cdPipelineIds []int) (map[int]bool, error)
- func (_m *PipelineRepository) FindActiveByAppId(appId int) ([]*pipelineConfig.Pipeline, error)
- func (_m *PipelineRepository) FindActiveByAppIdAndEnvironmentId(appId int, environmentId int) ([]*pipelineConfig.Pipeline, error)
- func (_m *PipelineRepository) FindActiveByAppIdAndEnvironmentIdV2() ([]*pipelineConfig.Pipeline, error)
- func (_m *PipelineRepository) FindActiveByAppIdAndPipelineId(appId int, pipelineId int) ([]*pipelineConfig.Pipeline, error)
- func (_m *PipelineRepository) FindActiveByAppIds(appIds []int) ([]*pipelineConfig.Pipeline, error)
- func (_m *PipelineRepository) FindActiveByEnvId(envId int) ([]*pipelineConfig.Pipeline, error)
- func (_m *PipelineRepository) FindActiveByEnvIdAndDeploymentType(environmentId int, deploymentAppType string, exclusionList []int, ...) ([]*pipelineConfig.Pipeline, error)
- func (_m *PipelineRepository) FindActiveByEnvIds(envId []int) ([]*pipelineConfig.Pipeline, error)
- func (_m *PipelineRepository) FindActiveByInFilter(envId int, appIdIncludes []int) ([]*pipelineConfig.Pipeline, error)
- func (_m *PipelineRepository) FindActiveByNotFilter(envId int, appIdExcludes []int) ([]*pipelineConfig.Pipeline, error)
- func (_m *PipelineRepository) FindActivePipelineByEnvId(envId int) ([]*pipelineConfig.Pipeline, error)
- func (_m *PipelineRepository) FindAllDeletedPipelineCountInLast24Hour() (int, error)
- func (_m *PipelineRepository) FindAllPipelineCreatedCountInLast24Hour() (int, error)
- func (_m *PipelineRepository) FindAllPipelinesByChartsOverrideAndAppIdAndChartId(chartOverridden bool, appId int, chartId int) ([]*pipelineConfig.Pipeline, error)
- func (_m *PipelineRepository) FindAppAndEnvDetailsByPipelineId(id int) (*pipelineConfig.Pipeline, error)
- func (_m *PipelineRepository) FindAppAndEnvironmentAndProjectByPipelineIds(pipelineIds []int) ([]*pipelineConfig.Pipeline, error)
- func (_m *PipelineRepository) FindAutomaticByCiPipelineId(ciPipelineId int) ([]*pipelineConfig.Pipeline, error)
- func (_m *PipelineRepository) FindByCiPipelineId(ciPipelineId int) ([]*pipelineConfig.Pipeline, error)
- func (_m *PipelineRepository) FindByCiPipelineIdsIn(ciPipelineIds []int) ([]*pipelineConfig.Pipeline, error)
- func (_m *PipelineRepository) FindById(id int) (*pipelineConfig.Pipeline, error)
- func (_m *PipelineRepository) FindByIdEvenIfInactive(id int) (*pipelineConfig.Pipeline, error)
- func (_m *PipelineRepository) FindByIdsIn(ids []int) ([]*pipelineConfig.Pipeline, error)
- func (_m *PipelineRepository) FindByIdsInAndEnvironment(ids []int, environmentId int) ([]*pipelineConfig.Pipeline, error)
- func (_m *PipelineRepository) FindByName(pipelineName string) (*pipelineConfig.Pipeline, error)
- func (_m *PipelineRepository) FindByParentCiPipelineId(ciPipelineId int) ([]*pipelineConfig.Pipeline, error)
- func (_m *PipelineRepository) FindByPipelineTriggerGitHash(gitHash string) (*pipelineConfig.Pipeline, error)
- func (_m *PipelineRepository) FindDeploymentTypeByPipelineIds(cdPipelineIds []int) (map[int]pipelineConfig.DeploymentObject, error)
- func (_m *PipelineRepository) FindIdsByAppIdsAndEnvironmentIds(appIds []int, environmentIds []int) ([]int, error)
- func (_m *PipelineRepository) FindIdsByProjectIdsAndEnvironmentIds(projectIds []int, environmentIds []int) ([]int, error)
- func (_m *PipelineRepository) FindNumberOfAppsWithCdPipeline(appIds []int) (int, error)
- func (_m *PipelineRepository) FindWithEnvironmentByCiIds(ctx context.Context, cIPipelineIds []int) ([]*pipelineConfig.Pipeline, error)
- func (_m *PipelineRepository) GetAppAndEnvDetailsForDeploymentAppTypePipeline(deploymentAppType string, clusterIds []int) ([]*pipelineConfig.Pipeline, error)
- func (_m *PipelineRepository) GetArgoPipelineByArgoAppName(argoAppName string) (pipelineConfig.Pipeline, error)
- func (_m *PipelineRepository) GetArgoPipelinesHavingLatestTriggerStuckInNonTerminalStatuses(deployedBeforeMinutes int, getPipelineDeployedWithinHours int) ([]*pipelineConfig.Pipeline, error)
- func (_m *PipelineRepository) GetArgoPipelinesHavingTriggersStuckInLastPossibleNonTerminalTimelines(pendingSinceSeconds int, timeForDegradation int) ([]*pipelineConfig.Pipeline, error)
- func (_m *PipelineRepository) GetByEnvOverrideId(envOverrideId int) ([]pipelineConfig.Pipeline, error)
- func (_m *PipelineRepository) GetByEnvOverrideIdAndEnvId(envOverrideId int, envId int) (pipelineConfig.Pipeline, error)
- func (_m *PipelineRepository) GetConnection() *pg.DB
- func (_m *PipelineRepository) GetPartiallyDeletedPipelineByStatus(appId int, envId int) (pipelineConfig.Pipeline, error)
- func (_m *PipelineRepository) GetPostStageConfigById(id int) (*pipelineConfig.Pipeline, error)
- func (_m *PipelineRepository) PipelineExists(pipelineName string) (bool, error)
- func (_m *PipelineRepository) Save(pipeline []*pipelineConfig.Pipeline, tx *pg.Tx) error
- func (_m *PipelineRepository) SetDeploymentAppCreatedInPipeline(deploymentAppCreated bool, pipelineId int, userId int32) error
- func (_m *PipelineRepository) UndoDelete(id int) error
- func (_m *PipelineRepository) UniqueAppEnvironmentPipelines() ([]*pipelineConfig.Pipeline, error)
- func (_m *PipelineRepository) Update(pipeline *pipelineConfig.Pipeline, tx *pg.Tx) error
- func (_m *PipelineRepository) UpdateCdPipelineAfterDeployment(deploymentAppType string, cdPipelineIdIncludes []int, userId int32, ...) error
- func (_m *PipelineRepository) UpdateCdPipelineDeploymentAppInFilter(deploymentAppType string, cdPipelineIdIncludes []int, userId int32, ...) error
- func (_m *PipelineRepository) UpdateOldCiPipelineIdToNewCiPipelineId(tx *pg.Tx, oldCiPipelineId int, newCiPipelineId int) error
- type PipelineStatusTimelineRepository
- func (_m *PipelineStatusTimelineRepository) CheckIfTerminalStatusTimelinePresentByWfrId(wfrId int) (bool, error)
- func (_m *PipelineStatusTimelineRepository) DeleteByCdWfrIdAndTimelineStatuses(cdWfrId int, status []timelineStatus.TimelineStatus) error
- func (_m *PipelineStatusTimelineRepository) DeleteByCdWfrIdAndTimelineStatusesWithTxn(cdWfrId int, status []timelineStatus.TimelineStatus, tx *pg.Tx) error
- func (_m *PipelineStatusTimelineRepository) FetchLatestTimelineByAppIdAndEnvId(appId int, envId int) (*pipelineConfig.PipelineStatusTimeline, error)
- func (_m *PipelineStatusTimelineRepository) FetchLatestTimelineByWfrId(wfrId int) (*pipelineConfig.PipelineStatusTimeline, error)
- func (_m *PipelineStatusTimelineRepository) FetchTimelineByWfrIdAndStatus(wfrId int, status timelineStatus.TimelineStatus) (*pipelineConfig.PipelineStatusTimeline, error)
- func (_m *PipelineStatusTimelineRepository) FetchTimelinesByPipelineId(pipelineId int) ([]*pipelineConfig.PipelineStatusTimeline, error)
- func (_m *PipelineStatusTimelineRepository) FetchTimelinesByWfrId(wfrId int) ([]*pipelineConfig.PipelineStatusTimeline, error)
- func (_m *PipelineStatusTimelineRepository) SaveTimeline(timeline *pipelineConfig.PipelineStatusTimeline) error
- func (_m *PipelineStatusTimelineRepository) SaveTimelinesWithTxn(timelines []*pipelineConfig.PipelineStatusTimeline, tx *pg.Tx) error
- func (_m *PipelineStatusTimelineRepository) UpdateTimeline(timeline *pipelineConfig.PipelineStatusTimeline) error
- func (_m *PipelineStatusTimelineRepository) UpdateTimelinesWithTxn(timelines []*pipelineConfig.PipelineStatusTimeline, tx *pg.Tx) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type CdWorkflowRepository ¶ added in v0.6.11
CdWorkflowRepository is an autogenerated mock type for the CdWorkflowRepository type
func NewCdWorkflowRepository ¶ added in v0.6.11
func NewCdWorkflowRepository(t mockConstructorTestingTNewCdWorkflowRepository) *CdWorkflowRepository
NewCdWorkflowRepository creates a new instance of CdWorkflowRepository. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations.
func (*CdWorkflowRepository) ExistsByStatus ¶ added in v0.6.11
func (_m *CdWorkflowRepository) ExistsByStatus(status string) (bool, error)
ExistsByStatus provides a mock function with given fields: status
func (*CdWorkflowRepository) FetchAllCdStagesLatestEntity ¶ added in v0.6.11
func (_m *CdWorkflowRepository) FetchAllCdStagesLatestEntity(pipelineIds []int) ([]*pipelineConfig.CdWorkflowStatus, error)
FetchAllCdStagesLatestEntity provides a mock function with given fields: pipelineIds
func (*CdWorkflowRepository) FetchAllCdStagesLatestEntityStatus ¶ added in v0.6.11
func (_m *CdWorkflowRepository) FetchAllCdStagesLatestEntityStatus(wfrIds []int) ([]*pipelineConfig.CdWorkflowRunner, error)
FetchAllCdStagesLatestEntityStatus provides a mock function with given fields: wfrIds
func (*CdWorkflowRepository) FetchArtifactsByCdPipelineId ¶ added in v0.6.11
func (_m *CdWorkflowRepository) FetchArtifactsByCdPipelineId(pipelineId int, runnerType bean.WorkflowType, offset int, limit int) ([]pipelineConfig.CdWorkflowRunner, error)
FetchArtifactsByCdPipelineId provides a mock function with given fields: pipelineId, runnerType, offset, limit
func (*CdWorkflowRepository) FindArtifactByPipelineIdAndRunnerType ¶ added in v0.6.11
func (_m *CdWorkflowRepository) FindArtifactByPipelineIdAndRunnerType(pipelineId int, runnerType bean.WorkflowType, limit int) ([]pipelineConfig.CdWorkflowRunner, error)
FindArtifactByPipelineIdAndRunnerType provides a mock function with given fields: pipelineId, runnerType, limit
func (*CdWorkflowRepository) FindById ¶ added in v0.6.11
func (_m *CdWorkflowRepository) FindById(wfId int) (*pipelineConfig.CdWorkflow, error)
FindById provides a mock function with given fields: wfId
func (*CdWorkflowRepository) FindByWorkflowIdAndRunnerType ¶ added in v0.6.11
func (_m *CdWorkflowRepository) FindByWorkflowIdAndRunnerType(ctx context.Context, wfId int, runnerType bean.WorkflowType) (pipelineConfig.CdWorkflowRunner, error)
FindByWorkflowIdAndRunnerType provides a mock function with given fields: wfId, runnerType
func (*CdWorkflowRepository) FindCdWorkflowMetaByEnvironmentId ¶ added in v0.6.11
func (_m *CdWorkflowRepository) FindCdWorkflowMetaByEnvironmentId(appId int, environmentId int, offset int, size int) ([]pipelineConfig.CdWorkflowRunner, error)
FindCdWorkflowMetaByEnvironmentId provides a mock function with given fields: appId, environmentId, offset, size
func (*CdWorkflowRepository) FindCdWorkflowMetaByPipelineId ¶ added in v0.6.11
func (_m *CdWorkflowRepository) FindCdWorkflowMetaByPipelineId(pipelineId int, offset int, size int) ([]pipelineConfig.CdWorkflowRunner, error)
FindCdWorkflowMetaByPipelineId provides a mock function with given fields: pipelineId, offset, size
func (*CdWorkflowRepository) FindConfigByPipelineId ¶ added in v0.6.11
func (_m *CdWorkflowRepository) FindConfigByPipelineId(pipelineId int) (*pipelineConfig.CdWorkflowConfig, error)
FindConfigByPipelineId provides a mock function with given fields: pipelineId
func (*CdWorkflowRepository) FindLastPreOrPostTriggeredByEnvironmentId ¶ added in v0.6.11
func (_m *CdWorkflowRepository) FindLastPreOrPostTriggeredByEnvironmentId(appId int, environmentId int) (pipelineConfig.CdWorkflowRunner, error)
FindLastPreOrPostTriggeredByEnvironmentId provides a mock function with given fields: appId, environmentId
func (*CdWorkflowRepository) FindLastPreOrPostTriggeredByPipelineId ¶ added in v0.6.11
func (_m *CdWorkflowRepository) FindLastPreOrPostTriggeredByPipelineId(pipelineId int) (pipelineConfig.CdWorkflowRunner, error)
FindLastPreOrPostTriggeredByPipelineId provides a mock function with given fields: pipelineId
func (*CdWorkflowRepository) FindLastStatusByPipelineIdAndRunnerType ¶ added in v0.6.11
func (_m *CdWorkflowRepository) FindLastStatusByPipelineIdAndRunnerType(pipelineId int, runnerType bean.WorkflowType) (pipelineConfig.CdWorkflowRunner, error)
FindLastStatusByPipelineIdAndRunnerType provides a mock function with given fields: pipelineId, runnerType
func (*CdWorkflowRepository) FindLatestCdWorkflowByPipelineId ¶ added in v0.6.11
func (_m *CdWorkflowRepository) FindLatestCdWorkflowByPipelineId(pipelineIds []int) (*pipelineConfig.CdWorkflow, error)
FindLatestCdWorkflowByPipelineId provides a mock function with given fields: pipelineIds
func (*CdWorkflowRepository) FindLatestCdWorkflowByPipelineIdV2 ¶ added in v0.6.11
func (_m *CdWorkflowRepository) FindLatestCdWorkflowByPipelineIdV2(pipelineIds []int) ([]*pipelineConfig.CdWorkflow, error)
FindLatestCdWorkflowByPipelineIdV2 provides a mock function with given fields: pipelineIds
func (*CdWorkflowRepository) FindLatestCdWorkflowRunnerByEnvironmentIdAndRunnerType ¶ added in v0.6.11
func (_m *CdWorkflowRepository) FindLatestCdWorkflowRunnerByEnvironmentIdAndRunnerType(appId int, environmentId int, runnerType bean.WorkflowType) (pipelineConfig.CdWorkflowRunner, error)
FindCdWorkflowRunnerByEnvironmentIdAndRunnerType provides a mock function with given fields: appId, environmentId, runnerType
func (*CdWorkflowRepository) FindLatestWfrByAppIdAndEnvironmentId ¶ added in v0.6.11
func (_m *CdWorkflowRepository) FindLatestWfrByAppIdAndEnvironmentId(appId int, environmentId int) (*pipelineConfig.CdWorkflowRunner, error)
FindLatestWfrByAppIdAndEnvironmentId provides a mock function with given fields: appId, environmentId
func (*CdWorkflowRepository) FindPreviousCdWfRunnerByStatus ¶ added in v0.6.11
func (_m *CdWorkflowRepository) FindPreviousCdWfRunnerByStatus(pipelineId int, currentWFRunnerId int, status []string) ([]*pipelineConfig.CdWorkflowRunner, error)
FindPreviousCdWfRunnerByStatus provides a mock function with given fields: pipelineId, currentWFRunnerId, status
func (*CdWorkflowRepository) FindWorkflowRunnerByCdWorkflowId ¶ added in v0.6.11
func (_m *CdWorkflowRepository) FindWorkflowRunnerByCdWorkflowId(wfIds []int) ([]*pipelineConfig.CdWorkflowRunner, error)
FindWorkflowRunnerByCdWorkflowId provides a mock function with given fields: wfIds
func (*CdWorkflowRepository) FindWorkflowRunnerById ¶ added in v0.6.11
func (_m *CdWorkflowRepository) FindWorkflowRunnerById(wfrId int) (*pipelineConfig.CdWorkflowRunner, error)
FindWorkflowRunnerById provides a mock function with given fields: wfrId
func (*CdWorkflowRepository) GetConnection ¶ added in v0.6.11
func (_m *CdWorkflowRepository) GetConnection() *pg.DB
GetConnection provides a mock function with given fields:
func (*CdWorkflowRepository) IsLatestWf ¶ added in v0.6.11
func (_m *CdWorkflowRepository) IsLatestWf(pipelineId int, wfId int) (bool, error)
IsLatestWf provides a mock function with given fields: pipelineId, wfId
func (*CdWorkflowRepository) SaveWorkFlow ¶ added in v0.6.11
func (_m *CdWorkflowRepository) SaveWorkFlow(ctx context.Context, wf *pipelineConfig.CdWorkflow) error
SaveWorkFlow provides a mock function with given fields: wf
func (*CdWorkflowRepository) SaveWorkFlowRunner ¶ added in v0.6.11
func (_m *CdWorkflowRepository) SaveWorkFlowRunner(wfr *pipelineConfig.CdWorkflowRunner) (*pipelineConfig.CdWorkflowRunner, error)
SaveWorkFlowRunner provides a mock function with given fields: wfr
func (*CdWorkflowRepository) SaveWorkFlows ¶ added in v0.6.11
func (_m *CdWorkflowRepository) SaveWorkFlows(wfs ...*pipelineConfig.CdWorkflow) error
SaveWorkFlows provides a mock function with given fields: wfs
func (*CdWorkflowRepository) UpdateWorkFlow ¶ added in v0.6.11
func (_m *CdWorkflowRepository) UpdateWorkFlow(wf *pipelineConfig.CdWorkflow) error
UpdateWorkFlow provides a mock function with given fields: wf
func (*CdWorkflowRepository) UpdateWorkFlowRunner ¶ added in v0.6.11
func (_m *CdWorkflowRepository) UpdateWorkFlowRunner(wfr *pipelineConfig.CdWorkflowRunner) error
UpdateWorkFlowRunner provides a mock function with given fields: wfr
func (*CdWorkflowRepository) UpdateWorkFlowRunners ¶ added in v0.6.11
func (_m *CdWorkflowRepository) UpdateWorkFlowRunners(wfr []*pipelineConfig.CdWorkflowRunner) error
UpdateWorkFlowRunners provides a mock function with given fields: wfr
func (*CdWorkflowRepository) UpdateWorkFlowRunnersWithTxn ¶ added in v0.6.11
func (_m *CdWorkflowRepository) UpdateWorkFlowRunnersWithTxn(wfrs []*pipelineConfig.CdWorkflowRunner, tx *pg.Tx) error
UpdateWorkFlowRunnersWithTxn provides a mock function with given fields: wfrs, tx
type CiPipelineRepository ¶ added in v0.6.19
CiPipelineRepository is an autogenerated mock type for the CiPipelineRepository type
func NewCiPipelineRepository ¶ added in v0.6.19
func NewCiPipelineRepository(t interface { mock.TestingT Cleanup(func()) }) *CiPipelineRepository
NewCiPipelineRepository creates a new instance of CiPipelineRepository. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.
func (*CiPipelineRepository) CheckIfPipelineExistsByNameAndAppId ¶ added in v0.7.0
func (_m *CiPipelineRepository) CheckIfPipelineExistsByNameAndAppId(pipelineName string, appId int) (bool, error)
CheckIfPipelineExistsByNameAndAppId provides a mock function with given fields: pipelineName, appId
func (*CiPipelineRepository) CommitTx ¶ added in v0.7.0
func (_m *CiPipelineRepository) CommitTx(tx *pg.Tx) error
CommitTx provides a mock function with given fields: tx
func (*CiPipelineRepository) FetchCiPipelinesForDG ¶ added in v0.6.19
func (_m *CiPipelineRepository) FetchCiPipelinesForDG(parentId int, childCiPipelineIds []int) (*pipelineConfig.CiPipeline, int, error)
FetchCiPipelinesForDG provides a mock function with given fields: parentId, childCiPipelineIds
func (*CiPipelineRepository) FetchParentCiPipelinesForDG ¶ added in v0.6.19
func (_m *CiPipelineRepository) FetchParentCiPipelinesForDG() ([]*bean.CiPipelinesMap, error)
FetchParentCiPipelinesForDG provides a mock function with given fields:
func (*CiPipelineRepository) FinDByParentCiPipelineAndAppId ¶ added in v0.6.19
func (_m *CiPipelineRepository) FinDByParentCiPipelineAndAppId(parentCiPipeline int, appIds []int) ([]*pipelineConfig.CiPipeline, error)
FinDByParentCiPipelineAndAppId provides a mock function with given fields: parentCiPipeline, appIds
func (*CiPipelineRepository) FindAllDeletedPipelineCountInLast24Hour ¶ added in v0.7.1
func (_m *CiPipelineRepository) FindAllDeletedPipelineCountInLast24Hour() (int, error)
FindAllDeletedPipelineCountInLast24Hour provides a mock function with given fields:
func (*CiPipelineRepository) FindAllPipelineCreatedCountInLast24Hour ¶ added in v0.7.1
func (_m *CiPipelineRepository) FindAllPipelineCreatedCountInLast24Hour() (int, error)
FindAllPipelineCreatedCountInLast24Hour provides a mock function with given fields:
func (*CiPipelineRepository) FindAppAndProjectByCiPipelineIds ¶ added in v0.6.19
func (_m *CiPipelineRepository) FindAppAndProjectByCiPipelineIds(ciPipelineIds []int) ([]*pipelineConfig.CiPipeline, error)
FindAppAndProjectByCiPipelineIds provides a mock function with given fields: ciPipelineIds
func (*CiPipelineRepository) FindAppIdsForCiPipelineIds ¶ added in v0.6.19
func (_m *CiPipelineRepository) FindAppIdsForCiPipelineIds(pipelineIds []int) (map[int]int, error)
FindAppIdsForCiPipelineIds provides a mock function with given fields: pipelineIds
func (*CiPipelineRepository) FindByAppId ¶ added in v0.6.19
func (_m *CiPipelineRepository) FindByAppId(appId int) ([]*pipelineConfig.CiPipeline, error)
FindByAppId provides a mock function with given fields: appId
func (*CiPipelineRepository) FindByAppIds ¶ added in v0.6.19
func (_m *CiPipelineRepository) FindByAppIds(appIds []int) ([]*pipelineConfig.CiPipeline, error)
FindByAppIds provides a mock function with given fields: appIds
func (*CiPipelineRepository) FindByCiAndAppDetailsById ¶ added in v0.6.19
func (_m *CiPipelineRepository) FindByCiAndAppDetailsById(pipelineId int) (*pipelineConfig.CiPipeline, error)
FindByCiAndAppDetailsById provides a mock function with given fields: pipelineId
func (*CiPipelineRepository) FindById ¶ added in v0.6.19
func (_m *CiPipelineRepository) FindById(id int) (*pipelineConfig.CiPipeline, error)
FindById provides a mock function with given fields: id
func (*CiPipelineRepository) FindByIdIncludingInActive ¶ added in v0.7.0
func (_m *CiPipelineRepository) FindByIdIncludingInActive(id int) (*pipelineConfig.CiPipeline, error)
FindByIdIncludingInActive provides a mock function with given fields: id
func (*CiPipelineRepository) FindByIdsIn ¶ added in v0.6.19
func (_m *CiPipelineRepository) FindByIdsIn(ids []int) ([]*pipelineConfig.CiPipeline, error)
FindByIdsIn provides a mock function with given fields: ids
func (*CiPipelineRepository) FindByName ¶ added in v0.6.19
func (_m *CiPipelineRepository) FindByName(pipelineName string) (*pipelineConfig.CiPipeline, error)
FindByName provides a mock function with given fields: pipelineName
func (*CiPipelineRepository) FindByParentCiPipelineId ¶ added in v0.6.19
func (_m *CiPipelineRepository) FindByParentCiPipelineId(parentCiPipelineId int) ([]*pipelineConfig.CiPipeline, error)
FindByParentCiPipelineId provides a mock function with given fields: parentCiPipelineId
func (*CiPipelineRepository) FindByParentCiPipelineIds ¶ added in v0.6.19
func (_m *CiPipelineRepository) FindByParentCiPipelineIds(parentCiPipelineIds []int) ([]*pipelineConfig.CiPipeline, error)
FindByParentCiPipelineIds provides a mock function with given fields: parentCiPipelineIds
func (*CiPipelineRepository) FindByParentIdAndType ¶ added in v0.7.0
func (_m *CiPipelineRepository) FindByParentIdAndType(parentCiPipelineId int, pipelineType string) ([]*pipelineConfig.CiPipeline, error)
FindByParentIdAndType provides a mock function with given fields: parentCiPipelineId, pipelineType
func (*CiPipelineRepository) FindCiEnvMappingByCiPipelineId ¶ added in v0.6.21
func (_m *CiPipelineRepository) FindCiEnvMappingByCiPipelineId(ciPipelineId int) (*pipelineConfig.CiEnvMapping, error)
FindCiEnvMappingByCiPipelineId provides a mock function with given fields: ciPipelineId
func (*CiPipelineRepository) FindCiPipelineByAppIdAndEnvIds ¶ added in v0.7.0
func (_m *CiPipelineRepository) FindCiPipelineByAppIdAndEnvIds(appId int, envIds []int) ([]*pipelineConfig.CiPipeline, error)
FindCiPipelineByAppIdAndEnvIds provides a mock function with given fields: appId, envIds
func (*CiPipelineRepository) FindCiPipelineConfigsByIds ¶ added in v0.6.19
func (_m *CiPipelineRepository) FindCiPipelineConfigsByIds(ids []int) ([]*pipelineConfig.CiPipeline, error)
FindCiPipelineConfigsByIds provides a mock function with given fields: ids
func (*CiPipelineRepository) FindCiScriptsByCiPipelineId ¶ added in v0.6.19
func (_m *CiPipelineRepository) FindCiScriptsByCiPipelineId(ciPipelineId int) ([]*pipelineConfig.CiPipelineScript, error)
FindCiScriptsByCiPipelineId provides a mock function with given fields: ciPipelineId
func (*CiPipelineRepository) FindCiScriptsByCiPipelineIds ¶ added in v0.6.19
func (_m *CiPipelineRepository) FindCiScriptsByCiPipelineIds(ciPipelineId []int) ([]*pipelineConfig.CiPipelineScript, error)
FindCiScriptsByCiPipelineIds provides a mock function with given fields: ciPipelineId
func (*CiPipelineRepository) FindExternalCiByAppId ¶ added in v0.6.19
func (_m *CiPipelineRepository) FindExternalCiByAppId(appId int) ([]*pipelineConfig.ExternalCiPipeline, error)
FindExternalCiByAppId provides a mock function with given fields: appId
func (*CiPipelineRepository) FindExternalCiByAppIds ¶ added in v0.6.19
func (_m *CiPipelineRepository) FindExternalCiByAppIds(appIds []int) ([]*pipelineConfig.ExternalCiPipeline, error)
FindExternalCiByAppIds provides a mock function with given fields: appIds
func (*CiPipelineRepository) FindExternalCiByCiPipelineId ¶ added in v0.6.19
func (_m *CiPipelineRepository) FindExternalCiByCiPipelineId(ciPipelineId int) (*pipelineConfig.ExternalCiPipeline, error)
FindExternalCiByCiPipelineId provides a mock function with given fields: ciPipelineId
func (*CiPipelineRepository) FindExternalCiById ¶ added in v0.6.19
func (_m *CiPipelineRepository) FindExternalCiById(id int) (*pipelineConfig.ExternalCiPipeline, error)
FindExternalCiById provides a mock function with given fields: id
func (*CiPipelineRepository) FindLinkedCiCount ¶ added in v0.7.0
func (_m *CiPipelineRepository) FindLinkedCiCount(ciPipelineId int) (int, error)
FindLinkedCiCount provides a mock function with given fields: ciPipelineId
func (*CiPipelineRepository) FindNumberOfAppsWithCiPipeline ¶ added in v0.6.19
func (_m *CiPipelineRepository) FindNumberOfAppsWithCiPipeline(appIds []int) (int, error)
FindNumberOfAppsWithCiPipeline provides a mock function with given fields: appIds
func (*CiPipelineRepository) FindOneWithAppData ¶ added in v0.7.0
func (_m *CiPipelineRepository) FindOneWithAppData(id int) (*pipelineConfig.CiPipeline, error)
FindOneWithAppData provides a mock function with given fields: id
func (*CiPipelineRepository) FindParentCiPipelineMapByAppId ¶ added in v0.6.19
func (_m *CiPipelineRepository) FindParentCiPipelineMapByAppId(appId int) ([]*pipelineConfig.CiPipeline, []int, error)
FindParentCiPipelineMapByAppId provides a mock function with given fields: appId
func (*CiPipelineRepository) FindWithMinDataByCiPipelineId ¶ added in v0.6.19
func (_m *CiPipelineRepository) FindWithMinDataByCiPipelineId(id int) (*pipelineConfig.CiPipeline, error)
FindWithMinDataByCiPipelineId provides a mock function with given fields: id
func (*CiPipelineRepository) GetCiPipelineByArtifactId ¶ added in v0.6.19
func (_m *CiPipelineRepository) GetCiPipelineByArtifactId(artifactId int) (*pipelineConfig.CiPipeline, error)
GetCiPipelineByArtifactId provides a mock function with given fields: artifactId
func (*CiPipelineRepository) GetDownStreamInfo ¶ added in v0.7.0
func (_m *CiPipelineRepository) GetDownStreamInfo(ctx context.Context, sourceCiPipelineId int, appNameMatch string, envNameMatch string, req *pagination.RepositoryRequest) ([]bean.LinkedCIDetails, int, error)
GetDownStreamInfo provides a mock function with given fields: ctx, sourceCiPipelineId, appNameMatch, envNameMatch, req
func (*CiPipelineRepository) GetExternalCiPipelineByArtifactId ¶ added in v0.6.19
func (_m *CiPipelineRepository) GetExternalCiPipelineByArtifactId(artifactId int) (*pipelineConfig.ExternalCiPipeline, error)
GetExternalCiPipelineByArtifactId provides a mock function with given fields: artifactId
func (*CiPipelineRepository) GetLinkedCiPipelines ¶ added in v0.7.0
func (_m *CiPipelineRepository) GetLinkedCiPipelines(ctx context.Context, ciPipelineId int) ([]*pipelineConfig.CiPipeline, error)
GetLinkedCiPipelines provides a mock function with given fields: ctx, ciPipelineId
func (*CiPipelineRepository) MarkCiPipelineScriptsInactiveByCiPipelineId ¶ added in v0.6.19
func (_m *CiPipelineRepository) MarkCiPipelineScriptsInactiveByCiPipelineId(ciPipelineId int, tx *pg.Tx) error
MarkCiPipelineScriptsInactiveByCiPipelineId provides a mock function with given fields: ciPipelineId, tx
func (*CiPipelineRepository) PipelineExistsByName ¶ added in v0.6.19
func (_m *CiPipelineRepository) PipelineExistsByName(names []string) ([]string, error)
PipelineExistsByName provides a mock function with given fields: names
func (*CiPipelineRepository) RollbackTx ¶ added in v0.7.0
func (_m *CiPipelineRepository) RollbackTx(tx *pg.Tx) error
RollbackTx provides a mock function with given fields: tx
func (*CiPipelineRepository) Save ¶ added in v0.6.19
func (_m *CiPipelineRepository) Save(pipeline *pipelineConfig.CiPipeline, tx *pg.Tx) error
Save provides a mock function with given fields: pipeline, tx
func (*CiPipelineRepository) SaveCiEnvMapping ¶ added in v0.6.21
func (_m *CiPipelineRepository) SaveCiEnvMapping(cienvmapping *pipelineConfig.CiEnvMapping, tx *pg.Tx) error
SaveCiEnvMapping provides a mock function with given fields: cienvmapping, tx
func (*CiPipelineRepository) SaveCiPipelineScript ¶ added in v0.6.19
func (_m *CiPipelineRepository) SaveCiPipelineScript(ciPipelineScript *pipelineConfig.CiPipelineScript, tx *pg.Tx) error
SaveCiPipelineScript provides a mock function with given fields: ciPipelineScript, tx
func (*CiPipelineRepository) SaveExternalCi ¶ added in v0.6.19
func (_m *CiPipelineRepository) SaveExternalCi(pipeline *pipelineConfig.ExternalCiPipeline, tx *pg.Tx) (*pipelineConfig.ExternalCiPipeline, error)
SaveExternalCi provides a mock function with given fields: pipeline, tx
func (*CiPipelineRepository) StartTx ¶ added in v0.7.0
func (_m *CiPipelineRepository) StartTx() (*pg.Tx, error)
StartTx provides a mock function with given fields:
func (*CiPipelineRepository) Update ¶ added in v0.6.19
func (_m *CiPipelineRepository) Update(pipeline *pipelineConfig.CiPipeline, tx *pg.Tx) error
Update provides a mock function with given fields: pipeline, tx
func (*CiPipelineRepository) UpdateCiEnvMapping ¶ added in v0.6.21
func (_m *CiPipelineRepository) UpdateCiEnvMapping(cienvmapping *pipelineConfig.CiEnvMapping, tx *pg.Tx) error
UpdateCiEnvMapping provides a mock function with given fields: cienvmapping, tx
func (*CiPipelineRepository) UpdateCiPipelineScript ¶ added in v0.6.19
func (_m *CiPipelineRepository) UpdateCiPipelineScript(script *pipelineConfig.CiPipelineScript, tx *pg.Tx) error
UpdateCiPipelineScript provides a mock function with given fields: script, tx
func (*CiPipelineRepository) UpdateExternalCi ¶ added in v0.6.19
func (_m *CiPipelineRepository) UpdateExternalCi(pipeline *pipelineConfig.ExternalCiPipeline, tx *pg.Tx) (*pipelineConfig.ExternalCiPipeline, error)
UpdateExternalCi provides a mock function with given fields: pipeline, tx
type CiWorkflowRepository ¶ added in v0.6.10
CiWorkflowRepository is an autogenerated mock type for the CiWorkflowRepository type
func NewCiWorkflowRepository ¶ added in v0.6.10
func NewCiWorkflowRepository(t mockConstructorTestingTNewCiWorkflowRepository) *CiWorkflowRepository
NewCiWorkflowRepository creates a new instance of CiWorkflowRepository. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations.
func (*CiWorkflowRepository) ExistsByStatus ¶ added in v0.6.10
func (_m *CiWorkflowRepository) ExistsByStatus(status string) (bool, error)
ExistsByStatus provides a mock function with given fields: status
func (*CiWorkflowRepository) FindBuildTypeAndStatusDataOfLast1Day ¶ added in v0.6.10
func (_m *CiWorkflowRepository) FindBuildTypeAndStatusDataOfLast1Day() []*pipelineConfig.BuildTypeCount
FindBuildTypeAndStatusDataOfLast1Day provides a mock function with given fields:
func (*CiWorkflowRepository) FindById ¶ added in v0.6.10
func (_m *CiWorkflowRepository) FindById(id int) (*pipelineConfig.CiWorkflow, error)
FindById provides a mock function with given fields: id
func (*CiWorkflowRepository) FindByName ¶ added in v0.6.10
func (_m *CiWorkflowRepository) FindByName(name string) (*pipelineConfig.CiWorkflow, error)
FindByName provides a mock function with given fields: name
func (*CiWorkflowRepository) FindByPipelineId ¶ added in v0.6.10
func (_m *CiWorkflowRepository) FindByPipelineId(pipelineId int, offset int, size int) ([]pipelineConfig.WorkflowWithArtifact, error)
FindByPipelineId provides a mock function with given fields: pipelineId, offset, size
func (*CiWorkflowRepository) FindByStatusesIn ¶ added in v0.6.10
func (_m *CiWorkflowRepository) FindByStatusesIn(activeStatuses []string) ([]*pipelineConfig.CiWorkflow, error)
FindByStatusesIn provides a mock function with given fields: activeStatuses
func (*CiWorkflowRepository) FindCiWorkflowGitTriggersById ¶ added in v0.6.17
func (_m *CiWorkflowRepository) FindCiWorkflowGitTriggersById(id int) (*pipelineConfig.CiWorkflow, error)
FindCiWorkflowGitTriggersById provides a mock function with given fields: id
func (*CiWorkflowRepository) FindConfigByPipelineId ¶ added in v0.6.10
func (_m *CiWorkflowRepository) FindConfigByPipelineId(pipelineId int) (*pipelineConfig.CiWorkflowConfig, error)
FindConfigByPipelineId provides a mock function with given fields: pipelineId
func (*CiWorkflowRepository) FindLastTriggeredWorkflow ¶ added in v0.6.10
func (_m *CiWorkflowRepository) FindLastTriggeredWorkflow(pipelineId int) (*pipelineConfig.CiWorkflow, error)
FindLastTriggeredWorkflow provides a mock function with given fields: pipelineId
func (*CiWorkflowRepository) FindLastTriggeredWorkflowByArtifactId ¶ added in v0.6.10
func (_m *CiWorkflowRepository) FindLastTriggeredWorkflowByArtifactId(ciArtifactId int) (*pipelineConfig.CiWorkflow, error)
FindLastTriggeredWorkflowByArtifactId provides a mock function with given fields: ciArtifactId
func (*CiWorkflowRepository) FindLastTriggeredWorkflowByCiIds ¶ added in v0.6.10
func (_m *CiWorkflowRepository) FindLastTriggeredWorkflowByCiIds(pipelineId []int) ([]*pipelineConfig.CiWorkflow, error)
FindLastTriggeredWorkflowByCiIds provides a mock function with given fields: pipelineId
func (*CiWorkflowRepository) FindLastTriggeredWorkflowGitTriggersByArtifactId ¶ added in v0.6.17
func (_m *CiWorkflowRepository) FindLastTriggeredWorkflowGitTriggersByArtifactId(ciArtifactId int) (*pipelineConfig.CiWorkflow, error)
FindLastTriggeredWorkflowGitTriggersByArtifactId provides a mock function with given fields: ciArtifactId
func (*CiWorkflowRepository) SaveWorkFlow ¶ added in v0.6.10
func (_m *CiWorkflowRepository) SaveWorkFlow(wf *pipelineConfig.CiWorkflow) error
SaveWorkFlow provides a mock function with given fields: wf
func (*CiWorkflowRepository) SaveWorkFlowConfig ¶ added in v0.6.10
func (_m *CiWorkflowRepository) SaveWorkFlowConfig(config *pipelineConfig.CiWorkflowConfig) error
SaveWorkFlowConfig provides a mock function with given fields: config
func (*CiWorkflowRepository) UpdateWorkFlow ¶ added in v0.6.10
func (_m *CiWorkflowRepository) UpdateWorkFlow(wf *pipelineConfig.CiWorkflow) error
UpdateWorkFlow provides a mock function with given fields: wf
type MockCiPipelineMaterialRepository ¶ added in v0.6.21
type MockCiPipelineMaterialRepository struct {
// contains filtered or unexported fields
}
MockCiPipelineMaterialRepository is a mock of CiPipelineMaterialRepository interface.
func NewMockCiPipelineMaterialRepository ¶ added in v0.6.21
func NewMockCiPipelineMaterialRepository(ctrl *gomock.Controller) *MockCiPipelineMaterialRepository
NewMockCiPipelineMaterialRepository creates a new mock instance.
func (*MockCiPipelineMaterialRepository) CheckRegexExistsForMaterial ¶ added in v0.6.21
func (m *MockCiPipelineMaterialRepository) CheckRegexExistsForMaterial(id int) bool
CheckRegexExistsForMaterial mocks base method.
func (*MockCiPipelineMaterialRepository) EXPECT ¶ added in v0.6.21
func (m *MockCiPipelineMaterialRepository) EXPECT() *MockCiPipelineMaterialRepositoryMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockCiPipelineMaterialRepository) FindByCiPipelineIdsIn ¶ added in v0.6.21
func (m *MockCiPipelineMaterialRepository) FindByCiPipelineIdsIn(ids []int) ([]*pipelineConfig.CiPipelineMaterial, error)
FindByCiPipelineIdsIn mocks base method.
func (*MockCiPipelineMaterialRepository) GetById ¶ added in v0.6.21
func (m *MockCiPipelineMaterialRepository) GetById(id int) (*pipelineConfig.CiPipelineMaterial, error)
GetById mocks base method.
func (*MockCiPipelineMaterialRepository) GetByPipelineId ¶ added in v0.6.21
func (m *MockCiPipelineMaterialRepository) GetByPipelineId(id int) ([]*pipelineConfig.CiPipelineMaterial, error)
GetByPipelineId mocks base method.
func (*MockCiPipelineMaterialRepository) GetByPipelineIdAndGitMaterialId ¶ added in v0.6.21
func (m *MockCiPipelineMaterialRepository) GetByPipelineIdAndGitMaterialId(id, gitMaterialId int) ([]*pipelineConfig.CiPipelineMaterial, error)
GetByPipelineIdAndGitMaterialId mocks base method.
func (*MockCiPipelineMaterialRepository) GetByPipelineIdForRegexAndFixed ¶ added in v0.6.21
func (m *MockCiPipelineMaterialRepository) GetByPipelineIdForRegexAndFixed(id int) ([]*pipelineConfig.CiPipelineMaterial, error)
GetByPipelineIdForRegexAndFixed mocks base method.
func (*MockCiPipelineMaterialRepository) GetCheckoutPath ¶ added in v0.6.21
func (m *MockCiPipelineMaterialRepository) GetCheckoutPath(gitMaterialId int) (string, error)
GetCheckoutPath mocks base method.
func (*MockCiPipelineMaterialRepository) GetRegexByPipelineId ¶ added in v0.6.21
func (m *MockCiPipelineMaterialRepository) GetRegexByPipelineId(id int) ([]*pipelineConfig.CiPipelineMaterial, error)
GetRegexByPipelineId mocks base method.
func (*MockCiPipelineMaterialRepository) Save ¶ added in v0.6.21
func (m *MockCiPipelineMaterialRepository) Save(tx *pg.Tx, pipeline ...*pipelineConfig.CiPipelineMaterial) error
Save mocks base method.
func (*MockCiPipelineMaterialRepository) Update ¶ added in v0.6.21
func (m *MockCiPipelineMaterialRepository) Update(tx *pg.Tx, material ...*pipelineConfig.CiPipelineMaterial) error
Update mocks base method.
func (*MockCiPipelineMaterialRepository) UpdateNotNull ¶ added in v0.6.21
func (m *MockCiPipelineMaterialRepository) UpdateNotNull(tx *pg.Tx, material ...*pipelineConfig.CiPipelineMaterial) error
UpdateNotNull mocks base method.
type MockCiPipelineMaterialRepositoryMockRecorder ¶ added in v0.6.21
type MockCiPipelineMaterialRepositoryMockRecorder struct {
// contains filtered or unexported fields
}
MockCiPipelineMaterialRepositoryMockRecorder is the mock recorder for MockCiPipelineMaterialRepository.
func (*MockCiPipelineMaterialRepositoryMockRecorder) CheckRegexExistsForMaterial ¶ added in v0.6.21
func (mr *MockCiPipelineMaterialRepositoryMockRecorder) CheckRegexExistsForMaterial(id interface{}) *gomock.Call
CheckRegexExistsForMaterial indicates an expected call of CheckRegexExistsForMaterial.
func (*MockCiPipelineMaterialRepositoryMockRecorder) FindByCiPipelineIdsIn ¶ added in v0.6.21
func (mr *MockCiPipelineMaterialRepositoryMockRecorder) FindByCiPipelineIdsIn(ids interface{}) *gomock.Call
FindByCiPipelineIdsIn indicates an expected call of FindByCiPipelineIdsIn.
func (*MockCiPipelineMaterialRepositoryMockRecorder) GetById ¶ added in v0.6.21
func (mr *MockCiPipelineMaterialRepositoryMockRecorder) GetById(id interface{}) *gomock.Call
GetById indicates an expected call of GetById.
func (*MockCiPipelineMaterialRepositoryMockRecorder) GetByPipelineId ¶ added in v0.6.21
func (mr *MockCiPipelineMaterialRepositoryMockRecorder) GetByPipelineId(id interface{}) *gomock.Call
GetByPipelineId indicates an expected call of GetByPipelineId.
func (*MockCiPipelineMaterialRepositoryMockRecorder) GetByPipelineIdAndGitMaterialId ¶ added in v0.6.21
func (mr *MockCiPipelineMaterialRepositoryMockRecorder) GetByPipelineIdAndGitMaterialId(id, gitMaterialId interface{}) *gomock.Call
GetByPipelineIdAndGitMaterialId indicates an expected call of GetByPipelineIdAndGitMaterialId.
func (*MockCiPipelineMaterialRepositoryMockRecorder) GetByPipelineIdForRegexAndFixed ¶ added in v0.6.21
func (mr *MockCiPipelineMaterialRepositoryMockRecorder) GetByPipelineIdForRegexAndFixed(id interface{}) *gomock.Call
GetByPipelineIdForRegexAndFixed indicates an expected call of GetByPipelineIdForRegexAndFixed.
func (*MockCiPipelineMaterialRepositoryMockRecorder) GetCheckoutPath ¶ added in v0.6.21
func (mr *MockCiPipelineMaterialRepositoryMockRecorder) GetCheckoutPath(gitMaterialId interface{}) *gomock.Call
GetCheckoutPath indicates an expected call of GetCheckoutPath.
func (*MockCiPipelineMaterialRepositoryMockRecorder) GetRegexByPipelineId ¶ added in v0.6.21
func (mr *MockCiPipelineMaterialRepositoryMockRecorder) GetRegexByPipelineId(id interface{}) *gomock.Call
GetRegexByPipelineId indicates an expected call of GetRegexByPipelineId.
func (*MockCiPipelineMaterialRepositoryMockRecorder) Save ¶ added in v0.6.21
func (mr *MockCiPipelineMaterialRepositoryMockRecorder) Save(tx interface{}, pipeline ...interface{}) *gomock.Call
Save indicates an expected call of Save.
func (*MockCiPipelineMaterialRepositoryMockRecorder) Update ¶ added in v0.6.21
func (mr *MockCiPipelineMaterialRepositoryMockRecorder) Update(tx interface{}, material ...interface{}) *gomock.Call
Update indicates an expected call of Update.
func (*MockCiPipelineMaterialRepositoryMockRecorder) UpdateNotNull ¶ added in v0.6.21
func (mr *MockCiPipelineMaterialRepositoryMockRecorder) UpdateNotNull(tx interface{}, material ...interface{}) *gomock.Call
UpdateNotNull indicates an expected call of UpdateNotNull.
type PipelineRepository ¶
PipelineRepository is an autogenerated mock type for the PipelineRepository type
func NewPipelineRepository ¶
func NewPipelineRepository(t interface { mock.TestingT Cleanup(func()) }) *PipelineRepository
NewPipelineRepository creates a new instance of PipelineRepository. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.
func (*PipelineRepository) Delete ¶
Delete provides a mock function with given fields: id, userId, tx
func (*PipelineRepository) FilterDeploymentDeleteRequestedPipelineIds ¶ added in v0.6.17
func (_m *PipelineRepository) FilterDeploymentDeleteRequestedPipelineIds(cdPipelineIds []int) (map[int]bool, error)
FilterDeploymentDeleteRequestedPipelineIds provides a mock function with given fields: cdPipelineIds
func (*PipelineRepository) FindActiveByAppId ¶
func (_m *PipelineRepository) FindActiveByAppId(appId int) ([]*pipelineConfig.Pipeline, error)
FindActiveByAppId provides a mock function with given fields: appId
func (*PipelineRepository) FindActiveByAppIdAndEnvironmentId ¶
func (_m *PipelineRepository) FindActiveByAppIdAndEnvironmentId(appId int, environmentId int) ([]*pipelineConfig.Pipeline, error)
FindActiveByAppIdAndEnvironmentId provides a mock function with given fields: appId, environmentId
func (*PipelineRepository) FindActiveByAppIdAndEnvironmentIdV2 ¶
func (_m *PipelineRepository) FindActiveByAppIdAndEnvironmentIdV2() ([]*pipelineConfig.Pipeline, error)
FindActiveByAppIdAndEnvironmentIdV2 provides a mock function with given fields:
func (*PipelineRepository) FindActiveByAppIdAndPipelineId ¶
func (_m *PipelineRepository) FindActiveByAppIdAndPipelineId(appId int, pipelineId int) ([]*pipelineConfig.Pipeline, error)
FindActiveByAppIdAndPipelineId provides a mock function with given fields: appId, pipelineId
func (*PipelineRepository) FindActiveByAppIds ¶ added in v0.6.13
func (_m *PipelineRepository) FindActiveByAppIds(appIds []int) ([]*pipelineConfig.Pipeline, error)
FindActiveByAppIds provides a mock function with given fields: appIds
func (*PipelineRepository) FindActiveByEnvId ¶
func (_m *PipelineRepository) FindActiveByEnvId(envId int) ([]*pipelineConfig.Pipeline, error)
FindActiveByEnvId provides a mock function with given fields: envId
func (*PipelineRepository) FindActiveByEnvIdAndDeploymentType ¶ added in v0.6.13
func (_m *PipelineRepository) FindActiveByEnvIdAndDeploymentType(environmentId int, deploymentAppType string, exclusionList []int, includeApps []int) ([]*pipelineConfig.Pipeline, error)
FindActiveByEnvIdAndDeploymentType provides a mock function with given fields: environmentId, deploymentAppType, exclusionList, includeApps
func (*PipelineRepository) FindActiveByEnvIds ¶ added in v0.6.17
func (_m *PipelineRepository) FindActiveByEnvIds(envId []int) ([]*pipelineConfig.Pipeline, error)
FindActiveByEnvIds provides a mock function with given fields: envId
func (*PipelineRepository) FindActiveByInFilter ¶
func (_m *PipelineRepository) FindActiveByInFilter(envId int, appIdIncludes []int) ([]*pipelineConfig.Pipeline, error)
FindActiveByInFilter provides a mock function with given fields: envId, appIdIncludes
func (*PipelineRepository) FindActiveByNotFilter ¶
func (_m *PipelineRepository) FindActiveByNotFilter(envId int, appIdExcludes []int) ([]*pipelineConfig.Pipeline, error)
FindActiveByNotFilter provides a mock function with given fields: envId, appIdExcludes
func (*PipelineRepository) FindActivePipelineByEnvId ¶ added in v0.7.1
func (_m *PipelineRepository) FindActivePipelineByEnvId(envId int) ([]*pipelineConfig.Pipeline, error)
FindActivePipelineByEnvId provides a mock function with given fields: envId
func (*PipelineRepository) FindAllDeletedPipelineCountInLast24Hour ¶ added in v0.7.1
func (_m *PipelineRepository) FindAllDeletedPipelineCountInLast24Hour() (int, error)
FindAllDeletedPipelineCountInLast24Hour provides a mock function with given fields:
func (*PipelineRepository) FindAllPipelineCreatedCountInLast24Hour ¶ added in v0.7.1
func (_m *PipelineRepository) FindAllPipelineCreatedCountInLast24Hour() (int, error)
FindAllPipelineCreatedCountInLast24Hour provides a mock function with given fields:
func (*PipelineRepository) FindAllPipelinesByChartsOverrideAndAppIdAndChartId ¶
func (_m *PipelineRepository) FindAllPipelinesByChartsOverrideAndAppIdAndChartId(chartOverridden bool, appId int, chartId int) ([]*pipelineConfig.Pipeline, error)
FindAllPipelinesByChartsOverrideAndAppIdAndChartId provides a mock function with given fields: chartOverridden, appId, chartId
func (*PipelineRepository) FindAppAndEnvDetailsByPipelineId ¶ added in v0.6.17
func (_m *PipelineRepository) FindAppAndEnvDetailsByPipelineId(id int) (*pipelineConfig.Pipeline, error)
FindAppAndEnvDetailsByPipelineId provides a mock function with given fields: id
func (*PipelineRepository) FindAppAndEnvironmentAndProjectByPipelineIds ¶ added in v0.6.15
func (_m *PipelineRepository) FindAppAndEnvironmentAndProjectByPipelineIds(pipelineIds []int) ([]*pipelineConfig.Pipeline, error)
FindAppAndEnvironmentAndProjectByPipelineIds provides a mock function with given fields: pipelineIds
func (*PipelineRepository) FindAutomaticByCiPipelineId ¶
func (_m *PipelineRepository) FindAutomaticByCiPipelineId(ciPipelineId int) ([]*pipelineConfig.Pipeline, error)
FindAutomaticByCiPipelineId provides a mock function with given fields: ciPipelineId
func (*PipelineRepository) FindByCiPipelineId ¶
func (_m *PipelineRepository) FindByCiPipelineId(ciPipelineId int) ([]*pipelineConfig.Pipeline, error)
FindByCiPipelineId provides a mock function with given fields: ciPipelineId
func (*PipelineRepository) FindByCiPipelineIdsIn ¶
func (_m *PipelineRepository) FindByCiPipelineIdsIn(ciPipelineIds []int) ([]*pipelineConfig.Pipeline, error)
FindByCiPipelineIdsIn provides a mock function with given fields: ciPipelineIds
func (*PipelineRepository) FindById ¶
func (_m *PipelineRepository) FindById(id int) (*pipelineConfig.Pipeline, error)
FindById provides a mock function with given fields: id
func (*PipelineRepository) FindByIdEvenIfInactive ¶ added in v0.7.1
func (_m *PipelineRepository) FindByIdEvenIfInactive(id int) (*pipelineConfig.Pipeline, error)
FindByIdEvenIfInactive provides a mock function with given fields: id
func (*PipelineRepository) FindByIdsIn ¶
func (_m *PipelineRepository) FindByIdsIn(ids []int) ([]*pipelineConfig.Pipeline, error)
FindByIdsIn provides a mock function with given fields: ids
func (*PipelineRepository) FindByIdsInAndEnvironment ¶
func (_m *PipelineRepository) FindByIdsInAndEnvironment(ids []int, environmentId int) ([]*pipelineConfig.Pipeline, error)
FindByIdsInAndEnvironment provides a mock function with given fields: ids, environmentId
func (*PipelineRepository) FindByName ¶
func (_m *PipelineRepository) FindByName(pipelineName string) (*pipelineConfig.Pipeline, error)
FindByName provides a mock function with given fields: pipelineName
func (*PipelineRepository) FindByParentCiPipelineId ¶
func (_m *PipelineRepository) FindByParentCiPipelineId(ciPipelineId int) ([]*pipelineConfig.Pipeline, error)
FindByParentCiPipelineId provides a mock function with given fields: ciPipelineId
func (*PipelineRepository) FindByPipelineTriggerGitHash ¶
func (_m *PipelineRepository) FindByPipelineTriggerGitHash(gitHash string) (*pipelineConfig.Pipeline, error)
FindByPipelineTriggerGitHash provides a mock function with given fields: gitHash
func (*PipelineRepository) FindDeploymentTypeByPipelineIds ¶ added in v0.7.1
func (_m *PipelineRepository) FindDeploymentTypeByPipelineIds(cdPipelineIds []int) (map[int]pipelineConfig.DeploymentObject, error)
FindDeploymentTypeByPipelineIds provides a mock function with given fields: cdPipelineIds
func (*PipelineRepository) FindIdsByAppIdsAndEnvironmentIds ¶
func (_m *PipelineRepository) FindIdsByAppIdsAndEnvironmentIds(appIds []int, environmentIds []int) ([]int, error)
FindIdsByAppIdsAndEnvironmentIds provides a mock function with given fields: appIds, environmentIds
func (*PipelineRepository) FindIdsByProjectIdsAndEnvironmentIds ¶
func (_m *PipelineRepository) FindIdsByProjectIdsAndEnvironmentIds(projectIds []int, environmentIds []int) ([]int, error)
FindIdsByProjectIdsAndEnvironmentIds provides a mock function with given fields: projectIds, environmentIds
func (*PipelineRepository) FindNumberOfAppsWithCdPipeline ¶
func (_m *PipelineRepository) FindNumberOfAppsWithCdPipeline(appIds []int) (int, error)
FindNumberOfAppsWithCdPipeline provides a mock function with given fields: appIds
func (*PipelineRepository) FindWithEnvironmentByCiIds ¶ added in v0.7.1
func (_m *PipelineRepository) FindWithEnvironmentByCiIds(ctx context.Context, cIPipelineIds []int) ([]*pipelineConfig.Pipeline, error)
FindWithEnvironmentByCiIds provides a mock function with given fields: ctx, cIPipelineIds
func (*PipelineRepository) GetAppAndEnvDetailsForDeploymentAppTypePipeline ¶
func (_m *PipelineRepository) GetAppAndEnvDetailsForDeploymentAppTypePipeline(deploymentAppType string, clusterIds []int) ([]*pipelineConfig.Pipeline, error)
GetAppAndEnvDetailsForDeploymentAppTypePipeline provides a mock function with given fields: deploymentAppType, clusterIds
func (*PipelineRepository) GetArgoPipelineByArgoAppName ¶ added in v0.6.11
func (_m *PipelineRepository) GetArgoPipelineByArgoAppName(argoAppName string) (pipelineConfig.Pipeline, error)
GetArgoPipelineByArgoAppName provides a mock function with given fields: argoAppName
func (*PipelineRepository) GetArgoPipelinesHavingLatestTriggerStuckInNonTerminalStatuses ¶ added in v0.6.11
func (_m *PipelineRepository) GetArgoPipelinesHavingLatestTriggerStuckInNonTerminalStatuses(deployedBeforeMinutes int, getPipelineDeployedWithinHours int) ([]*pipelineConfig.Pipeline, error)
GetArgoPipelinesHavingLatestTriggerStuckInNonTerminalStatuses provides a mock function with given fields: deployedBeforeMinutes, getPipelineDeployedWithinHours
func (*PipelineRepository) GetArgoPipelinesHavingTriggersStuckInLastPossibleNonTerminalTimelines ¶ added in v0.6.11
func (_m *PipelineRepository) GetArgoPipelinesHavingTriggersStuckInLastPossibleNonTerminalTimelines(pendingSinceSeconds int, timeForDegradation int) ([]*pipelineConfig.Pipeline, error)
GetArgoPipelinesHavingTriggersStuckInLastPossibleNonTerminalTimelines provides a mock function with given fields: pendingSinceSeconds, timeForDegradation
func (*PipelineRepository) GetByEnvOverrideId ¶
func (_m *PipelineRepository) GetByEnvOverrideId(envOverrideId int) ([]pipelineConfig.Pipeline, error)
GetByEnvOverrideId provides a mock function with given fields: envOverrideId
func (*PipelineRepository) GetByEnvOverrideIdAndEnvId ¶
func (_m *PipelineRepository) GetByEnvOverrideIdAndEnvId(envOverrideId int, envId int) (pipelineConfig.Pipeline, error)
GetByEnvOverrideIdAndEnvId provides a mock function with given fields: envOverrideId, envId
func (*PipelineRepository) GetConnection ¶
func (_m *PipelineRepository) GetConnection() *pg.DB
GetConnection provides a mock function with given fields:
func (*PipelineRepository) GetPartiallyDeletedPipelineByStatus ¶ added in v0.6.13
func (_m *PipelineRepository) GetPartiallyDeletedPipelineByStatus(appId int, envId int) (pipelineConfig.Pipeline, error)
GetPartiallyDeletedPipelineByStatus provides a mock function with given fields: appId, envId
func (*PipelineRepository) GetPostStageConfigById ¶ added in v0.6.17
func (_m *PipelineRepository) GetPostStageConfigById(id int) (*pipelineConfig.Pipeline, error)
GetPostStageConfigById provides a mock function with given fields: id
func (*PipelineRepository) PipelineExists ¶
func (_m *PipelineRepository) PipelineExists(pipelineName string) (bool, error)
PipelineExists provides a mock function with given fields: pipelineName
func (*PipelineRepository) Save ¶
func (_m *PipelineRepository) Save(pipeline []*pipelineConfig.Pipeline, tx *pg.Tx) error
Save provides a mock function with given fields: pipeline, tx
func (*PipelineRepository) SetDeploymentAppCreatedInPipeline ¶ added in v0.6.17
func (_m *PipelineRepository) SetDeploymentAppCreatedInPipeline(deploymentAppCreated bool, pipelineId int, userId int32) error
SetDeploymentAppCreatedInPipeline provides a mock function with given fields: deploymentAppCreated, pipelineId, userId
func (*PipelineRepository) UndoDelete ¶
func (_m *PipelineRepository) UndoDelete(id int) error
UndoDelete provides a mock function with given fields: id
func (*PipelineRepository) UniqueAppEnvironmentPipelines ¶
func (_m *PipelineRepository) UniqueAppEnvironmentPipelines() ([]*pipelineConfig.Pipeline, error)
UniqueAppEnvironmentPipelines provides a mock function with given fields:
func (*PipelineRepository) Update ¶
func (_m *PipelineRepository) Update(pipeline *pipelineConfig.Pipeline, tx *pg.Tx) error
Update provides a mock function with given fields: pipeline, tx
func (*PipelineRepository) UpdateCdPipelineAfterDeployment ¶ added in v0.6.17
func (_m *PipelineRepository) UpdateCdPipelineAfterDeployment(deploymentAppType string, cdPipelineIdIncludes []int, userId int32, delete bool) error
UpdateCdPipelineAfterDeployment provides a mock function with given fields: deploymentAppType, cdPipelineIdIncludes, userId, delete
func (*PipelineRepository) UpdateCdPipelineDeploymentAppInFilter ¶ added in v0.6.13
func (_m *PipelineRepository) UpdateCdPipelineDeploymentAppInFilter(deploymentAppType string, cdPipelineIdIncludes []int, userId int32, deploymentAppCreated bool, delete bool) error
UpdateCdPipelineDeploymentAppInFilter provides a mock function with given fields: deploymentAppType, cdPipelineIdIncludes, userId, deploymentAppCreated, delete
func (*PipelineRepository) UpdateOldCiPipelineIdToNewCiPipelineId ¶ added in v0.7.1
func (_m *PipelineRepository) UpdateOldCiPipelineIdToNewCiPipelineId(tx *pg.Tx, oldCiPipelineId int, newCiPipelineId int) error
UpdateOldCiPipelineIdToNewCiPipelineId provides a mock function with given fields: tx, oldCiPipelineId, newCiPipelineId
type PipelineStatusTimelineRepository ¶ added in v0.6.11
PipelineStatusTimelineRepository is an autogenerated mock type for the PipelineStatusTimelineRepository type
func NewPipelineStatusTimelineRepository ¶ added in v0.6.11
func NewPipelineStatusTimelineRepository(t mockConstructorTestingTNewPipelineStatusTimelineRepository) *PipelineStatusTimelineRepository
NewPipelineStatusTimelineRepository creates a new instance of PipelineStatusTimelineRepository. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations.
func (*PipelineStatusTimelineRepository) CheckIfTerminalStatusTimelinePresentByWfrId ¶ added in v0.6.11
func (_m *PipelineStatusTimelineRepository) CheckIfTerminalStatusTimelinePresentByWfrId(wfrId int) (bool, error)
CheckIfTerminalStatusTimelinePresentByWfrId provides a mock function with given fields: wfrId
func (*PipelineStatusTimelineRepository) DeleteByCdWfrIdAndTimelineStatuses ¶ added in v0.6.11
func (_m *PipelineStatusTimelineRepository) DeleteByCdWfrIdAndTimelineStatuses(cdWfrId int, status []timelineStatus.TimelineStatus) error
DeleteByCdWfrIdAndTimelineStatuses provides a mock function with given fields: cdWfrId, status
func (*PipelineStatusTimelineRepository) DeleteByCdWfrIdAndTimelineStatusesWithTxn ¶ added in v0.6.11
func (_m *PipelineStatusTimelineRepository) DeleteByCdWfrIdAndTimelineStatusesWithTxn(cdWfrId int, status []timelineStatus.TimelineStatus, tx *pg.Tx) error
DeleteByCdWfrIdAndTimelineStatusesWithTxn provides a mock function with given fields: cdWfrId, status, tx
func (*PipelineStatusTimelineRepository) FetchLatestTimelineByAppIdAndEnvId ¶ added in v0.6.11
func (_m *PipelineStatusTimelineRepository) FetchLatestTimelineByAppIdAndEnvId(appId int, envId int) (*pipelineConfig.PipelineStatusTimeline, error)
FetchLatestTimelineByAppIdAndEnvId provides a mock function with given fields: appId, envId
func (*PipelineStatusTimelineRepository) FetchLatestTimelineByWfrId ¶ added in v0.6.11
func (_m *PipelineStatusTimelineRepository) FetchLatestTimelineByWfrId(wfrId int) (*pipelineConfig.PipelineStatusTimeline, error)
FetchLatestTimelineByWfrId provides a mock function with given fields: wfrId
func (*PipelineStatusTimelineRepository) FetchTimelineByWfrIdAndStatus ¶ added in v0.6.11
func (_m *PipelineStatusTimelineRepository) FetchTimelineByWfrIdAndStatus(wfrId int, status timelineStatus.TimelineStatus) (*pipelineConfig.PipelineStatusTimeline, error)
FetchTimelineByWfrIdAndStatus provides a mock function with given fields: wfrId, status
func (*PipelineStatusTimelineRepository) FetchTimelinesByPipelineId ¶ added in v0.6.11
func (_m *PipelineStatusTimelineRepository) FetchTimelinesByPipelineId(pipelineId int) ([]*pipelineConfig.PipelineStatusTimeline, error)
FetchTimelinesByPipelineId provides a mock function with given fields: pipelineId
func (*PipelineStatusTimelineRepository) FetchTimelinesByWfrId ¶ added in v0.6.11
func (_m *PipelineStatusTimelineRepository) FetchTimelinesByWfrId(wfrId int) ([]*pipelineConfig.PipelineStatusTimeline, error)
FetchTimelinesByWfrId provides a mock function with given fields: wfrId
func (*PipelineStatusTimelineRepository) SaveTimeline ¶ added in v0.6.11
func (_m *PipelineStatusTimelineRepository) SaveTimeline(timeline *pipelineConfig.PipelineStatusTimeline) error
SaveTimeline provides a mock function with given fields: timeline
func (*PipelineStatusTimelineRepository) SaveTimelinesWithTxn ¶ added in v0.6.11
func (_m *PipelineStatusTimelineRepository) SaveTimelinesWithTxn(timelines []*pipelineConfig.PipelineStatusTimeline, tx *pg.Tx) error
SaveTimelinesWithTxn provides a mock function with given fields: timelines, tx
func (*PipelineStatusTimelineRepository) UpdateTimeline ¶ added in v0.6.11
func (_m *PipelineStatusTimelineRepository) UpdateTimeline(timeline *pipelineConfig.PipelineStatusTimeline) error
UpdateTimeline provides a mock function with given fields: timeline
func (*PipelineStatusTimelineRepository) UpdateTimelinesWithTxn ¶ added in v0.6.11
func (_m *PipelineStatusTimelineRepository) UpdateTimelinesWithTxn(timelines []*pipelineConfig.PipelineStatusTimeline, tx *pg.Tx) error
UpdateTimelinesWithTxn provides a mock function with given fields: timelines, tx