notify_go

type ChannelFunc func(ctx context.Context, no *Notification) error

type CircleTask struct {
	IterCronTimes iterator.Iterable[time.Time]
	CronExpr      string
	BeginTime     time.Time
	EndTime       time.Time
	HookBefore    func()
	HookAfter     func()

	*Notification
	// contains filtered or unexported fields
}

type DefaultTask struct {
	Err        chan error
	HookBefore func()
	HookAfter  func()
	*Notification
}

type Middleware func(channelFunc ChannelFunc) ChannelFunc

type Notification struct {
	notifier.Delivery
	Channel notifier.IChannel
}

type TriggerTask struct {
	Err         chan error
	TriggerTime time.Time
	HookBefore  func()
	HookAfter   func()
	*Notification
}