@@ -16,9 +16,14 @@ const nodeInfoEndpoint = "nodes"
16
16
const nodeConnectionEndpoint = "uptimes"
17
17
const dealsEndpoint = "deals"
18
18
19
- var host = os .Getenv ("API_HOST" ) + "metrics-dashboard/"
19
+ func trackEvent (path string , json string ) {
20
+ var host = os .Getenv ("API_HOST" )
21
+ if host == "" {
22
+ return
23
+ }
24
+
25
+ var url = host + "metrics-dashboard/" + path
20
26
21
- func TrackEvent (url string , json string ) {
22
27
data := []byte (json )
23
28
24
29
client := & http.Client {Timeout : time .Second * 1 }
@@ -34,7 +39,6 @@ func TrackEvent(url string, json string) {
34
39
}
35
40
36
41
func TrackJobOfferUpdate (evOffer data.JobOfferContainer ) {
37
- var url = host + jobsEndpoint
38
42
var module = evOffer .JobOffer .Module .Name
39
43
if module == "" {
40
44
module = evOffer .JobOffer .Module .Repo + ":" + evOffer .JobOffer .Module .Hash
@@ -53,12 +57,10 @@ func TrackJobOfferUpdate(evOffer data.JobOfferContainer) {
53
57
byts , _ := json .Marshal (data )
54
58
payload := string (byts )
55
59
56
- TrackEvent ( url , payload )
60
+ trackEvent ( jobsEndpoint , payload )
57
61
}
58
62
59
63
func TrackNodeInfo (resourceOffer data.ResourceOffer ) {
60
- var url = host + nodeInfoEndpoint
61
-
62
64
data := map [string ]interface {}{
63
65
"ID" : resourceOffer .ResourceProvider ,
64
66
"GPU" : resourceOffer .Spec .GPU ,
@@ -69,7 +71,7 @@ func TrackNodeInfo(resourceOffer data.ResourceOffer) {
69
71
byts , _ := json .Marshal (data )
70
72
payload := string (byts )
71
73
72
- TrackEvent ( url , payload )
74
+ trackEvent ( nodeInfoEndpoint , payload )
73
75
}
74
76
75
77
type NodeConnectionParams struct {
@@ -80,7 +82,6 @@ type NodeConnectionParams struct {
80
82
}
81
83
82
84
func TrackNodeConnectionEvent (params NodeConnectionParams ) {
83
- var url = host + nodeConnectionEndpoint
84
85
data := map [string ]interface {}{
85
86
"ID" : params .ID ,
86
87
"Event" : params .Event ,
@@ -91,7 +92,7 @@ func TrackNodeConnectionEvent(params NodeConnectionParams) {
91
92
byts , _ := json .Marshal (data )
92
93
payload := string (byts )
93
94
94
- TrackEvent ( url , payload )
95
+ trackEvent ( nodeConnectionEndpoint , payload )
95
96
}
96
97
97
98
type DealPayload struct {
@@ -102,9 +103,8 @@ type DealPayload struct {
102
103
}
103
104
104
105
func TrackDeal (params DealPayload ) {
105
- var url = host + dealsEndpoint
106
106
byts , _ := json .Marshal (params )
107
107
payload := string (byts )
108
108
109
- TrackEvent ( url , payload )
109
+ trackEvent ( dealsEndpoint , payload )
110
110
}
0 commit comments