notify

type Message struct {
	From       common.EntityId  `json:"from"`
	Type       string           `json:"type"`
	Attributes m.AttributeValue `json:"attributes"`
}

type Notify interface {
	Shutdown() error
	Start() (err error)
	Stat() *Stat
	Repeat(msg m.MessageDelivery)
	Send(msg Message)
	AddProvider(name string, provider Provider)
	RemoveProvider(name string)
	Provider(name string) (provider Provider, err error)
}

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

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

type ProviderRegistrar interface {
	AddProvider(name string, provider Provider)
	RemoveProvider(name string)
	Provider(name string) (provider Provider, err error)
}

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

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

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