pubsub

Documentation

Index

• type ApplicationStatusUpdateHandler
• type ApplicationStatusUpdateHandlerImpl
  • func NewApplicationStatusUpdateHandlerImpl(logger *zap.SugaredLogger, appService app.AppService, ...) *ApplicationStatusUpdateHandlerImpl
  • func (impl *ApplicationStatusUpdateHandlerImpl) Subscribe() error
• type CiCompleteEvent
• type CiEventHandler
• type CiEventHandlerImpl
  • func NewCiEventHandlerImpl(logger *zap.SugaredLogger, webhookService pipeline.WebhookService) *CiEventHandlerImpl
  • func (impl *CiEventHandlerImpl) BuildCiArtifactRequest(event CiCompleteEvent) (*pipeline.CiArtifactWebhookRequest, error)
  • func (impl *CiEventHandlerImpl) Subscribe() error
• type CronBasedEventReceiver
• type CronBasedEventReceiverImpl
  • func NewCronBasedEventReceiverImpl(logger *zap.SugaredLogger, eventService event.EventService) *CronBasedEventReceiverImpl
  • func (impl *CronBasedEventReceiverImpl) Subscribe() error
• type GitWebhookHandler
• type GitWebhookHandlerImpl
  • func NewGitWebhookHandler(logger *zap.SugaredLogger, gitWebhookService git.GitWebhookService) *GitWebhookHandlerImpl
  • func (impl *GitWebhookHandlerImpl) Subscribe() error
• type WorkflowStatusUpdateHandler
• type WorkflowStatusUpdateHandlerImpl
  • func NewWorkflowStatusUpdateHandlerImpl(logger *zap.SugaredLogger, ciHandler pipeline.CiHandler, ...) *WorkflowStatusUpdateHandlerImpl
  • func (impl *WorkflowStatusUpdateHandlerImpl) Subscribe() error
  • func (impl *WorkflowStatusUpdateHandlerImpl) SubscribeCD() error

Types

type ApplicationStatusUpdateHandler

type ApplicationStatusUpdateHandler interface {
	Subscribe() error
}

type ApplicationStatusUpdateHandlerImpl

type ApplicationStatusUpdateHandlerImpl struct {
	// contains filtered or unexported fields
}

func NewApplicationStatusUpdateHandlerImpl

func NewApplicationStatusUpdateHandlerImpl(logger *zap.SugaredLogger, 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, 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, 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, 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, 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