Documentation
¶
Index ¶
- type ApplicationDetail
- type ApplicationStatusUpdateHandler
- type ApplicationStatusUpdateHandlerImpl
- type CiCompleteEvent
- type CiEventHandler
- type CiEventHandlerImpl
- type CronBasedEventReceiver
- type CronBasedEventReceiverImpl
- type GitWebhookHandler
- type GitWebhookHandlerImpl
- 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"` OldApplication *v1alpha12.Application `json:"oldApplication"` }
type ApplicationStatusUpdateHandler ¶
type ApplicationStatusUpdateHandler interface {
Subscribe() error
}
type ApplicationStatusUpdateHandlerImpl ¶
type ApplicationStatusUpdateHandlerImpl struct {
// contains filtered or unexported fields
}
func NewApplicationStatusUpdateHandlerImpl ¶
func NewApplicationStatusUpdateHandlerImpl(logger *zap.SugaredLogger, pubsubClient *pubsub.PubSubClient, appService app.AppService, workflowDagExecutor pipeline.WorkflowDagExecutor, installedAppService service.InstalledAppService) *ApplicationStatusUpdateHandlerImpl
func (*ApplicationStatusUpdateHandlerImpl) Subscribe ¶
func (impl *ApplicationStatusUpdateHandlerImpl) Subscribe() error
type CiCompleteEvent ¶
type CiCompleteEvent struct { CiProjectDetails []pipeline.CiProjectDetails `json:"ciProjectDetails"` DockerImage string `json:"dockerImage" validate:"required"` Digest string `json:"digest" validate:"required"` PipelineId int `json:"pipelineId"` WorkflowId *int `json:"workflowId"` TriggeredBy int32 `json:"triggeredBy"` PipelineName string `json:"pipelineName"` DataSource string `json:"dataSource"` MaterialType string `json:"materialType" validate:"required"` }
type CiEventHandler ¶
type CiEventHandler interface { Subscribe() error BuildCiArtifactRequest(event CiCompleteEvent) (*pipeline.CiArtifactWebhookRequest, error) }
type CiEventHandlerImpl ¶
type CiEventHandlerImpl struct {
// contains filtered or unexported fields
}
func NewCiEventHandlerImpl ¶
func NewCiEventHandlerImpl(logger *zap.SugaredLogger, pubsubClient *pubsub.PubSubClient, webhookService pipeline.WebhookService) *CiEventHandlerImpl
func (*CiEventHandlerImpl) BuildCiArtifactRequest ¶
func (impl *CiEventHandlerImpl) BuildCiArtifactRequest(event CiCompleteEvent) (*pipeline.CiArtifactWebhookRequest, error)
func (*CiEventHandlerImpl) Subscribe ¶
func (impl *CiEventHandlerImpl) Subscribe() error
type CronBasedEventReceiver ¶
type CronBasedEventReceiver interface {
Subscribe() error
}
type CronBasedEventReceiverImpl ¶
type CronBasedEventReceiverImpl struct {
// contains filtered or unexported fields
}
func NewCronBasedEventReceiverImpl ¶
func NewCronBasedEventReceiverImpl(logger *zap.SugaredLogger, pubsubClient *pubsub.PubSubClient, eventService event.EventService) *CronBasedEventReceiverImpl
func (*CronBasedEventReceiverImpl) Subscribe ¶
func (impl *CronBasedEventReceiverImpl) 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.PubSubClient, gitWebhookService git.GitWebhookService) *GitWebhookHandlerImpl
func (*GitWebhookHandlerImpl) Subscribe ¶
func (impl *GitWebhookHandlerImpl) Subscribe() error
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.PubSubClient, 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.