-
Notifications
You must be signed in to change notification settings - Fork 246
/
events_subs.go
33 lines (28 loc) · 934 Bytes
/
events_subs.go
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
package signal
const (
// EventSubscriptionsData is triggered when there is new data in any of the subscriptions
EventSubscriptionsData = "subscriptions.data"
// EventSubscriptionsError is triggered when subscriptions failed to get new data
EventSubscriptionsError = "subscriptions.error"
)
type SubscriptionDataEvent struct {
FilterID string `json:"subscription_id"`
Data []interface{} `json:"data"`
}
type SubscriptionErrorEvent struct {
FilterID string `json:"subscription_id"`
ErrorMessage string `json:"error_message"`
}
// SendSubscriptionDataEvent
func SendSubscriptionDataEvent(filterID string, data []interface{}) {
send(EventSubscriptionsData, SubscriptionDataEvent{
FilterID: filterID,
Data: data,
})
}
// SendSubscriptionErrorEvent
func SendSubscriptionErrorEvent(filterID string, err error) {
send(EventSubscriptionsError, SubscriptionErrorEvent{
ErrorMessage: err.Error(),
})
}