Help us shape the future of Go! Take the 2026 Go Developer Survey

out

package
v1.8.2 Latest Latest
Warning

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

Go to latest
Published: Oct 1, 2025 License: Apache-2.0 Imports: 23 Imported by: 10

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, userMetadata *bean3.UserMetadata) 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, userMetadata *bean3.UserMetadata) 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, userMetadata *bean2.UserMetadata) (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, userMetadata *bean2.UserMetadata) (interface{}, error)

Directories

Path Synopsis

Jump to

Keyboard shortcuts

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