notifications

Documentation

Index

• func CreateMsgChan()
• func GetEmailer(config runtimeInterfaces.NotificationsConfig, scope promutils.Scope, ...) interfaces.Emailer
• func NewEventsPublisher(config runtimeInterfaces.ExternalEventsConfig, scope promutils.Scope) interfaces.Publisher
• 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 GetTemplateValue
• type ProcessorConfig
• type PublisherConfig

Functions

func CreateMsgChan

func CreateMsgChan()

func GetEmailer

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

func NewEventsPublisher

func NewEventsPublisher(config runtimeInterfaces.ExternalEventsConfig, scope promutils.Scope) interfaces.Publisher

func NewNotificationsProcessor

func NewNotificationsProcessor(config runtimeInterfaces.NotificationsConfig, scope promutils.Scope, sm core.SecretManager) 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 *admin.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 GetTemplateValue

type GetTemplateValue func(*admin.WorkflowExecutionEventRequest, *admin.Execution) string

type ProcessorConfig

type ProcessorConfig struct {
	QueueName string

	AccountID string
}

type PublisherConfig

type PublisherConfig struct {
	TopicName string
}