Documentation ¶
Index ¶
- Constants
- func FlyteEmailToSesEmailInput(email admin.EmailMessage) ses.SendEmailInput
- func NewAwsEmailer(config runtimeInterfaces.NotificationsConfig, scope promutils.Scope, ...) interfaces.Emailer
- func NewEventsPublisher(pub pubsub.Publisher, scope promutils.Scope, eventTypes []string) interfaces.Publisher
- func NewNoopEmail() interfaces.Emailer
- func NewNoopProcess() interfaces.Processor
- func NewNoopPublish() interfaces.Publisher
- func NewProcessor(sub pubsub.Subscriber, emailer interfaces.Emailer, scope promutils.Scope) interfaces.Processor
- func NewPublisher(pub pubsub.Publisher, scope promutils.Scope) interfaces.Publisher
- type AwsEmailer
- type EventPublisher
- type NoopEmail
- type NoopProcess
- type NoopPublish
- type Processor
- type Publisher
Constants ¶
View Source
const ( Task = "task" Node = "node" Workflow = "workflow" AllTypes = "all" AllTypesShort = "*" )
Variables ¶
This section is empty.
Functions ¶
func FlyteEmailToSesEmailInput ¶ added in v0.2.2
func FlyteEmailToSesEmailInput(email admin.EmailMessage) ses.SendEmailInput
func NewAwsEmailer ¶
func NewAwsEmailer(config runtimeInterfaces.NotificationsConfig, scope promutils.Scope, awsEmail sesiface.SESAPI) interfaces.Emailer
func NewEventsPublisher ¶ added in v0.3.34
func NewNoopEmail ¶
func NewNoopEmail() interfaces.Emailer
func NewNoopProcess ¶
func NewNoopProcess() interfaces.Processor
func NewNoopPublish ¶
func NewNoopPublish() interfaces.Publisher
func NewProcessor ¶
func NewProcessor(sub pubsub.Subscriber, emailer interfaces.Emailer, scope promutils.Scope) interfaces.Processor
func NewPublisher ¶
Types ¶
type AwsEmailer ¶
type AwsEmailer struct {
// contains filtered or unexported fields
}
func (*AwsEmailer) SendEmail ¶
func (e *AwsEmailer) SendEmail(ctx context.Context, email admin.EmailMessage) error
type EventPublisher ¶ added in v0.3.34
type EventPublisher struct {
// contains filtered or unexported fields
}
TODO: Add a counter that encompasses the publisher stats grouped by project and domain.
type NoopProcess ¶
type NoopProcess struct{}
func (*NoopProcess) StartProcessing ¶
func (n *NoopProcess) StartProcessing()
func (*NoopProcess) StopProcessing ¶
func (n *NoopProcess) StopProcessing() error
type NoopPublish ¶
type NoopPublish struct{}
type Processor ¶
type Processor struct {
// contains filtered or unexported fields
}
TODO: Add a counter that encompasses the publisher stats grouped by project and domain.
func (*Processor) StartProcessing ¶
func (p *Processor) StartProcessing()
Currently only email is the supported notification because slack and pagerduty both use email client to trigger those notifications. When Pagerduty and other notifications are supported, a publisher per type should be created.
func (*Processor) StopProcessing ¶
Click to show internal directories.
Click to hide internal directories.