notifications

package

v1.11.0 Latest Latest Go to latest Published: Mar 12, 2024 License: Apache-2.0 Imports: 19 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/flyteorg/flyte

Links

Open Source Insights

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

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func GetEmailer ¶

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

func NewEventsPublisher ¶

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 ¶

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
implementations
interfaces
mocks

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