mirror of
https://github.com/c9s/bbgo.git
synced 2024-11-22 23:05:15 +00:00
48 lines
1.3 KiB
Go
48 lines
1.3 KiB
Go
package bbgo
|
|
|
|
type Notifier interface {
|
|
NotifyTo(channel, format string, args ...interface{})
|
|
Notify(format string, args ...interface{})
|
|
}
|
|
|
|
type NullNotifier struct{}
|
|
|
|
func (n *NullNotifier) NotifyTo(channel, format string, args ...interface{}) {}
|
|
|
|
func (n *NullNotifier) Notify(format string, args ...interface{}) {}
|
|
|
|
type Notifiability struct {
|
|
notifiers []Notifier
|
|
SessionChannelRouter *PatternChannelRouter
|
|
SymbolChannelRouter *PatternChannelRouter
|
|
ObjectChannelRouter *ObjectChannelRouter
|
|
}
|
|
|
|
func (m *Notifiability) RouteSymbol(symbol string) (channel string, ok bool) {
|
|
return m.SymbolChannelRouter.Route(symbol)
|
|
}
|
|
|
|
func (m *Notifiability) RouteSession(session string) (channel string, ok bool) {
|
|
return m.SessionChannelRouter.Route(session)
|
|
}
|
|
|
|
func (m *Notifiability) RouteObject(obj interface{}) (channel string, ok bool) {
|
|
return m.ObjectChannelRouter.Route(obj)
|
|
}
|
|
|
|
func (m *Notifiability) AddNotifier(notifier Notifier) {
|
|
m.notifiers = append(m.notifiers, notifier)
|
|
}
|
|
|
|
func (m *Notifiability) Notify(format string, args ...interface{}) {
|
|
for _, n := range m.notifiers {
|
|
n.Notify(format, args...)
|
|
}
|
|
}
|
|
|
|
func (m *Notifiability) NotifyTo(channel, format string, args ...interface{}) {
|
|
for _, n := range m.notifiers {
|
|
n.NotifyTo(channel, format, args...)
|
|
}
|
|
}
|