pubsub

Documentation

Index

• Constants
• 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) Subscribe() error
• type CronBasedEventReceiver
• type CronBasedEventReceiverImpl
  • func NewCronBasedEventReceiverImpl(logger *zap.SugaredLogger, pubsubClient *pubsub.PubSubClient, ...) *CronBasedEventReceiverImpl
  • func (impl *CronBasedEventReceiverImpl) 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

Constants

const CI_COMPLETE_DURABLE = "CI-RUNNER.CI-COMPLETE_DURABLE-1"

const CI_COMPLETE_GROUP = "CI-RUNNER.CI-COMPLETE_GROUP-1"

const CI_COMPLETE_TOPIC = "CI-RUNNER.CI-COMPLETE"

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, pubsubClient *pubsub.PubSubClient, appService app.AppService,
	workflowDagExecutor pipeline.WorkflowDagExecutor) *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