Documentation
¶
Index ¶
- Constants
- Variables
- 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 NewGcpProcessor(sub pubsub.Subscriber, emailer interfaces.Emailer, scope promutils.Scope) interfaces.Processor
- 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
- func NewSandboxProcessor(subChan <-chan []byte, emailer interfaces.Emailer) interfaces.Processor
- func NewSendGridEmailer(config runtimeInterfaces.NotificationsConfig, scope promutils.Scope) interfaces.Emailer
- type AwsEmailer
- type EventPublisher
- type EventPublisherSystemMetrics
- type ExternalEmailer
- type GcpProcessor
- type NoopEmail
- type NoopProcess
- type NoopPublish
- type Processor
- type Publisher
- type SandboxProcessor
- type SandboxPublisher
- type SendgridEmailer
Constants ¶
View Source
const ( Task = "task" Node = "node" Workflow = "workflow" AllTypes = "all" AllTypesShort = "*" )
Variables ¶
View Source
var SupportedEvents = map[string]string{ Task: proto.MessageName(&taskExecutionReq), Node: proto.MessageName(&nodeExecutionReq), Workflow: proto.MessageName(&workflowExecutionReq), }
Functions ¶
func FlyteEmailToSesEmailInput ¶ added in v0.3.38
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.38
func NewGcpProcessor ¶ added in v0.6.33
func NewGcpProcessor(sub pubsub.Subscriber, emailer interfaces.Emailer, scope promutils.Scope) interfaces.Processor
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 ¶
func NewSandboxProcessor ¶ added in v1.1.119
func NewSandboxProcessor(subChan <-chan []byte, emailer interfaces.Emailer) interfaces.Processor
func NewSendGridEmailer ¶ added in v0.5.11
func NewSendGridEmailer(config runtimeInterfaces.NotificationsConfig, scope promutils.Scope) interfaces.Emailer
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.38
type EventPublisher struct {
// contains filtered or unexported fields
}
TODO: Add a counter that encompasses the publisher stats grouped by project and domain.
type EventPublisherSystemMetrics ¶ added in v0.6.135
type EventPublisherSystemMetrics struct { Scope promutils.Scope PublishTotal prometheus.Counter PublishSuccess prometheus.Counter PublishError prometheus.Counter }
func NewEventPublisherSystemMetrics ¶ added in v0.6.135
func NewEventPublisherSystemMetrics(scope promutils.Scope) EventPublisherSystemMetrics
type ExternalEmailer ¶ added in v0.5.11
type ExternalEmailer = string
const (
Sendgrid ExternalEmailer = "sendgrid"
)
type GcpProcessor ¶ added in v0.6.33
type GcpProcessor struct {
// contains filtered or unexported fields
}
TODO: Add a counter that encompasses the publisher stats grouped by project and domain.
func (*GcpProcessor) StartProcessing ¶ added in v0.6.33
func (p *GcpProcessor) StartProcessing()
func (*GcpProcessor) StopProcessing ¶ added in v0.6.33
func (p *GcpProcessor) StopProcessing() error
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 ¶
type Publisher ¶
type Publisher struct {
// contains filtered or unexported fields
}
TODO: Add a counter that encompasses the publisher stats grouped by project and domain.
type SandboxProcessor ¶ added in v1.1.119
type SandboxProcessor struct {
// contains filtered or unexported fields
}
func (*SandboxProcessor) StartProcessing ¶ added in v1.1.119
func (p *SandboxProcessor) StartProcessing()
func (*SandboxProcessor) StopProcessing ¶ added in v1.1.119
func (p *SandboxProcessor) StopProcessing() error
type SandboxPublisher ¶ added in v1.1.119
type SandboxPublisher struct {
// contains filtered or unexported fields
}
func NewSandboxPublisher ¶ added in v1.1.119
func NewSandboxPublisher(pubChan chan<- []byte) *SandboxPublisher
type SendgridEmailer ¶ added in v0.5.11
type SendgridEmailer struct {
// contains filtered or unexported fields
}
func (SendgridEmailer) SendEmail ¶ added in v0.5.11
func (s SendgridEmailer) SendEmail(ctx context.Context, email admin.EmailMessage) error
Click to show internal directories.
Click to hide internal directories.