notifier

Documentation

Index

• type BotResponseSender
• type Notifier
  • func New(responseSender BotResponseSender, storage Storage, interval time.Duration) *Notifier
  • func (n *Notifier) Run(ctx context.Context)
• type Storage

Types

type BotResponseSender

type BotResponseSender interface {
	SendBotResponse(response sender.BotResponse, opts ...sender.BotResponseOption) error
}

BotResponseSender - bot's response sender.

type Notifier

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

Notifier sends reminders to users.

func New

func New(responseSender BotResponseSender, storage Storage, interval time.Duration) *Notifier

New creates new Notifier.

func (*Notifier) Run

func (n *Notifier) Run(ctx context.Context)

Run starts infinite loop to fetch reminders from Storage and send them to users. Breaks infinite loop on context error.

type Storage

type Storage interface {
	GetPendingReminders(ctx context.Context, limit int64) ([]domain.Reminder, error)
	UpdateReminder(ctx context.Context, reminder domain.Reminder) error
}

Storage - storage interface.