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
|
Author: Jelmer Vernooij <jelmer@debian.org>
Description: Remove support for systemd, as it requires the go-systemd package
go-systemd is not currently packaged.
diff --git a/log/sinks_unix.go b/log/sinks_unix.go
index 0067a79..dc868a5 100644
--- a/log/sinks_unix.go
+++ b/log/sinks_unix.go
@@ -20,61 +20,12 @@ package log
// based on previous package by: Cong Ding <dinggnu@gmail.com>
import (
- "fmt"
- "github.com/coreos/go-systemd/journal"
"io"
- "strings"
)
-type journalSink struct{}
-
-func (sink *journalSink) Log(fields Fields) {
- message := fields["message"].(string)
- priority := toJournalPriority(fields["priority"].(Priority))
- journalFields := make(map[string]string)
- for k, v := range fields {
- if k == "message" || k == "priority" {
- continue
- }
- journalFields[strings.ToUpper(k)] = fmt.Sprint(v)
- }
- journal.Send(message, priority, journalFields)
-}
-
-func toJournalPriority(priority Priority) journal.Priority {
- switch priority {
- case PriEmerg:
- return journal.PriEmerg
- case PriAlert:
- return journal.PriAlert
- case PriCrit:
- return journal.PriCrit
- case PriErr:
- return journal.PriErr
- case PriWarning:
- return journal.PriWarning
- case PriNotice:
- return journal.PriNotice
- case PriInfo:
- return journal.PriInfo
- case PriDebug:
- return journal.PriDebug
-
- default:
- return journal.PriErr
- }
-}
-
-func JournalSink() Sink {
- return &journalSink{}
-}
-
func CombinedSink(writer io.Writer, format string, fields []string) Sink {
sinks := make([]Sink, 0)
sinks = append(sinks, WriterSink(writer, format, fields))
- if journal.Enabled() {
- sinks = append(sinks, JournalSink())
- }
return &combinedSink{
sinks: sinks,
|
