logstash

package module
v0.0.0-...-6877e64 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Dec 3, 2015 License: Apache-2.0 Imports: 7 Imported by: 0

README

logspout-logstash

A minimalistic adapter for github.com/gliderlabs/logspout to write to Logstash UDP

Follow the instructions in https://github.com/gliderlabs/logspout/tree/master/custom on how to build your own Logspout container with custom modules. Basically just copy the contents of the custom folder and include:

import (
  _ "github.com/looplab/logspout-logstash"
  _ "github.com/gliderlabs/logspout/transports/udp"
)

in modules.go.

Use by setting ROUTE_URIS=logstash://host:port to the Logstash host and port for UDP.

In your logstash config, set the input codec to json e.g:

input { udp { port => 5000 codec => json } }

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func NewLogstashAdapter

func NewLogstashAdapter(route *router.Route) (router.LogAdapter, error)

NewLogstashAdapter creates a LogstashAdapter with TCP as the default transport.

Types

type LogstashAdapter

type LogstashAdapter struct {
	// contains filtered or unexported fields
}

LogstashAdapter is an adapter that streams TCP JSON to Logstash.

func (*LogstashAdapter) Stream

func (a *LogstashAdapter) Stream(logstream chan *router.Message)

Stream implements the router.LogAdapter interface.

type LogstashMessage

type LogstashMessage struct {
	Name     string      `json:"docker.name"`
	ID       string      `json:"docker.id"`
	Image    string      `json:"docker.image"`
	Hostname string      `json:"docker.hostname"`
	Data     interface{} `json:"data,omitempty"`
	Token    string      `json:"token,omitempty"` // logz.io token
}

LogstashMessage is a simple JSON input to Logstash.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL