pubsub

package
v0.6.28 Latest Latest
Warning

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

 Go to latest Published: Mar 13, 2024 License: Apache-2.0 Imports: 32 Imported by: 9

Documentation

Index

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 ApplicationStatusHandler interface {
	Subscribe() error
	SubscribeDeleteStatus() error
}

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"`
	PluginRegistryArtifactDetails map[string][]string      `json:"PluginRegistryArtifactDetails"`
	PluginArtifactStage           string                   `json:"pluginArtifactStage"`
}

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, validator *validator.Validate, 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

func (*CiEventHandlerImpl) ValidateAndHandleCiSuccessEvent added in v0.6.28 

func (impl *CiEventHandlerImpl) ValidateAndHandleCiSuccessEvent(triggerContext pipeline.TriggerContext, ciPipelineId int, request *pipeline.CiArtifactWebhookRequest, imagePushedAt *time.Time) (int, 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

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.