notify

README

NOTIFY Plugin

Documentation

Documentation

Index

• Constants
• Variables
• func New() supervisor.Pluggable
• func NewMessage() *common.Message
• type Notify
  • func NewNotify(adaptors *adaptors.Adaptors) *Notify
  • func (n *Notify) SaveAndSend(msg common.Message, provider Provider)
  • func (n *Notify) Send(msg *m.MessageDelivery, provider Provider)
  • func (n *Notify) Shutdown()
  • func (n *Notify) Start()
• type NotifyBind
  • func NewNotifyBind(eventBus bus.Bus) *NotifyBind
  • func (b *NotifyBind) NewMessage() *common.Message
  • func (b *NotifyBind) Send(msg common.Message)
• type Provider
• type Stat
• type TemplateBind
  • func NewTemplateBind(adaptor *adaptors.Adaptors) *TemplateBind
  • func (t *TemplateBind) Render(templateName string, params map[string]interface{}) *m.TemplateRender
• type Worker
  • func NewWorker(adaptor *adaptors.Adaptors) *Worker
  • func (n *Worker) SaveAndSend(msg notifyCommon.Message, provider Provider)
  • func (n *Worker) Send(msg *m.MessageDelivery, provider Provider)

Constants

const (
	// Name ...
	Name = "notify"
	// TopicNotify ...
	TopicNotify = "system/plugins/notify"

	Version = "0.0.1"
)

Variables

var F embed.FS

Functions

func New

func New() supervisor.Pluggable

New ...

func NewMessage

func NewMessage() *common.Message

NewMessage ...

Types

type Notify

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

func NewNotify

func NewNotify(adaptors *adaptors.Adaptors) *Notify

NewNotify ...

func (*Notify) SaveAndSend

func (n *Notify) SaveAndSend(msg common.Message, provider Provider)

func (*Notify) Send

func (n *Notify) Send(msg *m.MessageDelivery, provider Provider)

func (*Notify) Shutdown

func (n *Notify) Shutdown()

func (*Notify) Start

func (n *Notify) Start()

type NotifyBind

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

NotifyBind ...

func NewNotifyBind

func NewNotifyBind(eventBus bus.Bus) *NotifyBind

NewNotifyBind ...

func (*NotifyBind) NewMessage

func (b *NotifyBind) NewMessage() *common.Message

NewMessage ...

func (*NotifyBind) Send

func (b *NotifyBind) Send(msg common.Message)

Send ...

type Provider

type Provider interface {
	Save(common.Message) (addresses []string, message *m.Message)
	Send(addresses string, message *m.Message) error
	MessageParams() m.Attributes
}

Provider ...

type Stat

type Stat struct {
	Workers int `json:"workers"`
}

Stat ...

type TemplateBind

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

TemplateBind ...

func NewTemplateBind

func NewTemplateBind(adaptor *adaptors.Adaptors) *TemplateBind

NewTemplateBind ...

func (*TemplateBind) Render

func (t *TemplateBind) Render(templateName string, params map[string]interface{}) *m.TemplateRender

Render ...

type Worker

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

Worker ...

func NewWorker

func NewWorker(adaptor *adaptors.Adaptors) *Worker

NewWorker ...

func (*Worker) SaveAndSend

func (n *Worker) SaveAndSend(msg notifyCommon.Message, provider Provider)

func (*Worker) Send

func (n *Worker) Send(msg *m.MessageDelivery, provider Provider)