forked from elastic/beats
-
Notifications
You must be signed in to change notification settings - Fork 8
/
data.go
34 lines (31 loc) · 1.04 KB
/
data.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
34
package activity
import (
"time"
s "github.com/elastic/beats/libbeat/common/schema"
c "github.com/elastic/beats/libbeat/common/schema/mapstrstr"
)
// Based on: https://www.postgresql.org/docs/9.2/static/monitoring-stats.html#PG-STAT-ACTIVITY-VIEW
var schema = s.Schema{
"database": s.Object{
"oid": c.Int("datid"),
"name": c.Str("datname"),
},
"pid": c.Int("pid"),
"user": s.Object{
"id": c.Int("usesysid"),
"name": c.Str("usename"),
},
"application_name": c.Str("application_name"),
"client": s.Object{
"address": c.Str("client_addr"),
"hostname": c.Str("client_hostname"),
"port": c.Int("client_port"),
},
"backend_start": c.Time(time.RFC3339Nano, "backend_start"),
"transaction_start": c.Time(time.RFC3339Nano, "xact_start", s.Optional),
"query_start": c.Time(time.RFC3339Nano, "query_start", s.Optional),
"state_change": c.Time(time.RFC3339Nano, "state_change", s.Optional),
"waiting": c.Bool("waiting", s.Optional),
"state": c.Str("state"),
"query": c.Str("query"),
}