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 ComponentInfo ¶
type DockerInfo ¶
type JavaException ¶
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 { Message string `json:"message"` Stream string `json:"stream"` Docker DockerInfo `json:"docker"` Component ComponentInfo `json:"component"` JavaLog *JavaLog `json:"javaLog,omitempty"` }
LogstashMessage is a simple JSON input to Logstash.
Click to show internal directories.
Click to hide internal directories.