status

package
v0.7.1 Latest Latest
Warning

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

 Go to latest Published: Jul 10, 2024 License: Apache-2.0 Imports: 14 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                       timelineStatus.TimelineStatus `json:"status"`
	StatusDetail                 string                        `json:"statusDetail"`
	StatusTime                   time.Time                     `json:"statusTime"`
	ResourceDetails              []*SyncStageResourceDetailDto `json:"resourceDetails,omitempty"`
}

type PipelineStatusTimelineResourcesService 

type PipelineStatusTimelineResourcesService interface {
	SaveOrUpdatePipelineTimelineResources(runnerHistoryId 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(runnerHistoryId int, application *v1alpha1.Application, tx *pg.Tx, userId int32, isAppStore bool) error

type PipelineStatusTimelineService 

type PipelineStatusTimelineService interface {
	SaveTimeline(timeline *pipelineConfig.PipelineStatusTimeline, tx *pg.Tx) error
	FetchTimelines(appId, envId, wfrId int, showTimeline bool) (*PipelineTimelineDetailDto, error)
	FetchTimelinesForAppStore(installedAppId, envId, installedAppVersionHistoryId int, showTimeline bool) (*PipelineTimelineDetailDto, error)
	NewDevtronAppPipelineStatusTimelineDbObject(cdWorkflowRunnerId int, timelineStatus timelineStatus.TimelineStatus, timelineDescription string, userId int32) *pipelineConfig.PipelineStatusTimeline
	NewHelmAppDeploymentStatusTimelineDbObject(installedAppVersionHistoryId int, timelineStatus timelineStatus.TimelineStatus, timelineDescription string, userId int32) *pipelineConfig.PipelineStatusTimeline
	SaveTimelineIfNotAlreadyPresent(timeline *pipelineConfig.PipelineStatusTimeline, tx *pg.Tx) (isTimelineUpdated bool, err error)
	GetArgoAppSyncStatus(cdWfrId int) bool
	GetTimelineStatusesFor(request *bean.TimelineGetRequest) ([]timelineStatus.TimelineStatus, error)
	GetArgoAppSyncStatusForAppStore(installedAppVersionHistoryId int) bool
	SaveMultipleTimelinesIfNotAlreadyPresent(timelines []*pipelineConfig.PipelineStatusTimeline, tx *pg.Tx) error

	MarkPipelineStatusTimelineFailed(cdWfrId int, statusDetailMessage string) error
	MarkPipelineStatusTimelineSuperseded(cdWfrId int) error
}

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) GetArgoAppSyncStatus added in v0.6.28 

func (impl *PipelineStatusTimelineServiceImpl) GetArgoAppSyncStatus(cdWfrId int) bool

func (*PipelineStatusTimelineServiceImpl) GetArgoAppSyncStatusForAppStore added in v0.6.28 

func (impl *PipelineStatusTimelineServiceImpl) GetArgoAppSyncStatusForAppStore(installedAppVersionHistoryId int) bool

func (*PipelineStatusTimelineServiceImpl) GetTimelineStatusesFor added in v0.7.1 

func (impl *PipelineStatusTimelineServiceImpl) GetTimelineStatusesFor(request *bean.TimelineGetRequest) ([]timelineStatus.TimelineStatus, error)

func (*PipelineStatusTimelineServiceImpl) MarkPipelineStatusTimelineFailed added in v0.6.29 

func (impl *PipelineStatusTimelineServiceImpl) MarkPipelineStatusTimelineFailed(cdWfrId int, statusDetailMessage string) error

func (*PipelineStatusTimelineServiceImpl) MarkPipelineStatusTimelineSuperseded added in v0.7.1 

func (impl *PipelineStatusTimelineServiceImpl) MarkPipelineStatusTimelineSuperseded(cdWfrId int) error

func (*PipelineStatusTimelineServiceImpl) NewDevtronAppPipelineStatusTimelineDbObject added in v0.7.1 

func (impl *PipelineStatusTimelineServiceImpl) NewDevtronAppPipelineStatusTimelineDbObject(cdWorkflowRunnerId int, timelineStatus timelineStatus.TimelineStatus, timelineDescription string, userId int32) *pipelineConfig.PipelineStatusTimeline

func (*PipelineStatusTimelineServiceImpl) NewHelmAppDeploymentStatusTimelineDbObject added in v0.7.1 

func (impl *PipelineStatusTimelineServiceImpl) NewHelmAppDeploymentStatusTimelineDbObject(installedAppVersionHistoryId int, timelineStatus timelineStatus.TimelineStatus, timelineDescription string, userId int32) *pipelineConfig.PipelineStatusTimeline

func (*PipelineStatusTimelineServiceImpl) SaveMultipleTimelinesIfNotAlreadyPresent added in v0.7.1 

func (impl *PipelineStatusTimelineServiceImpl) SaveMultipleTimelinesIfNotAlreadyPresent(timelines []*pipelineConfig.PipelineStatusTimeline, tx *pg.Tx) error

func (*PipelineStatusTimelineServiceImpl) SaveTimeline 

func (impl *PipelineStatusTimelineServiceImpl) SaveTimeline(timeline *pipelineConfig.PipelineStatusTimeline, tx *pg.Tx) error

func (*PipelineStatusTimelineServiceImpl) SaveTimelineIfNotAlreadyPresent added in v0.7.1 

func (impl *PipelineStatusTimelineServiceImpl) SaveTimelineIfNotAlreadyPresent(timeline *pipelineConfig.PipelineStatusTimeline, tx *pg.Tx) (isTimelineUpdated bool, err 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

Directories

Path Synopsis

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.