Documentation
¶
Index ¶
- type ApplicationDetail
- type ApplicationStatusHandler
- type ApplicationStatusHandlerImpl
- type CiCompleteEvent
- type CiEventConfig
- type CiEventHandler
- type CiEventHandlerImpl
- func (impl *CiEventHandlerImpl) BuildCIArtifactRequestForImageFromCR(imageDetails types.ImageDetail, region string, event CiCompleteEvent, ...) (*pipeline.CiArtifactWebhookRequest, error)
- func (impl *CiEventHandlerImpl) BuildCiArtifactRequest(event CiCompleteEvent) (*pipeline.CiArtifactWebhookRequest, error)
- func (impl *CiEventHandlerImpl) BuildCiArtifactRequestForWebhook(event CiCompleteEvent) (*pipeline.CiArtifactWebhookRequest, error)
- func (impl *CiEventHandlerImpl) Subscribe() error
- type GitWebhookHandler
- type GitWebhookHandlerImpl
- type ImageDetailsFromCR
- type WorkflowStatusUpdateHandler
- type WorkflowStatusUpdateHandlerImpl
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type ApplicationDetail ¶ added in v0.4.28
type ApplicationDetail struct { Application *v1alpha12.Application `json:"application"` StatusTime time.Time `json:"statusTime"` }
type ApplicationStatusHandler ¶ added in v0.6.13
type ApplicationStatusHandlerImpl ¶ added in v0.6.13
type ApplicationStatusHandlerImpl struct {
// contains filtered or unexported fields
}
func NewApplicationStatusHandlerImpl ¶ added in v0.6.13
func NewApplicationStatusHandlerImpl(logger *zap.SugaredLogger, pubsubClient *pubsub.PubSubClientServiceImpl, appService app.AppService, workflowDagExecutor pipeline.WorkflowDagExecutor, installedAppService service.InstalledAppService, appStoreDeploymentService service.AppStoreDeploymentService, pipelineBuilder pipeline.PipelineBuilder, pipelineRepository pipelineConfig.PipelineRepository, installedAppRepository repository4.InstalledAppRepository) *ApplicationStatusHandlerImpl
func (*ApplicationStatusHandlerImpl) Subscribe ¶ added in v0.6.13
func (impl *ApplicationStatusHandlerImpl) Subscribe() error
func (*ApplicationStatusHandlerImpl) SubscribeDeleteStatus ¶ added in v0.6.13
func (impl *ApplicationStatusHandlerImpl) SubscribeDeleteStatus() error
type CiCompleteEvent ¶
type CiCompleteEvent struct { CiProjectDetails []bean2.CiProjectDetails `json:"ciProjectDetails"` DockerImage string `json:"dockerImage" validate:"required,image-validator"` Digest string `json:"digest"` PipelineId int `json:"pipelineId"` WorkflowId *int `json:"workflowId"` TriggeredBy int32 `json:"triggeredBy"` PipelineName string `json:"pipelineName"` DataSource string `json:"dataSource"` MaterialType string `json:"materialType"` Metrics util.CIMetrics `json:"metrics"` AppName string `json:"appName"` IsArtifactUploaded bool `json:"isArtifactUploaded"` FailureReason string `json:"failureReason"` ImageDetailsFromCR *ImageDetailsFromCR `json:"imageDetailsFromCR"` }
type CiEventConfig ¶ added in v0.6.15
type CiEventConfig struct {
ExposeCiMetrics bool `env:"EXPOSE_CI_METRICS" envDefault:"false"`
}
func GetCiEventConfig ¶ added in v0.6.15
func GetCiEventConfig() (*CiEventConfig, error)
type CiEventHandler ¶
type CiEventHandler interface { Subscribe() error BuildCiArtifactRequest(event CiCompleteEvent) (*pipeline.CiArtifactWebhookRequest, error) BuildCiArtifactRequestForWebhook(event CiCompleteEvent) (*pipeline.CiArtifactWebhookRequest, error) }
type CiEventHandlerImpl ¶
type CiEventHandlerImpl struct {
// contains filtered or unexported fields
}
func NewCiEventHandlerImpl ¶
func NewCiEventHandlerImpl(logger *zap.SugaredLogger, pubsubClient *pubsub.PubSubClientServiceImpl, webhookService pipeline.WebhookService, ciEventConfig *CiEventConfig) *CiEventHandlerImpl
func (*CiEventHandlerImpl) BuildCIArtifactRequestForImageFromCR ¶ added in v0.6.24
func (impl *CiEventHandlerImpl) BuildCIArtifactRequestForImageFromCR(imageDetails types.ImageDetail, region string, event CiCompleteEvent, workflowId int) (*pipeline.CiArtifactWebhookRequest, error)
func (*CiEventHandlerImpl) BuildCiArtifactRequest ¶
func (impl *CiEventHandlerImpl) BuildCiArtifactRequest(event CiCompleteEvent) (*pipeline.CiArtifactWebhookRequest, error)
func (*CiEventHandlerImpl) BuildCiArtifactRequestForWebhook ¶ added in v0.6.9
func (impl *CiEventHandlerImpl) BuildCiArtifactRequestForWebhook(event CiCompleteEvent) (*pipeline.CiArtifactWebhookRequest, error)
func (*CiEventHandlerImpl) Subscribe ¶
func (impl *CiEventHandlerImpl) Subscribe() error
type GitWebhookHandler ¶
type GitWebhookHandler interface {
Subscribe() error
}
type GitWebhookHandlerImpl ¶
type GitWebhookHandlerImpl struct {
// contains filtered or unexported fields
}
func NewGitWebhookHandler ¶
func NewGitWebhookHandler(logger *zap.SugaredLogger, pubsubClient *pubsub.PubSubClientServiceImpl, gitWebhookService git.GitWebhookService) *GitWebhookHandlerImpl
func (*GitWebhookHandlerImpl) Subscribe ¶
func (impl *GitWebhookHandlerImpl) Subscribe() error
type ImageDetailsFromCR ¶ added in v0.6.24
type ImageDetailsFromCR struct { ImageDetails []types.ImageDetail `json:"imageDetails"` Region string `json:"region"` }
type WorkflowStatusUpdateHandler ¶
type WorkflowStatusUpdateHandler interface {
Subscribe() error
}
type WorkflowStatusUpdateHandlerImpl ¶
type WorkflowStatusUpdateHandlerImpl struct {
// contains filtered or unexported fields
}
func NewWorkflowStatusUpdateHandlerImpl ¶
func NewWorkflowStatusUpdateHandlerImpl(logger *zap.SugaredLogger, pubsubClient *pubsub.PubSubClientServiceImpl, ciHandler pipeline.CiHandler, cdHandler pipeline.CdHandler, eventFactory client.EventFactory, eventClient client.EventClient, cdWorkflowRepository pipelineConfig.CdWorkflowRepository) *WorkflowStatusUpdateHandlerImpl
func (*WorkflowStatusUpdateHandlerImpl) Subscribe ¶
func (impl *WorkflowStatusUpdateHandlerImpl) Subscribe() error
func (*WorkflowStatusUpdateHandlerImpl) SubscribeCD ¶
func (impl *WorkflowStatusUpdateHandlerImpl) SubscribeCD() error
Click to show internal directories.
Click to hide internal directories.