Documentation
¶
Index ¶
- type PipelineStatusSyncDetailService
- type PipelineStatusSyncDetailServiceImpl
- func (impl *PipelineStatusSyncDetailServiceImpl) GetLastSyncTimeForLatestCdWfrByCdPipelineId(pipelineId int) (time.Time, error)
- func (impl *PipelineStatusSyncDetailServiceImpl) GetLastSyncTimeForLatestInstalledAppVersionHistoryByInstalledAppVersionId(installedAppVersionId int) (time.Time, error)
- func (impl *PipelineStatusSyncDetailServiceImpl) GetSyncTimeAndCountByCdWfrId(cdWfrId int) (time.Time, int, error)
- func (impl *PipelineStatusSyncDetailServiceImpl) GetSyncTimeAndCountByInstalledAppVersionHistoryId(installedAppVersionHistoryId int) (time.Time, int, error)
- func (impl *PipelineStatusSyncDetailServiceImpl) SaveOrUpdateSyncDetail(cdWfrId int, userId int32) error
- func (impl *PipelineStatusSyncDetailServiceImpl) SaveOrUpdateSyncDetailForAppStore(installedAppVersionHistoryId int, userId int32) error
- type PipelineStatusTimelineDto
- type PipelineStatusTimelineResourcesService
- type PipelineStatusTimelineResourcesServiceImpl
- func (impl *PipelineStatusTimelineResourcesServiceImpl) GetTimelineResourcesForATimeline(cdWfrIds []int) (map[int][]*SyncStageResourceDetailDto, error)
- func (impl *PipelineStatusTimelineResourcesServiceImpl) GetTimelineResourcesForATimelineForAppStore(installedAppVersionHistoryId int) ([]*SyncStageResourceDetailDto, error)
- func (impl *PipelineStatusTimelineResourcesServiceImpl) SaveOrUpdatePipelineTimelineResources(pipelineId int, application *v1alpha1.Application, tx *pg.Tx, userId int32, ...) error
- type PipelineStatusTimelineService
- type PipelineStatusTimelineServiceImpl
- func (impl *PipelineStatusTimelineServiceImpl) FetchTimelines(appId, envId, wfrId int, showTimeline bool) (*PipelineTimelineDetailDto, error)
- func (impl *PipelineStatusTimelineServiceImpl) FetchTimelinesForAppStore(installedAppId, envId, installedAppVersionHistoryId int, showTimeline bool) (*PipelineTimelineDetailDto, error)
- func (impl *PipelineStatusTimelineServiceImpl) GetTimelineDbObjectByTimelineStatusAndTimelineDescription(cdWorkflowRunnerId int, timelineStatus pipelineConfig.TimelineStatus, ...) *pipelineConfig.PipelineStatusTimeline
- func (impl *PipelineStatusTimelineServiceImpl) SaveTimeline(timeline *pipelineConfig.PipelineStatusTimeline, tx *pg.Tx, isAppStore bool) error
- type PipelineTimelineDetailDto
- type SyncStageResourceDetailDto
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type PipelineStatusSyncDetailService ¶
type PipelineStatusSyncDetailService interface {
SaveOrUpdateSyncDetail(cdWfrId int, userId int32) error
SaveOrUpdateSyncDetailForAppStore(installedAppVersionHistoryId int, userId int32) error
GetSyncTimeAndCountByCdWfrId(cdWfrId int) (time.Time, int, error)
GetSyncTimeAndCountByInstalledAppVersionHistoryId(installedAppVersionHistoryId int) (time.Time, int, error)
GetLastSyncTimeForLatestCdWfrByCdPipelineId(pipelineId int) (time.Time, error)
GetLastSyncTimeForLatestInstalledAppVersionHistoryByInstalledAppVersionId(installedAppVersionId int) (time.Time, error)
}
type PipelineStatusSyncDetailServiceImpl ¶
type PipelineStatusSyncDetailServiceImpl struct {
// contains filtered or unexported fields
}
func NewPipelineStatusSyncDetailServiceImpl ¶
func NewPipelineStatusSyncDetailServiceImpl(logger *zap.SugaredLogger, pipelineStatusSyncDetailRepository pipelineConfig.PipelineStatusSyncDetailRepository, ) *PipelineStatusSyncDetailServiceImpl
func (*PipelineStatusSyncDetailServiceImpl) GetLastSyncTimeForLatestCdWfrByCdPipelineId ¶
func (impl *PipelineStatusSyncDetailServiceImpl) GetLastSyncTimeForLatestCdWfrByCdPipelineId(pipelineId int) (time.Time, error)
func (*PipelineStatusSyncDetailServiceImpl) GetLastSyncTimeForLatestInstalledAppVersionHistoryByInstalledAppVersionId ¶
func (impl *PipelineStatusSyncDetailServiceImpl) GetLastSyncTimeForLatestInstalledAppVersionHistoryByInstalledAppVersionId(installedAppVersionId int) (time.Time, error)
func (*PipelineStatusSyncDetailServiceImpl) GetSyncTimeAndCountByCdWfrId ¶
func (*PipelineStatusSyncDetailServiceImpl) GetSyncTimeAndCountByInstalledAppVersionHistoryId ¶
func (*PipelineStatusSyncDetailServiceImpl) SaveOrUpdateSyncDetail ¶
func (impl *PipelineStatusSyncDetailServiceImpl) SaveOrUpdateSyncDetail(cdWfrId int, userId int32) error
func (*PipelineStatusSyncDetailServiceImpl) SaveOrUpdateSyncDetailForAppStore ¶
func (impl *PipelineStatusSyncDetailServiceImpl) SaveOrUpdateSyncDetailForAppStore(installedAppVersionHistoryId int, userId int32) error
type PipelineStatusTimelineDto ¶
type PipelineStatusTimelineDto struct {
Id int `json:"id"`
InstalledAppVersionHistoryId int `json:"InstalledAppVersionHistoryId,omitempty"`
CdWorkflowRunnerId int `json:"cdWorkflowRunnerId"`
Status pipelineConfig.TimelineStatus `json:"status"`
StatusDetail string `json:"statusDetail"`
StatusTime time.Time `json:"statusTime"`
ResourceDetails []*SyncStageResourceDetailDto `json:"resourceDetails,omitempty"`
}
type PipelineStatusTimelineResourcesService ¶
type PipelineStatusTimelineResourcesService interface {
SaveOrUpdatePipelineTimelineResources(pipelineId int, application *v1alpha1.Application, tx *pg.Tx, userId int32, isAppStore bool) error
GetTimelineResourcesForATimeline(cdWfrIds []int) (map[int][]*SyncStageResourceDetailDto, error)
GetTimelineResourcesForATimelineForAppStore(installedAppVersionHistoryId int) ([]*SyncStageResourceDetailDto, error)
}
type PipelineStatusTimelineResourcesServiceImpl ¶
type PipelineStatusTimelineResourcesServiceImpl struct {
// contains filtered or unexported fields
}
func NewPipelineStatusTimelineResourcesServiceImpl ¶
func NewPipelineStatusTimelineResourcesServiceImpl(dbConnection *pg.DB, logger *zap.SugaredLogger, pipelineStatusTimelineResourcesRepository pipelineConfig.PipelineStatusTimelineResourcesRepository) *PipelineStatusTimelineResourcesServiceImpl
func (*PipelineStatusTimelineResourcesServiceImpl) GetTimelineResourcesForATimeline ¶
func (impl *PipelineStatusTimelineResourcesServiceImpl) GetTimelineResourcesForATimeline(cdWfrIds []int) (map[int][]*SyncStageResourceDetailDto, error)
func (*PipelineStatusTimelineResourcesServiceImpl) GetTimelineResourcesForATimelineForAppStore ¶
func (impl *PipelineStatusTimelineResourcesServiceImpl) GetTimelineResourcesForATimelineForAppStore(installedAppVersionHistoryId int) ([]*SyncStageResourceDetailDto, error)
func (*PipelineStatusTimelineResourcesServiceImpl) SaveOrUpdatePipelineTimelineResources ¶
func (impl *PipelineStatusTimelineResourcesServiceImpl) SaveOrUpdatePipelineTimelineResources(pipelineId int, application *v1alpha1.Application, tx *pg.Tx, userId int32, isAppStore bool) error
type PipelineStatusTimelineService ¶
type PipelineStatusTimelineService interface {
SaveTimeline(timeline *pipelineConfig.PipelineStatusTimeline, tx *pg.Tx, isAppStore bool) error
FetchTimelines(appId, envId, wfrId int, showTimeline bool) (*PipelineTimelineDetailDto, error)
FetchTimelinesForAppStore(installedAppId, envId, installedAppVersionHistoryId int, showTimeline bool) (*PipelineTimelineDetailDto, error)
GetTimelineDbObjectByTimelineStatusAndTimelineDescription(cdWorkflowRunnerId int, timelineStatus pipelineConfig.TimelineStatus, timelineDescription string, userId int32) *pipelineConfig.PipelineStatusTimeline
}
type PipelineStatusTimelineServiceImpl ¶
type PipelineStatusTimelineServiceImpl struct {
// contains filtered or unexported fields
}
func NewPipelineStatusTimelineServiceImpl ¶
func NewPipelineStatusTimelineServiceImpl(logger *zap.SugaredLogger, pipelineStatusTimelineRepository pipelineConfig.PipelineStatusTimelineRepository, cdWorkflowRepository pipelineConfig.CdWorkflowRepository, userService user.UserService, pipelineStatusTimelineResourcesService PipelineStatusTimelineResourcesService, pipelineStatusSyncDetailService PipelineStatusSyncDetailService, installedAppRepository repository.InstalledAppRepository, installedAppVersionHistory repository.InstalledAppVersionHistoryRepository, ) *PipelineStatusTimelineServiceImpl
func (*PipelineStatusTimelineServiceImpl) FetchTimelines ¶
func (impl *PipelineStatusTimelineServiceImpl) FetchTimelines(appId, envId, wfrId int, showTimeline bool) (*PipelineTimelineDetailDto, error)
func (*PipelineStatusTimelineServiceImpl) FetchTimelinesForAppStore ¶
func (impl *PipelineStatusTimelineServiceImpl) FetchTimelinesForAppStore(installedAppId, envId, installedAppVersionHistoryId int, showTimeline bool) (*PipelineTimelineDetailDto, error)
func (*PipelineStatusTimelineServiceImpl) GetTimelineDbObjectByTimelineStatusAndTimelineDescription ¶
func (impl *PipelineStatusTimelineServiceImpl) GetTimelineDbObjectByTimelineStatusAndTimelineDescription(cdWorkflowRunnerId int, timelineStatus pipelineConfig.TimelineStatus, timelineDescription string, userId int32) *pipelineConfig.PipelineStatusTimeline
func (*PipelineStatusTimelineServiceImpl) SaveTimeline ¶
func (impl *PipelineStatusTimelineServiceImpl) SaveTimeline(timeline *pipelineConfig.PipelineStatusTimeline, tx *pg.Tx, isAppStore bool) error
type PipelineTimelineDetailDto ¶
type PipelineTimelineDetailDto struct {
DeploymentStartedOn time.Time `json:"deploymentStartedOn"`
DeploymentFinishedOn time.Time `json:"deploymentFinishedOn"`
TriggeredBy string `json:"triggeredBy"`
Timelines []*PipelineStatusTimelineDto `json:"timelines"`
StatusLastFetchedAt time.Time `json:"statusLastFetchedAt"`
StatusFetchCount int `json:"statusFetchCount"`
WfrStatus string `json:"wfrStatus"`
DeploymentAppDeleteRequest bool `json:"deploymentAppDeleteRequest"`
}
type SyncStageResourceDetailDto ¶
type SyncStageResourceDetailDto struct {
Id int `json:"id"`
InstalledAppVersionHistoryId int `json:"installedAppVersionHistoryId,omitempty"`
CdWorkflowRunnerId int `json:"cdWorkflowRunnerId,omitempty"`
ResourceName string `json:"resourceName"`
ResourceKind string `json:"resourceKind"`
ResourceGroup string `json:"resourceGroup"`
ResourceStatus string `json:"resourceStatus"`
ResourcePhase string `json:"resourcePhase"`
StatusMessage string `json:"statusMessage"`
TimelineStage pipelineConfig.ResourceTimelineStage `json:"timelineStage,omitempty"`
}
Click to show internal directories.
Click to hide internal directories.