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
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
|
// Package papertrail implements a papertrail logfmt format handler.
package papertrail
import (
"bytes"
"fmt"
"log/syslog"
"net"
"os"
"sync"
"time"
"github.com/apex/log"
"github.com/go-logfmt/logfmt"
)
// TODO: syslog portion is ad-hoc for my serverless use-case,
// I don't really need hostnames etc, but this should be improved
// Config for Papertrail.
type Config struct {
// Papertrail settings.
Host string // Host subdomain such as "logs4"
Port int // Port number
// Application settings
Hostname string // Hostname value
Tag string // Tag value
}
// Handler implementation.
type Handler struct {
*Config
mu sync.Mutex
conn net.Conn
}
// New handler.
func New(config *Config) *Handler {
conn, err := net.Dial("udp", fmt.Sprintf("%s.papertrailapp.com:%d", config.Host, config.Port))
if err != nil {
panic(err)
}
return &Handler{
Config: config,
conn: conn,
}
}
// HandleLog implements log.Handler.
func (h *Handler) HandleLog(e *log.Entry) error {
ts := time.Now().Format(time.Stamp)
var buf bytes.Buffer
enc := logfmt.NewEncoder(&buf)
enc.EncodeKeyval("level", e.Level.String())
enc.EncodeKeyval("message", e.Message)
for k, v := range e.Fields {
enc.EncodeKeyval(k, v)
}
enc.EndRecord()
msg := []byte(fmt.Sprintf("<%d>%s %s %s[%d]: %s\n", syslog.LOG_KERN, ts, h.Hostname, h.Tag, os.Getpid(), buf.String()))
h.mu.Lock()
_, err := h.conn.Write(msg)
h.mu.Unlock()
return err
}
|
