|
@@ -0,0 +1,94 @@
|
|
|
+// Package logentries provides the log driver for forwarding server logs
|
|
|
+// to logentries endpoints.
|
|
|
+package logentries
|
|
|
+
|
|
|
+import (
|
|
|
+ "fmt"
|
|
|
+
|
|
|
+ "github.com/Sirupsen/logrus"
|
|
|
+ "github.com/bsphere/le_go"
|
|
|
+ "github.com/docker/docker/daemon/logger"
|
|
|
+)
|
|
|
+
|
|
|
+type logentries struct {
|
|
|
+ tag string
|
|
|
+ containerID string
|
|
|
+ containerName string
|
|
|
+ writer *le_go.Logger
|
|
|
+ extra map[string]string
|
|
|
+}
|
|
|
+
|
|
|
+const (
|
|
|
+ name = "logentries"
|
|
|
+ token = "logentries-token"
|
|
|
+)
|
|
|
+
|
|
|
+func init() {
|
|
|
+ if err := logger.RegisterLogDriver(name, New); err != nil {
|
|
|
+ logrus.Fatal(err)
|
|
|
+ }
|
|
|
+ if err := logger.RegisterLogOptValidator(name, ValidateLogOpt); err != nil {
|
|
|
+ logrus.Fatal(err)
|
|
|
+ }
|
|
|
+}
|
|
|
+
|
|
|
+// New creates a logentries logger using the configuration passed in on
|
|
|
+// the context. The supported context configuration variable is
|
|
|
+// logentries-token.
|
|
|
+func New(ctx logger.Context) (logger.Logger, error) {
|
|
|
+ logrus.WithField("container", ctx.ContainerID).
|
|
|
+ WithField("token", ctx.Config[token]).
|
|
|
+ Debug("logging driver logentries configured")
|
|
|
+
|
|
|
+ log, err := le_go.Connect(ctx.Config[token])
|
|
|
+ if err != nil {
|
|
|
+ return nil, err
|
|
|
+ }
|
|
|
+ return &logentries{
|
|
|
+ containerID: ctx.ContainerID,
|
|
|
+ containerName: ctx.ContainerName,
|
|
|
+ writer: log,
|
|
|
+ }, nil
|
|
|
+}
|
|
|
+
|
|
|
+func (f *logentries) Log(msg *logger.Message) error {
|
|
|
+ data := map[string]string{
|
|
|
+ "container_id": f.containerID,
|
|
|
+ "container_name": f.containerName,
|
|
|
+ "source": msg.Source,
|
|
|
+ "log": string(msg.Line),
|
|
|
+ }
|
|
|
+ for k, v := range f.extra {
|
|
|
+ data[k] = v
|
|
|
+ }
|
|
|
+ f.writer.Println(f.tag, msg.Timestamp, data)
|
|
|
+ return nil
|
|
|
+}
|
|
|
+
|
|
|
+func (f *logentries) Close() error {
|
|
|
+ return f.writer.Close()
|
|
|
+}
|
|
|
+
|
|
|
+func (f *logentries) Name() string {
|
|
|
+ return name
|
|
|
+}
|
|
|
+
|
|
|
+// ValidateLogOpt looks for logentries specific log option logentries-address.
|
|
|
+func ValidateLogOpt(cfg map[string]string) error {
|
|
|
+ for key := range cfg {
|
|
|
+ switch key {
|
|
|
+ case "env":
|
|
|
+ case "labels":
|
|
|
+ case "tag":
|
|
|
+ case key:
|
|
|
+ default:
|
|
|
+ return fmt.Errorf("unknown log opt '%s' for logentries log driver", key)
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+ if cfg[token] == "" {
|
|
|
+ return fmt.Errorf("Missing logentries token")
|
|
|
+ }
|
|
|
+
|
|
|
+ return nil
|
|
|
+}
|