Documentation ¶
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 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 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) FindAllPipelineInLast24Hour() ([]*pipelineConfig.Pipeline, 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) 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) 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) 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
- type PipelineStatusTimelineRepository
- func (_m *PipelineStatusTimelineRepository) CheckIfTerminalStatusTimelinePresentByWfrId(wfrId int) (bool, error)
- func (_m *PipelineStatusTimelineRepository) DeleteByCdWfrIdAndTimelineStatuses(cdWfrId int, status []pipelineConfig.TimelineStatus) error
- func (_m *PipelineStatusTimelineRepository) DeleteByCdWfrIdAndTimelineStatusesWithTxn(cdWfrId int, status []pipelineConfig.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 pipelineConfig.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 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 PipelineRepository ¶
PipelineRepository is an autogenerated mock type for the PipelineRepository type
func NewPipelineRepository ¶
func NewPipelineRepository(t mockConstructorTestingTNewPipelineRepository) *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.
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) FindAllPipelineInLast24Hour ¶
func (_m *PipelineRepository) FindAllPipelineInLast24Hour() ([]*pipelineConfig.Pipeline, error)
FindAllPipelineInLast24Hour 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) 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) 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) 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
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 []pipelineConfig.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 []pipelineConfig.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 pipelineConfig.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