notifications

package
v1.1.131 Latest Latest
Warning

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

 Go to latest Published: Sep 27, 2023 License: Apache-2.0 Imports: 19 Imported by: 2

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func CreateMsgChan added in v1.1.119 

func CreateMsgChan()

For sandbox only

func GetEmailer 

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

func NewEventsPublisher added in v0.3.38 

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

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 *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 added in v0.1.4 

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

type ProcessorConfig 

type ProcessorConfig struct {
	QueueName string
	AccountID string
}

type PublisherConfig 

type PublisherConfig struct {
	TopicName string
}

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.