pubsub

Documentation

Index

• type ApplicationDetail
• type ApplicationStatusHandler
• type ApplicationStatusHandlerImpl
  • func NewApplicationStatusHandlerImpl(logger *zap.SugaredLogger, pubsubClient *pubsub.PubSubClientServiceImpl, ...) *ApplicationStatusHandlerImpl
  • func (impl *ApplicationStatusHandlerImpl) Subscribe() error
  • func (impl *ApplicationStatusHandlerImpl) SubscribeDeleteStatus() error
• type GitWebhookHandler
• type GitWebhookHandlerImpl
  • func NewGitWebhookHandler(logger *zap.SugaredLogger, pubsubClient *pubsub.PubSubClientServiceImpl, ...) *GitWebhookHandlerImpl
  • func (impl *GitWebhookHandlerImpl) Subscribe() error

Types

type ApplicationDetail

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

type ApplicationStatusHandler

type ApplicationStatusHandler interface {
	Subscribe() error
	SubscribeDeleteStatus() error
}

type ApplicationStatusHandlerImpl

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

func NewApplicationStatusHandlerImpl

func NewApplicationStatusHandlerImpl(logger *zap.SugaredLogger, pubsubClient *pubsub.PubSubClientServiceImpl, appService app.AppService,
	workflowDagExecutor dag.WorkflowDagExecutor, installedAppService FullMode.InstalledAppDBExtendedService,
	appStoreDeploymentService service.AppStoreDeploymentService, pipelineBuilder pipeline.PipelineBuilder,
	pipelineRepository pipelineConfig.PipelineRepository, installedAppRepository repository4.InstalledAppRepository,
	cdWorkflowCommonService cd.CdWorkflowCommonService) *ApplicationStatusHandlerImpl

func (*ApplicationStatusHandlerImpl) Subscribe

func (impl *ApplicationStatusHandlerImpl) Subscribe() error

func (*ApplicationStatusHandlerImpl) SubscribeDeleteStatus

func (impl *ApplicationStatusHandlerImpl) SubscribeDeleteStatus() 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