mocks

package

Go to main page

Versions in this module

v0

v0.7.3

Oct 2, 2024

v0.7.2

Aug 26, 2024

v0.7.2-rc.0

Jul 11, 2024

v0.7.1

Jul 10, 2024

Changes in this version

type CiPipelineRepository

+ func (_m *CiPipelineRepository) FindAllDeletedPipelineCountInLast24Hour() (int, error)

+ func (_m *CiPipelineRepository) FindAllPipelineCreatedCountInLast24Hour() (int, error)

type PipelineRepository

+ func (_m *PipelineRepository) FindActivePipelineByEnvId(envId int) ([]*pipelineConfig.Pipeline, error)

+ func (_m *PipelineRepository) FindAllDeletedPipelineCountInLast24Hour() (int, error)

+ func (_m *PipelineRepository) FindAllPipelineCreatedCountInLast24Hour() (int, error)

+ func (_m *PipelineRepository) FindByIdEvenIfInactive(id int) (*pipelineConfig.Pipeline, error)

+ func (_m *PipelineRepository) FindDeploymentTypeByPipelineIds(cdPipelineIds []int) (map[int]pipelineConfig.DeploymentObject, error)

+ func (_m *PipelineRepository) FindWithEnvironmentByCiIds(ctx context.Context, cIPipelineIds []int) ([]*pipelineConfig.Pipeline, error)

+ func (_m *PipelineRepository) UpdateOldCiPipelineIdToNewCiPipelineId(tx *pg.Tx, oldCiPipelineId int, newCiPipelineId int) error

v0.7.0

Jun 7, 2024

Changes in this version

type CiPipelineRepository

+ func (_m *CiPipelineRepository) CheckIfPipelineExistsByNameAndAppId(pipelineName string, appId int) (bool, error)

+ func (_m *CiPipelineRepository) CommitTx(tx *pg.Tx) error

+ func (_m *CiPipelineRepository) FindByIdIncludingInActive(id int) (*pipelineConfig.CiPipeline, error)

+ func (_m *CiPipelineRepository) FindByParentIdAndType(parentCiPipelineId int, pipelineType string) ([]*pipelineConfig.CiPipeline, error)

+ func (_m *CiPipelineRepository) FindCiPipelineByAppIdAndEnvIds(appId int, envIds []int) ([]*pipelineConfig.CiPipeline, error)

+ func (_m *CiPipelineRepository) FindLinkedCiCount(ciPipelineId int) (int, error)

+ func (_m *CiPipelineRepository) FindOneWithAppData(id int) (*pipelineConfig.CiPipeline, error)

+ func (_m *CiPipelineRepository) GetDownStreamInfo(ctx context.Context, sourceCiPipelineId int, limit int, offset int, ...) ([]bean.LinkedCIDetails, int, error)

+ func (_m *CiPipelineRepository) GetLinkedCiPipelines(ctx context.Context, ciPipelineId int) ([]*pipelineConfig.CiPipeline, error)

+ func (_m *CiPipelineRepository) RollbackTx(tx *pg.Tx) error

+ func (_m *CiPipelineRepository) StartTx() (*pg.Tx, error)

v0.6.29

Apr 13, 2024

v0.6.28

Mar 13, 2024

v0.6.27

Jan 30, 2024

v0.6.27-rc.0

Dec 15, 2023

v0.6.26

Dec 14, 2023

v0.6.25

Dec 7, 2023

v0.6.25-rc.0

Oct 30, 2023

v0.6.24

Oct 29, 2023

v0.6.23

Oct 20, 2023

v0.6.23-rc.0

Sep 15, 2023

v0.6.22

Sep 14, 2023

v0.6.21

Aug 23, 2023

Changes in this version

type CiPipelineRepository

+ func (_m *CiPipelineRepository) FindCiEnvMappingByCiPipelineId(ciPipelineId int) (*pipelineConfig.CiEnvMapping, error)

+ func (_m *CiPipelineRepository) SaveCiEnvMapping(cienvmapping *pipelineConfig.CiEnvMapping, tx *pg.Tx) error

+ func (_m *CiPipelineRepository) UpdateCiEnvMapping(cienvmapping *pipelineConfig.CiEnvMapping, tx *pg.Tx) error

+ type MockCiPipelineMaterialRepository struct

+ func NewMockCiPipelineMaterialRepository(ctrl *gomock.Controller) *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 struct

+ 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

v0.6.20

Aug 13, 2023

v0.6.19

Jul 17, 2023

Changes in this version

+ type CiPipelineRepository struct

+ func NewCiPipelineRepository(t mockConstructorTestingTNewCiPipelineRepository) *CiPipelineRepository

+ func (_m *CiPipelineRepository) FetchCiPipelinesForDG(parentId int, childCiPipelineIds []int) (*pipelineConfig.CiPipeline, int, error)

+ func (_m *CiPipelineRepository) FetchParentCiPipelinesForDG() ([]*pipelineConfig.CiPipelinesMap, error)

+ func (_m *CiPipelineRepository) FinDByParentCiPipelineAndAppId(parentCiPipeline int, appIds []int) ([]*pipelineConfig.CiPipeline, error)

+ func (_m *CiPipelineRepository) FindAllPipelineInLast24Hour() ([]*pipelineConfig.CiPipeline, 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) 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) 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) FindNumberOfAppsWithCiPipeline(appIds []int) (int, 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) GetExternalCiPipelineByArtifactId(artifactId int) (*pipelineConfig.ExternalCiPipeline, error)

+ func (_m *CiPipelineRepository) MarkCiPipelineScriptsInactiveByCiPipelineId(ciPipelineId int, tx *pg.Tx) error

+ func (_m *CiPipelineRepository) PipelineExistsByName(names []string) ([]string, error)

+ func (_m *CiPipelineRepository) Save(pipeline *pipelineConfig.CiPipeline, 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) Update(pipeline *pipelineConfig.CiPipeline, 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)

v0.6.18

Jul 3, 2023

v0.6.18-rc.4

Jun 28, 2023

v0.6.18-rc.3

Jun 27, 2023

v0.6.18-rc.2

Jun 14, 2023

v0.6.18-rc.1

Jun 9, 2023

v0.6.18-rc.0

Jun 1, 2023

v0.6.17

Jun 1, 2023

Changes in this version

type CiWorkflowRepository

+ func (_m *CiWorkflowRepository) FindCiWorkflowGitTriggersById(id int) (*pipelineConfig.CiWorkflow, error)

+ func (_m *CiWorkflowRepository) FindLastTriggeredWorkflowGitTriggersByArtifactId(ciArtifactId int) (*pipelineConfig.CiWorkflow, error)

type PipelineRepository

+ func (_m *PipelineRepository) FilterDeploymentDeleteRequestedPipelineIds(cdPipelineIds []int) (map[int]bool, error)

+ func (_m *PipelineRepository) FindActiveByEnvIds(envId []int) ([]*pipelineConfig.Pipeline, error)

+ func (_m *PipelineRepository) FindAppAndEnvDetailsByPipelineId(id int) (*pipelineConfig.Pipeline, error)

+ func (_m *PipelineRepository) GetPostStageConfigById(id int) (*pipelineConfig.Pipeline, error)

+ func (_m *PipelineRepository) SetDeploymentAppCreatedInPipeline(deploymentAppCreated bool, pipelineId int, userId int32) error

+ func (_m *PipelineRepository) UpdateCdPipelineAfterDeployment(deploymentAppType string, cdPipelineIdIncludes []int, userId int32, ...) error

v0.6.17-rc.0

May 25, 2023

v0.6.16

May 23, 2023

v0.6.15

Apr 11, 2023

Changes in this version

type PipelineRepository

+ func (_m *PipelineRepository) FindAppAndEnvironmentAndProjectByPipelineIds(pipelineIds []int) (pipelines []*pipelineConfig.Pipeline, err error)

v0.6.14

Mar 28, 2023

v0.6.13

Feb 28, 2023

Changes in this version

type PipelineRepository

+ func (_m *PipelineRepository) FindActiveByAppIds(appIds []int) (pipelines []*pipelineConfig.Pipeline, err error)

+ func (_m *PipelineRepository) FindActiveByEnvIdAndDeploymentType(environmentId int, deploymentAppType string, exclusionList []int, ...) ([]*pipelineConfig.Pipeline, error)

+ func (_m *PipelineRepository) GetPartiallyDeletedPipelineByStatus(appId int, envId int) (pipelineConfig.Pipeline, error)

+ func (_m *PipelineRepository) UpdateCdPipelineDeploymentAppInFilter(deploymentAppType string, cdPipelineIdIncludes []int, userId int32) error

v0.6.12

Feb 27, 2023

v0.6.11

Jan 31, 2023

Changes in this version

+ type CdWorkflowRepository struct

+ func NewCdWorkflowRepository(t mockConstructorTestingTNewCdWorkflowRepository) *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(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(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 PipelineRepository

+ func (_m *PipelineRepository) GetArgoPipelineByArgoAppName(argoAppName string) (pipelineConfig.Pipeline, error)

+ func (_m *PipelineRepository) GetArgoPipelinesHavingLatestTriggerStuckInNonTerminalStatuses(deployedBeforeMinutes int) ([]*pipelineConfig.Pipeline, error)

+ func (_m *PipelineRepository) GetArgoPipelinesHavingTriggersStuckInLastPossibleNonTerminalTimelines(pendingSinceSeconds int, timeForDegradation int) ([]*pipelineConfig.Pipeline, error)

+ type PipelineStatusTimelineRepository struct

+ func NewPipelineStatusTimelineRepository(t mockConstructorTestingTNewPipelineStatusTimelineRepository) *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

v0.6.11-rc.0

Jan 17, 2023

v0.6.10

Jan 9, 2023

Changes in this version

+ type CiWorkflowRepository struct

+ func NewCiWorkflowRepository(t mockConstructorTestingTNewCiWorkflowRepository) *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) 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) SaveWorkFlow(wf *pipelineConfig.CiWorkflow) error

+ func (_m *CiWorkflowRepository) SaveWorkFlowConfig(config *pipelineConfig.CiWorkflowConfig) error

+ func (_m *CiWorkflowRepository) UpdateWorkFlow(wf *pipelineConfig.CiWorkflow) error

v0.6.10-rc.1

Jan 3, 2023

v0.6.10-rc.0

Dec 21, 2022

v0.6.9

Dec 14, 2022

Changes in this version

+ type PipelineRepository struct

+ func NewPipelineRepository(t mockConstructorTestingTNewPipelineRepository) *PipelineRepository

+ func (_m *PipelineRepository) Delete(id int, tx *pg.Tx) 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) FindActiveByEnvId(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) 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) 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) GetPipelineIdsHavingStatusTimelinesPendingAfterKubectlApplyStatus(pendingSinceSeconds int) ([]int, error)

+ func (_m *PipelineRepository) PipelineExists(pipelineName string) (bool, error)

+ func (_m *PipelineRepository) Save(pipeline []*pipelineConfig.Pipeline, tx *pg.Tx) 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) UpdateCdPipeline(pipeline *pipelineConfig.Pipeline) error

v0.6.9-rc.2

Dec 9, 2022

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL