logstash

Documentation

Index

• func NewLogger(address string, ssl bool) *tcplog.Logger
• type LogstashFormatter
  • func (lf *LogstashFormatter) Format(m *cypress.Message) ([]byte, error)
• type Plugin
  • func (p *Plugin) Receiver() (cypress.Receiver, error)
• type Send
  • func (p *Send) Execute(args []string) error

Functions

func NewLogger

func NewLogger(address string, ssl bool) *tcplog.Logger

Types

type LogstashFormatter

type LogstashFormatter struct{}

func (*LogstashFormatter) Format

func (lf *LogstashFormatter) Format(m *cypress.Message) ([]byte, error)

type Plugin

type Plugin struct {
	Host string
	Ssl  bool
}

func (*Plugin) Receiver

func (p *Plugin) Receiver() (cypress.Receiver, error)

type Send

type Send struct {
	Host string `short:"H" long:"host" description:"Logstash host <host>:<port>"`
	Ssl  bool   `short:"S" long:"tls" default:"false" description:"Use TLS"`
}

func (*Send) Execute

func (p *Send) Execute(args []string) error