notifications

Documentation

Index

• func GetEmailer(config runtimeInterfaces.NotificationsConfig, scope promutils.Scope) interfaces.Emailer
• func NewNotificationsProcessor(config runtimeInterfaces.NotificationsConfig, scope promutils.Scope) interfaces.Processor
• func NewNotificationsPublisher(config runtimeInterfaces.NotificationsConfig, scope promutils.Scope) interfaces.Publisher
• func ToEmailMessageFromWorkflowExecutionEvent(config runtimeInterfaces.NotificationsConfig, ...) *admin.EmailMessage
• type EmailerConfig
• type ProcessorConfig
• type PublisherConfig

Functions

func GetEmailer

func GetEmailer(config runtimeInterfaces.NotificationsConfig, scope promutils.Scope) interfaces.Emailer

func NewNotificationsProcessor

func NewNotificationsProcessor(config runtimeInterfaces.NotificationsConfig, scope promutils.Scope) interfaces.Processor

func NewNotificationsPublisher

func NewNotificationsPublisher(config runtimeInterfaces.NotificationsConfig, scope promutils.Scope) interfaces.Publisher

func ToEmailMessageFromWorkflowExecutionEvent

func ToEmailMessageFromWorkflowExecutionEvent(
	config runtimeInterfaces.NotificationsConfig,
	emailNotification admin.EmailNotification,
	request admin.WorkflowExecutionEventRequest,
	execution models.Execution) *admin.EmailMessage

Converts a terminal execution event and existing execution model to an admin.EmailMessage proto, substituting parameters in customizable email fields set in the flyteadmin application notifications config.

Types

type EmailerConfig

type EmailerConfig struct {
	SenderEmail string
	BaseURL     string
}

type ProcessorConfig

type ProcessorConfig struct {
	QueueName string
	AccountID string
}

type PublisherConfig

type PublisherConfig struct {
	TopicName string
}