notifier

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: 23 Imported by: 6

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type NotificationConfigBuilder 

type NotificationConfigBuilder interface {
	BuildNotificationSettingsConfig(notificationSettingsRequest *beans.NotificationConfigRequest, existingNotificationSettingsConfig *repository.NotificationSettingsView, userId int32) (*repository.NotificationSettingsView, error)
	BuildNewNotificationSettings(notificationSettingsRequest *beans.NotificationConfigRequest, notificationSettingsView *repository.NotificationSettingsView) ([]repository.NotificationSettings, error)
	BuildNotificationSettingWithPipeline(teamId *int, envId *int, appId *int, pipelineId *int, clusterId *int, pipelineType util.PipelineType, eventTypeId int, viewId int, providers []*bean.Provider) (repository.NotificationSettings, error)
}

type NotificationConfigBuilderImpl 

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

func NewNotificationConfigBuilderImpl 

func NewNotificationConfigBuilderImpl(logger *zap.SugaredLogger) *NotificationConfigBuilderImpl

func (NotificationConfigBuilderImpl) BuildNewNotificationSettings 

func (impl NotificationConfigBuilderImpl) BuildNewNotificationSettings(notificationSettingsRequest *beans.NotificationConfigRequest, notificationSettingsView *repository.NotificationSettingsView) ([]repository.NotificationSettings, error)

func (NotificationConfigBuilderImpl) BuildNotificationSettingWithPipeline 

func (impl NotificationConfigBuilderImpl) BuildNotificationSettingWithPipeline(teamId *int, envId *int, appId *int, pipelineId *int, clusterId *int, pipelineType util.PipelineType, eventTypeId int, viewId int, providers []*bean.Provider) (repository.NotificationSettings, error)

func (NotificationConfigBuilderImpl) BuildNotificationSettingsConfig 

func (impl NotificationConfigBuilderImpl) BuildNotificationSettingsConfig(notificationSettingsRequest *beans.NotificationConfigRequest, existingNotificationSettingsConfig *repository.NotificationSettingsView, userId int32) (*repository.NotificationSettingsView, error)

type NotificationConfigService 

type NotificationConfigService interface {
	CreateOrUpdateNotificationSettings(notificationSettingsRequest *beans.NotificationRequest, userId int32) (int, error)
	FindAll(offset int, size int) ([]*repository.NotificationSettingsViewWithAppEnv, int, error)
	BuildNotificationSettingsResponse(notificationSettings []*repository.NotificationSettingsViewWithAppEnv) ([]*beans.NotificationSettingsResponse, int, error)
	DeleteNotificationSettings(request beans.NSDeleteRequest) error
	FindNotificationSettingOptions(request *repository.SearchRequest) ([]*beans.SearchFilterResponse, error)

	UpdateNotificationSettings(notificationSettingsRequest *beans.NotificationUpdateRequest, userId int32) (int, error)
	FetchNSViewByIds(ids []*int) ([]*beans.NSConfig, error)
}

type NotificationConfigServiceImpl 

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

func NewNotificationConfigServiceImpl 

func NewNotificationConfigServiceImpl(logger *zap.SugaredLogger, notificationSettingsRepository repository.NotificationSettingsRepository, notificationConfigBuilder NotificationConfigBuilder, ciPipelineRepository pipelineConfig.CiPipelineRepository,
	pipelineRepository pipelineConfig.PipelineRepository, slackRepository repository.SlackNotificationRepository, webhookRepository repository.WebhookNotificationRepository,
	sesRepository repository.SESNotificationRepository, smtpRepository repository.SMTPNotificationRepository,
	teamRepository repository2.TeamRepository,
	environmentRepository repository3.EnvironmentRepository, appRepository app.AppRepository, clusterService clusterService.ClusterService,
	userRepository repository4.UserRepository, ciPipelineMaterialRepository pipelineConfig.CiPipelineMaterialRepository,
	teamReadService read.TeamReadService) *NotificationConfigServiceImpl

func (*NotificationConfigServiceImpl) BuildNotificationSettingsResponse 

func (impl *NotificationConfigServiceImpl) BuildNotificationSettingsResponse(notificationSettingViews []*repository.NotificationSettingsViewWithAppEnv) ([]*beans.NotificationSettingsResponse, int, error)

func (*NotificationConfigServiceImpl) CreateOrUpdateNotificationSettings 

func (impl *NotificationConfigServiceImpl) CreateOrUpdateNotificationSettings(notificationSettingsRequest *beans.NotificationRequest, userId int32) (int, error)

func (*NotificationConfigServiceImpl) DeleteNotificationSettings 

func (impl *NotificationConfigServiceImpl) DeleteNotificationSettings(request beans.NSDeleteRequest) error

func (*NotificationConfigServiceImpl) FetchNSViewByIds 

func (impl *NotificationConfigServiceImpl) FetchNSViewByIds(ids []*int) ([]*beans.NSConfig, error)

func (*NotificationConfigServiceImpl) FindAll 

func (impl *NotificationConfigServiceImpl) FindAll(offset int, size int) ([]*repository.NotificationSettingsViewWithAppEnv, int, error)

func (*NotificationConfigServiceImpl) FindNotificationSettingOptions 

func (impl *NotificationConfigServiceImpl) FindNotificationSettingOptions(settingRequest *repository.SearchRequest) ([]*beans.SearchFilterResponse, error)

func (*NotificationConfigServiceImpl) UpdateNotificationSettings 

func (impl *NotificationConfigServiceImpl) UpdateNotificationSettings(notificationSettingsRequest *beans.NotificationUpdateRequest, userId int32) (int, error)

type SESNotificationService 

type SESNotificationService interface {
	SaveOrEditNotificationConfig(channelReq []*beans.SESConfigDto, userId int32) ([]int, error)
	FetchSESNotificationConfigById(id int) (*beans.SESConfigDto, error)
	FetchAllSESNotificationConfig() ([]*beans.SESConfigDto, error)
	FetchAllSESNotificationConfigAutocomplete() ([]*beans.NotificationChannelAutoResponse, error)
	DeleteNotificationConfig(channelReq *beans.SESConfigDto, userId int32) error
}

type SESNotificationServiceImpl 

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

func NewSESNotificationServiceImpl 

func NewSESNotificationServiceImpl(logger *zap.SugaredLogger, sesRepository repository.SESNotificationRepository,
	teamService team.TeamService, notificationSettingsRepository repository.NotificationSettingsRepository) *SESNotificationServiceImpl

func (*SESNotificationServiceImpl) DeleteNotificationConfig added in v0.3.15 

func (impl *SESNotificationServiceImpl) DeleteNotificationConfig(deleteReq *beans.SESConfigDto, userId int32) error

func (*SESNotificationServiceImpl) FetchAllSESNotificationConfig 

func (impl *SESNotificationServiceImpl) FetchAllSESNotificationConfig() ([]*beans.SESConfigDto, error)

func (*SESNotificationServiceImpl) FetchAllSESNotificationConfigAutocomplete 

func (impl *SESNotificationServiceImpl) FetchAllSESNotificationConfigAutocomplete() ([]*beans.NotificationChannelAutoResponse, error)

func (*SESNotificationServiceImpl) FetchSESNotificationConfigById 

func (impl *SESNotificationServiceImpl) FetchSESNotificationConfigById(id int) (*beans.SESConfigDto, error)

func (*SESNotificationServiceImpl) SaveOrEditNotificationConfig 

func (impl *SESNotificationServiceImpl) SaveOrEditNotificationConfig(channelReq []*beans.SESConfigDto, userId int32) ([]int, error)

type SMTPNotificationService added in v0.4.24 

type SMTPNotificationService interface {
	SaveOrEditNotificationConfig(channelReq []*beans.SMTPConfigDto, userId int32) ([]int, error)
	FetchSMTPNotificationConfigById(id int) (*beans.SMTPConfigDto, error)
	FetchAllSMTPNotificationConfig() ([]*beans.SMTPConfigDto, error)
	FetchAllSMTPNotificationConfigAutocomplete() ([]*beans.NotificationChannelAutoResponse, error)
	DeleteNotificationConfig(channelReq *beans.SMTPConfigDto, userId int32) error
}

type SMTPNotificationServiceImpl added in v0.4.24 

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

func NewSMTPNotificationServiceImpl added in v0.4.24 

func NewSMTPNotificationServiceImpl(logger *zap.SugaredLogger, smtpRepository repository.SMTPNotificationRepository,
	teamService team.TeamService, notificationSettingsRepository repository.NotificationSettingsRepository) *SMTPNotificationServiceImpl

func (*SMTPNotificationServiceImpl) DeleteNotificationConfig added in v0.4.24 

func (impl *SMTPNotificationServiceImpl) DeleteNotificationConfig(deleteReq *beans.SMTPConfigDto, userId int32) error

func (*SMTPNotificationServiceImpl) FetchAllSMTPNotificationConfig added in v0.4.24 

func (impl *SMTPNotificationServiceImpl) FetchAllSMTPNotificationConfig() ([]*beans.SMTPConfigDto, error)

func (*SMTPNotificationServiceImpl) FetchAllSMTPNotificationConfigAutocomplete added in v0.4.24 

func (impl *SMTPNotificationServiceImpl) FetchAllSMTPNotificationConfigAutocomplete() ([]*beans.NotificationChannelAutoResponse, error)

func (*SMTPNotificationServiceImpl) FetchSMTPNotificationConfigById added in v0.4.24 

func (impl *SMTPNotificationServiceImpl) FetchSMTPNotificationConfigById(id int) (*beans.SMTPConfigDto, error)

func (*SMTPNotificationServiceImpl) SaveOrEditNotificationConfig added in v0.4.24 

func (impl *SMTPNotificationServiceImpl) SaveOrEditNotificationConfig(channelReq []*beans.SMTPConfigDto, userId int32) ([]int, error)

type SlackNotificationService 

type SlackNotificationService interface {
	SaveOrEditNotificationConfig(channelReq []beans.SlackConfigDto, userId int32) ([]int, error)
	FetchSlackNotificationConfigById(id int) (*beans.SlackConfigDto, error)
	FetchAllSlackNotificationConfig() ([]*beans.SlackConfigDto, error)
	FetchAllSlackNotificationConfigAutocomplete() ([]*beans.NotificationChannelAutoResponse, error)
	RecipientListingSuggestion(value string) ([]*beans.NotificationRecipientListingResponse, error)
	DeleteNotificationConfig(deleteReq *beans.SlackConfigDto, userId int32) error
}

type SlackNotificationServiceImpl 

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

func NewSlackNotificationServiceImpl 

func NewSlackNotificationServiceImpl(logger *zap.SugaredLogger, slackRepository repository.SlackNotificationRepository, webhookRepository repository.WebhookNotificationRepository, teamService team.TeamService,
	userRepository repository2.UserRepository, notificationSettingsRepository repository.NotificationSettingsRepository) *SlackNotificationServiceImpl

func (*SlackNotificationServiceImpl) DeleteNotificationConfig added in v0.3.15 

func (impl *SlackNotificationServiceImpl) DeleteNotificationConfig(deleteReq *beans.SlackConfigDto, userId int32) error

func (*SlackNotificationServiceImpl) FetchAllSlackNotificationConfig 

func (impl *SlackNotificationServiceImpl) FetchAllSlackNotificationConfig() ([]*beans.SlackConfigDto, error)

func (*SlackNotificationServiceImpl) FetchAllSlackNotificationConfigAutocomplete 

func (impl *SlackNotificationServiceImpl) FetchAllSlackNotificationConfigAutocomplete() ([]*beans.NotificationChannelAutoResponse, error)

func (*SlackNotificationServiceImpl) FetchSlackNotificationConfigById 

func (impl *SlackNotificationServiceImpl) FetchSlackNotificationConfigById(id int) (*beans.SlackConfigDto, error)

func (*SlackNotificationServiceImpl) RecipientListingSuggestion 

func (impl *SlackNotificationServiceImpl) RecipientListingSuggestion(value string) ([]*beans.NotificationRecipientListingResponse, error)

func (*SlackNotificationServiceImpl) SaveOrEditNotificationConfig 

func (impl *SlackNotificationServiceImpl) SaveOrEditNotificationConfig(channelReq []beans.SlackConfigDto, userId int32) ([]int, error)

type WebhookNotificationService added in v0.6.18 

type WebhookNotificationService interface {
	SaveOrEditNotificationConfig(channelReq []beans.WebhookConfigDto, userId int32) ([]int, error)
	FetchWebhookNotificationConfigById(id int) (*beans.WebhookConfigDto, error)
	GetWebhookVariables() (map[string]beans.WebhookVariable, error)
	FetchAllWebhookNotificationConfig() ([]*beans.WebhookConfigDto, error)
	FetchAllWebhookNotificationConfigAutocomplete() ([]*beans.NotificationChannelAutoResponse, error)
	DeleteNotificationConfig(deleteReq *beans.WebhookConfigDto, userId int32) error
}

type WebhookNotificationServiceImpl added in v0.6.18 

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

func NewWebhookNotificationServiceImpl added in v0.6.18 

func NewWebhookNotificationServiceImpl(logger *zap.SugaredLogger, webhookRepository repository.WebhookNotificationRepository, teamService team.TeamService,
	userRepository repository2.UserRepository, notificationSettingsRepository repository.NotificationSettingsRepository) *WebhookNotificationServiceImpl

func (*WebhookNotificationServiceImpl) DeleteNotificationConfig added in v0.6.18 

func (impl *WebhookNotificationServiceImpl) DeleteNotificationConfig(deleteReq *beans.WebhookConfigDto, userId int32) error

func (*WebhookNotificationServiceImpl) FetchAllWebhookNotificationConfig added in v0.6.18 

func (impl *WebhookNotificationServiceImpl) FetchAllWebhookNotificationConfig() ([]*beans.WebhookConfigDto, error)

func (*WebhookNotificationServiceImpl) FetchAllWebhookNotificationConfigAutocomplete added in v0.6.18 

func (impl *WebhookNotificationServiceImpl) FetchAllWebhookNotificationConfigAutocomplete() ([]*beans.NotificationChannelAutoResponse, error)

func (*WebhookNotificationServiceImpl) FetchWebhookNotificationConfigById added in v0.6.18 

func (impl *WebhookNotificationServiceImpl) FetchWebhookNotificationConfigById(id int) (*beans.WebhookConfigDto, error)

func (*WebhookNotificationServiceImpl) GetWebhookVariables added in v0.6.18 

func (impl *WebhookNotificationServiceImpl) GetWebhookVariables() (map[string]beans.WebhookVariable, error)

func (*WebhookNotificationServiceImpl) SaveOrEditNotificationConfig added in v0.6.18 

func (impl *WebhookNotificationServiceImpl) SaveOrEditNotificationConfig(channelReq []beans.WebhookConfigDto, userId int32) ([]int, 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.