pubsub

package
v0.6.18-rc.4 Latest Latest
Warning

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

 Go to latest Published: Jun 28, 2023 License: Apache-2.0 Imports: 26 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   []pipeline.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"`
}

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) 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 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.