status

package
v0.6.23 Latest Latest
Warning

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

 Go to latest Published: Oct 20, 2023 License: Apache-2.0 Imports: 11 Imported by: 0

Documentation

Index

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 (impl *PipelineStatusSyncDetailServiceImpl) GetSyncTimeAndCountByCdWfrId(cdWfrId int) (time.Time, int, error)

func (*PipelineStatusSyncDetailServiceImpl) GetSyncTimeAndCountByInstalledAppVersionHistoryId 

func (impl *PipelineStatusSyncDetailServiceImpl) GetSyncTimeAndCountByInstalledAppVersionHistoryId(installedAppVersionHistoryId int) (time.Time, int, error)

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"`
}

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.