|
7 | 7 | "github.com/TykTechnologies/tyk-pump/analytics" |
8 | 8 | "github.com/mitchellh/mapstructure" |
9 | 9 | "github.com/robertkowalski/graylog-golang" |
10 | | - "strconv" |
11 | 10 | ) |
12 | 11 |
|
13 | 12 | type GraylogPump struct { |
@@ -97,23 +96,23 @@ func (p *GraylogPump) WriteData(data []interface{}) error { |
97 | 96 | mapping := map[string]interface{}{ |
98 | 97 | "method": record.Method, |
99 | 98 | "path": record.Path, |
100 | | - "response_code": strconv.Itoa(record.ResponseCode), |
| 99 | + "response_code": record.ResponseCode, |
101 | 100 | "api_key": record.APIKey, |
102 | 101 | "api_version": record.APIVersion, |
103 | 102 | "api_name": record.APIName, |
104 | 103 | "api_id": record.APIID, |
105 | 104 | "org_id": record.OrgID, |
106 | 105 | "oauth_id": record.OauthID, |
107 | 106 | "raw_request": string(rReq), |
108 | | - "request_time": strconv.Itoa(int(record.RequestTime)), |
| 107 | + "request_time": record.RequestTime, |
109 | 108 | "raw_response": string(rResp), |
110 | 109 | } |
111 | 110 |
|
112 | | - messageMap := map[string]string{} |
| 111 | + messageMap := map[string]interface{}{} |
113 | 112 |
|
114 | 113 | for _, key := range p.conf.Tags { |
115 | 114 | if value, ok := mapping[key]; ok { |
116 | | - messageMap[key] = value.(string) |
| 115 | + messageMap[key] = value |
117 | 116 | } |
118 | 117 | } |
119 | 118 |
|
|
0 commit comments