out

package
v0.7.3 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Oct 2, 2024 License: Apache-2.0 Imports: 20 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

Functions

This section is empty.

Types

type AppStoreAppsEventPublishService added in v0.7.0

type AppStoreAppsEventPublishService interface {
	PublishBulkDeployEvent(installAppVersions []*appStoreBean.InstallAppVersionDTO) map[int]error
}

type AppStoreAppsEventPublishServiceImpl added in v0.7.0

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

func NewAppStoreAppsEventPublishServiceImpl added in v0.7.0

func NewAppStoreAppsEventPublishServiceImpl(logger *zap.SugaredLogger,
	pubSubClient *pubsub.PubSubClientServiceImpl) *AppStoreAppsEventPublishServiceImpl

func (*AppStoreAppsEventPublishServiceImpl) PublishBulkDeployEvent added in v0.7.0

func (impl *AppStoreAppsEventPublishServiceImpl) PublishBulkDeployEvent(installAppVersions []*appStoreBean.InstallAppVersionDTO) map[int]error

PublishBulkDeployEvent take installAppVersions and published their event. Response is map of installedAppVersionId along with error in publishing if any

type CDPipelineEventPublishService added in v0.7.0

type CDPipelineEventPublishService interface {
	PublishBulkTriggerTopicEvent(pipelineId, appId,
		artifactId int, userId int32) error

	PublishArgoTypePipelineSyncEvent(pipelineId, installedAppVersionId int,
		userId int32, isAppStoreApplication bool) error
}

type CDPipelineEventPublishServiceImpl added in v0.7.0

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

func NewCDPipelineEventPublishServiceImpl added in v0.7.0

func NewCDPipelineEventPublishServiceImpl(logger *zap.SugaredLogger,
	pubSubClient *pubsub.PubSubClientServiceImpl) *CDPipelineEventPublishServiceImpl

func (*CDPipelineEventPublishServiceImpl) PublishArgoTypePipelineSyncEvent added in v0.7.0

func (impl *CDPipelineEventPublishServiceImpl) PublishArgoTypePipelineSyncEvent(pipelineId, installedAppVersionId int,
	userId int32, isAppStoreApplication bool) error

func (*CDPipelineEventPublishServiceImpl) PublishBulkTriggerTopicEvent added in v0.7.0

func (impl *CDPipelineEventPublishServiceImpl) PublishBulkTriggerTopicEvent(pipelineId, appId,
	artifactId int, userId int32) error

type CIPipelineEventPublishService added in v0.7.0

type CIPipelineEventPublishService interface {
	PublishGitWebhookEvent(gitHostId int, gitHostName string, eventType, requestJSON string) error
}

type CIPipelineEventPublishServiceImpl added in v0.7.0

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

func NewCIPipelineEventPublishServiceImpl added in v0.7.0

func NewCIPipelineEventPublishServiceImpl(logger *zap.SugaredLogger,
	pubSubClient *pubsub.PubSubClientServiceImpl) *CIPipelineEventPublishServiceImpl

func (*CIPipelineEventPublishServiceImpl) PublishGitWebhookEvent added in v0.7.0

func (impl *CIPipelineEventPublishServiceImpl) PublishGitWebhookEvent(gitHostId int, gitHostName string, eventType, requestJSON string) error

type PipelineConfigEventPublishService added in v0.7.0

type PipelineConfigEventPublishService interface {
	PublishCDPipelineDelete(pipelineId int, triggeredBy int32) error
}

type PipelineConfigEventPublishServiceImpl added in v0.7.0

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

func NewPipelineConfigEventPublishServiceImpl added in v0.7.0

func NewPipelineConfigEventPublishServiceImpl(logger *zap.SugaredLogger,
	pubSubClient *pubsub.PubSubClientServiceImpl) *PipelineConfigEventPublishServiceImpl

func (*PipelineConfigEventPublishServiceImpl) PublishCDPipelineDelete added in v0.7.0

func (impl *PipelineConfigEventPublishServiceImpl) PublishCDPipelineDelete(pipelineId int, triggeredBy int32) error

type WorkflowEventPublishService

type WorkflowEventPublishService interface {
	TriggerBulkHibernateAsync(request bean.StopDeploymentGroupRequest) (interface{}, error)
	TriggerAsyncRelease(userDeploymentRequestId int, overrideRequest *apiBean.ValuesOverrideRequest,
		valuesOverrideResponse *app.ValuesOverrideResponse, ctx context.Context, triggeredBy int32) (releaseNo int, 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,
	pipelineStatusTimelineService status.PipelineStatusTimelineService,
	triggerEventEvaluator celEvaluator.TriggerEventEvaluator,

	cdWorkflowRepository pipelineConfig.CdWorkflowRepository,
	pipelineRepository pipelineConfig.PipelineRepository,
	groupRepository repository.DeploymentGroupRepository) (*WorkflowEventPublishServiceImpl, error)

func (*WorkflowEventPublishServiceImpl) TriggerAsyncRelease added in v0.7.1

func (impl *WorkflowEventPublishServiceImpl) TriggerAsyncRelease(userDeploymentRequestId int, overrideRequest *apiBean.ValuesOverrideRequest,
	valuesOverrideResponse *app.ValuesOverrideResponse, ctx context.Context, triggeredBy int32) (releaseNo int, err error)

TriggerAsyncRelease will publish async Install/Upgrade request event for Devtron App releases

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)

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL