out

package
v1.1.0 Latest Latest
Warning

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

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

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var EventProcessorOutWireSet = wire.NewSet(
	celEvaluator.NewTriggerEventEvaluatorImpl,
	wire.Bind(new(celEvaluator.TriggerEventEvaluator), new(*celEvaluator.TriggerEventEvaluatorImpl)),

	NewWorkflowEventPublishServiceImpl,
	wire.Bind(new(WorkflowEventPublishService), new(*WorkflowEventPublishServiceImpl)),

	NewPipelineConfigEventPublishServiceImpl,
	wire.Bind(new(PipelineConfigEventPublishService), new(*PipelineConfigEventPublishServiceImpl)),

	NewCDPipelineEventPublishServiceImpl,
	wire.Bind(new(CDPipelineEventPublishService), new(*CDPipelineEventPublishServiceImpl)),

	NewAppStoreAppsEventPublishServiceImpl,
	wire.Bind(new(AppStoreAppsEventPublishService), new(*AppStoreAppsEventPublishServiceImpl)),

	NewCIPipelineEventPublishServiceImpl,
	wire.Bind(new(CIPipelineEventPublishService), new(*CIPipelineEventPublishServiceImpl)),
)

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(event *bean.CIPipelineGitWebhookEvent) 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(event *bean.CIPipelineGitWebhookEvent) 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, manifestPushTemplate *appBean.ManifestPushTemplate, 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, manifestPushTemplate *appBean.ManifestPushTemplate, 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)

Source Files

View all Source files

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.