ses

package
v0.3.4 Latest Latest
Warning

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

Go to latest
Published: Jan 23, 2026 License: MIT Imports: 11 Imported by: 0

Documentation

Index

Constants

View Source
const SourceType = "ses"

Variables

This section is empty.

Functions

This section is empty.

Types

type Config

type Config struct {
	From string   `yaml:"from"`
	To   []string `yaml:"to"`
}

func (*Config) Validate

func (c *Config) Validate() error

type Metrics

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

func GetMetricsInstance

func GetMetricsInstance(namespace, monitor string) *Metrics

func (Metrics) IncErrors

func (m Metrics) IncErrors(group, source, sourceType, errorType string)

func (Metrics) IncMessagesPublished

func (m Metrics) IncMessagesPublished(group, source, sourceType string)

type SES

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

func NewSES

func NewSES(ctx context.Context, log logrus.FieldLogger, monitor, name string, docs *string, includeMonitorName, includeGroupName bool, config *Config) (*SES, error)

func (*SES) GetConfig

func (s *SES) GetConfig() *Config

func (*SES) GetName

func (s *SES) GetName() string

func (*SES) GetType

func (s *SES) GetType() string

func (*SES) Publish

func (s *SES) Publish(ctx context.Context, e event.Event) error

func (*SES) Start

func (s *SES) Start(ctx context.Context) error

func (*SES) Stop

func (s *SES) Stop(ctx context.Context) error

Jump to

Keyboard shortcuts

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