pubsub

Documentation

Index

• type ApplicationDetail
• type ApplicationStatusUpdateHandler
• type ApplicationStatusUpdateHandlerImpl
  • func NewApplicationStatusUpdateHandlerImpl(logger *zap.SugaredLogger, pubsubClient *pubsub.PubSubClient, ...) *ApplicationStatusUpdateHandlerImpl
  • func (impl *ApplicationStatusUpdateHandlerImpl) Subscribe() error
• type CiCompleteEvent
• type CiEventHandler
• type CiEventHandlerImpl
  • func NewCiEventHandlerImpl(logger *zap.SugaredLogger, pubsubClient *pubsub.PubSubClient, ...) *CiEventHandlerImpl
  • 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
  • func NewGitWebhookHandler(logger *zap.SugaredLogger, pubsubClient *pubsub.PubSubClient, ...) *GitWebhookHandlerImpl
  • func (impl *GitWebhookHandlerImpl) Subscribe() error
• type WorkflowStatusUpdateHandler
• type WorkflowStatusUpdateHandlerImpl
  • func NewWorkflowStatusUpdateHandlerImpl(logger *zap.SugaredLogger, pubsubClient *pubsub.PubSubClient, ...) *WorkflowStatusUpdateHandlerImpl
  • func (impl *WorkflowStatusUpdateHandlerImpl) Subscribe() error
  • func (impl *WorkflowStatusUpdateHandlerImpl) SubscribeCD() error

Types

type ApplicationDetail

type ApplicationDetail struct {
	Application *v1alpha12.Application `json:"application"`
	StatusTime  time.Time              `json:"statusTime"`
}

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,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"`
}

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.PubSubClient, webhookService pipeline.WebhookService) *CiEventHandlerImpl

func (*CiEventHandlerImpl) BuildCiArtifactRequest

func (impl *CiEventHandlerImpl) BuildCiArtifactRequest(event CiCompleteEvent) (*pipeline.CiArtifactWebhookRequest, error)

func (*CiEventHandlerImpl) BuildCiArtifactRequestForWebhook

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