notify_go

README

notify-go

ref:

1. https://github.com/golang-standards/project-layout

Documentation

Index

• type ChannelFunc
• type CircleTask
  • func NewCircleTask(notification *Notification, expr string, begin time.Time, end time.Time) *CircleTask
  • func (ct *CircleTask) Send(ctx context.Context)
• type DefaultTask
• type Middleware
• type Notification
  • func NewNotification(c notifier.IChannel, recvs []notifier.Receiver, content notifier.Content) *Notification
  • func (no *Notification) Send(ctx context.Context, mls ...Middleware) error
• type TriggerTask
  • func NewTriggerTask(notification *Notification, t time.Time) *TriggerTask
  • func (tt *TriggerTask) Send(ctx context.Context)

Types

type ChannelFunc

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

type CircleTask

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
}

CircleTask 循环触发任务

func NewCircleTask

func NewCircleTask(notification *Notification, expr string, begin time.Time, end time.Time) *CircleTask

func (*CircleTask) Send

func (ct *CircleTask) Send(ctx context.Context)

type DefaultTask

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

DefaultTask 默认任务

type Middleware

type Middleware func(channelFunc ChannelFunc) ChannelFunc

type Notification

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

func NewNotification

func NewNotification(c notifier.IChannel, recvs []notifier.Receiver, content notifier.Content) *Notification

func (*Notification) Send

func (no *Notification) Send(ctx context.Context, mls ...Middleware) error

type TriggerTask

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

TriggerTask 定时触发任务

func NewTriggerTask

func NewTriggerTask(notification *Notification, t time.Time) *TriggerTask

func (*TriggerTask) Send

func (tt *TriggerTask) Send(ctx context.Context)

Send 一次性任务