Affected by 
Documentation
¶
Index ¶
- Variables
- type WorkflowEventPublishService
- type WorkflowEventPublishServiceImpl
- func (impl *WorkflowEventPublishServiceImpl) TriggerBulkDeploymentAsync(requests []*bean.BulkTriggerRequest, UserId int32) (interface{}, error)
- func (impl *WorkflowEventPublishServiceImpl) TriggerBulkHibernateAsync(request bean.StopDeploymentGroupRequest) (interface{}, error)
- func (impl *WorkflowEventPublishServiceImpl) TriggerHelmAsyncRelease(overrideRequest *bean3.ValuesOverrideRequest, ctx context.Context, ...) (releaseNo int, manifest []byte, err error)
- func (impl *WorkflowEventPublishServiceImpl) UpdatePreviousQueuedRunnerStatus(cdWfrId, pipelineId int, triggeredBy int32) error
Constants ¶
This section is empty.
Variables ¶
View Source
var EventProcessorOutWireSet = wire.NewSet( NewWorkflowEventPublishServiceImpl, wire.Bind(new(WorkflowEventPublishService), new(*WorkflowEventPublishServiceImpl)), )
Functions ¶
This section is empty.
Types ¶
type WorkflowEventPublishService ¶
type WorkflowEventPublishService interface {
TriggerBulkHibernateAsync(request bean.StopDeploymentGroupRequest) (interface{}, error)
TriggerHelmAsyncRelease(overrideRequest *bean3.ValuesOverrideRequest, ctx context.Context, triggeredAt time.Time,
triggeredBy int32) (releaseNo int, manifest []byte, err error)
TriggerBulkDeploymentAsync(requests []*bean.BulkTriggerRequest, UserId int32) (interface{}, error)
}
type WorkflowEventPublishServiceImpl ¶
type WorkflowEventPublishServiceImpl struct {
// contains filtered or unexported fields
}
func NewWorkflowEventPublishServiceImpl ¶
func NewWorkflowEventPublishServiceImpl(logger *zap.SugaredLogger, pubSubClient *pubsub.PubSubClientServiceImpl, cdWorkflowCommonService cd.CdWorkflowCommonService, deployedConfigurationHistoryService history.DeployedConfigurationHistoryService, manifestCreationService manifest.ManifestCreationService, pipelineStatusTimelineService status.PipelineStatusTimelineService, cdWorkflowRepository pipelineConfig.CdWorkflowRepository, pipelineRepository pipelineConfig.PipelineRepository, groupRepository repository.DeploymentGroupRepository) (*WorkflowEventPublishServiceImpl, error)
func (*WorkflowEventPublishServiceImpl) TriggerBulkDeploymentAsync ¶
func (impl *WorkflowEventPublishServiceImpl) TriggerBulkDeploymentAsync(requests []*bean.BulkTriggerRequest, UserId int32) (interface{}, error)
func (*WorkflowEventPublishServiceImpl) TriggerBulkHibernateAsync ¶
func (impl *WorkflowEventPublishServiceImpl) TriggerBulkHibernateAsync(request bean.StopDeploymentGroupRequest) (interface{}, error)
func (*WorkflowEventPublishServiceImpl) TriggerHelmAsyncRelease ¶
func (impl *WorkflowEventPublishServiceImpl) TriggerHelmAsyncRelease(overrideRequest *bean3.ValuesOverrideRequest, ctx context.Context, triggeredAt time.Time, triggeredBy int32) (releaseNo int, manifest []byte, err error)
TriggerHelmAsyncRelease will publish async helm Install/Upgrade request event for Devtron App releases
func (*WorkflowEventPublishServiceImpl) UpdatePreviousQueuedRunnerStatus ¶
func (impl *WorkflowEventPublishServiceImpl) UpdatePreviousQueuedRunnerStatus(cdWfrId, pipelineId int, triggeredBy int32) error
Source Files
Directories
Click to show internal directories.
Click to hide internal directories.