notifiers

Documentation

Index

• type EmailConfig
• type EmailNotification
• type EmailWorker
  • func NewEmailWorker(cfg EmailConfig) *EmailWorker
  • func (w *EmailWorker) Close()
  • func (w *EmailWorker) Send(notification *EmailNotification) error
• type TelegramConfig
• type TelegramNotification
• type TelegramWorker
  • func NewTelegramWorker(cfg TelegramConfig) *TelegramWorker
  • func (w *TelegramWorker) Close()
  • func (w *TelegramWorker) QueueLen() int
  • func (w *TelegramWorker) Send(notification *TelegramNotification) error

Types

type EmailConfig

type EmailConfig struct {
	SMTPHost    string
	SMTPPort    int
	Username    string
	Password    string
	FromAddress string
}

type EmailNotification

type EmailNotification struct {
	ToAddress string
	Subject   string
	Body      string
}

type EmailWorker

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

func NewEmailWorker

func NewEmailWorker(cfg EmailConfig) *EmailWorker

func (*EmailWorker) Close

func (w *EmailWorker) Close()

func (*EmailWorker) Send

func (w *EmailWorker) Send(notification *EmailNotification) error

type TelegramConfig

type TelegramConfig struct {
	BotToken   string
	ChatID     string
	APIBaseURL string
}

type TelegramNotification

type TelegramNotification struct {
	Message string
}

type TelegramWorker

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

func NewTelegramWorker

func NewTelegramWorker(cfg TelegramConfig) *TelegramWorker

func (*TelegramWorker) Close

func (w *TelegramWorker) Close()

func (*TelegramWorker) QueueLen

func (w *TelegramWorker) QueueLen() int

QueueLen returns the current number of buffered notifications awaiting delivery. Intended for tests and operational diagnostics; not part of the public notifier contract.

func (*TelegramWorker) Send

func (w *TelegramWorker) Send(notification *TelegramNotification) error