implementations

package

v1.11.0 Latest Latest Go to latest Published: Mar 12, 2024 License: Apache-2.0 Imports: 23 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 ¶

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
- func (e *AwsEmailer) SendEmail(ctx context.Context, email admin.EmailMessage) error
type EventPublisher
- func (p *EventPublisher) Publish(ctx context.Context, notificationType string, msg proto.Message) error
type EventPublisherSystemMetrics
- func NewEventPublisherSystemMetrics(scope promutils.Scope) EventPublisherSystemMetrics
type ExternalEmailer
type GcpProcessor
- func (p *GcpProcessor) StartProcessing()
- func (p *GcpProcessor) StopProcessing() error
type NoopEmail
- func (n *NoopEmail) SendEmail(ctx context.Context, email admin.EmailMessage) error
type NoopProcess
- func (n *NoopProcess) StartProcessing()
- func (n *NoopProcess) StopProcessing() error
type NoopPublish
- func (n *NoopPublish) Publish(ctx context.Context, notificationType string, msg proto.Message) error
type Processor
- func (p *Processor) StartProcessing()
- func (p *Processor) StopProcessing() error
type Publisher
- func (p *Publisher) Publish(ctx context.Context, notificationType string, msg proto.Message) error
type SandboxProcessor
- func (p *SandboxProcessor) StartProcessing()
- func (p *SandboxProcessor) StopProcessing() error
type SandboxPublisher
- func NewSandboxPublisher(pubChan chan<- []byte) *SandboxPublisher
- func (p *SandboxPublisher) Publish(ctx context.Context, notificationType string, msg proto.Message) error
type SendgridEmailer
- func (s SendgridEmailer) SendEmail(ctx context.Context, email admin.EmailMessage) error

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 ¶

func FlyteEmailToSesEmailInput(email admin.EmailMessage) ses.SendEmailInput

func NewAwsEmailer ¶

func NewAwsEmailer(config runtimeInterfaces.NotificationsConfig, scope promutils.Scope, awsEmail sesiface.SESAPI) interfaces.Emailer

func NewEventsPublisher ¶

func NewEventsPublisher(pub pubsub.Publisher, scope promutils.Scope, eventTypes []string) interfaces.Publisher

func NewGcpProcessor ¶

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 NewPublisher(pub pubsub.Publisher, scope promutils.Scope) interfaces.Publisher

func NewSandboxProcessor ¶

func NewSandboxProcessor(subChan <-chan []byte, emailer interfaces.Emailer) interfaces.Processor

func NewSendGridEmailer ¶

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 ¶

type EventPublisher struct {
	// contains filtered or unexported fields
}

TODO: Add a counter that encompasses the publisher stats grouped by project and domain.

func (*EventPublisher) Publish ¶

func (p *EventPublisher) Publish(ctx context.Context, notificationType string, msg proto.Message) error

The key is the notification type as defined as an enum.

type EventPublisherSystemMetrics ¶

type EventPublisherSystemMetrics struct {
	Scope          promutils.Scope
	PublishTotal   prometheus.Counter
	PublishSuccess prometheus.Counter
	PublishError   prometheus.Counter
}

func NewEventPublisherSystemMetrics ¶

func NewEventPublisherSystemMetrics(scope promutils.Scope) EventPublisherSystemMetrics

type ExternalEmailer ¶

type ExternalEmailer = string

const (
	Sendgrid ExternalEmailer = "sendgrid"
)

type GcpProcessor ¶

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 ¶

func (p *GcpProcessor) StartProcessing()

func (*GcpProcessor) StopProcessing ¶

func (p *GcpProcessor) StopProcessing() error

type NoopEmail ¶

type NoopEmail struct{}

Email to use when there is no email configuration.

func (*NoopEmail) SendEmail ¶

func (n *NoopEmail) SendEmail(ctx context.Context, email admin.EmailMessage) 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{}

func (*NoopPublish) Publish ¶

func (n *NoopPublish) Publish(ctx context.Context, notificationType string, msg proto.Message) error

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 ¶

func (p *Processor) StopProcessing() error

type Publisher ¶

type Publisher struct {
	// contains filtered or unexported fields
}

TODO: Add a counter that encompasses the publisher stats grouped by project and domain.

func (*Publisher) Publish ¶

func (p *Publisher) Publish(ctx context.Context, notificationType string, msg proto.Message) error

The key is the notification type as defined as an enum.

type SandboxProcessor ¶

type SandboxProcessor struct {
	// contains filtered or unexported fields
}

func (*SandboxProcessor) StartProcessing ¶

func (p *SandboxProcessor) StartProcessing()

func (*SandboxProcessor) StopProcessing ¶

func (p *SandboxProcessor) StopProcessing() error

type SandboxPublisher ¶

type SandboxPublisher struct {
	// contains filtered or unexported fields
}

func NewSandboxPublisher ¶

func NewSandboxPublisher(pubChan chan<- []byte) *SandboxPublisher

func (*SandboxPublisher) Publish ¶

func (p *SandboxPublisher) Publish(ctx context.Context, notificationType string, msg proto.Message) error

type SendgridEmailer ¶

type SendgridEmailer struct {
	// contains filtered or unexported fields
}

func (SendgridEmailer) SendEmail ¶

func (s SendgridEmailer) SendEmail(ctx context.Context, email admin.EmailMessage) error

Source Files ¶

View all Source files

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