notify

type ChannelNotifier ¶

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

ChannelNotifier 는 백업 결과를 조직의 알림 채널(Telegram · 이메일 · Slack)로 보낸다(B3-3, nullus-plan#63).

구조화 로그는 그대로 남긴다 — 채널이 하나도 없거나 발송이 실패해도 결과가 어딘가에는 남아야 한다. 어느 채널로 보낼지는 알림 모듈이 조직의 구독으로 정한다. 백업은 이벤트만 낸다.

발송은 백업을 붙들지 않는다 — 결과를 기록한 뒤 따로 보낸다. 백업의 마무리 ctx(짧다)로 보내면 느린 채널 하나가 시간을 다 써서 다른 채널과 발송 이력까지 사라진다. 발송 결과는 알림 모듈의 이력에 남고, 실패는 여기서 경고 로그로도 남긴다.

func NewChannelNotifier(log *LogNotifier, publisher sharednotify.Publisher) *ChannelNotifier

func (n *ChannelNotifier) NotifyBackupResult(ctx context.Context, run *domain.BackupRun) error

func (n *ChannelNotifier) Wait()

type LogNotifier ¶

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

func NewLogNotifier(logger *slog.Logger) *LogNotifier

func (n *LogNotifier) NotifyBackupResult(_ context.Context, run *domain.BackupRun) error