logstash

README

go-logstash

A golang package that sends newline delimited data via tcp to logstash.

Example

import(
	"github.com/heatxsink/go-logstash"
	"fmt"
)

func main() {
	l := logstash.New("127.0.0.1", 9000, 5)
	_, err := l.Connect()
	if err != nil {
		fmt.Println(err)
	}
	err = l.Writeln("{ 'foo' : 'bar' }")
	if err != nil {
		fmt.Println(err)
	}
}

Documentation

Index

• type Logstash
  • func New(hostname string, port int, timeout int) *Logstash
  • func (l *Logstash) Connect() (*net.TCPConn, error)
  • func (l *Logstash) Dump()
  • func (l *Logstash) SetTimeouts()
  • func (l *Logstash) Writeln(message string) error

Types

type Logstash

type Logstash struct {
	Hostname   string
	Port       int
	Connection *net.TCPConn
	Timeout    int
}

func New

func New(hostname string, port int, timeout int) *Logstash

func (*Logstash) Connect

func (l *Logstash) Connect() (*net.TCPConn, error)

func (*Logstash) Dump

func (l *Logstash) Dump()

func (*Logstash) SetTimeouts

func (l *Logstash) SetTimeouts()

func (*Logstash) Writeln

func (l *Logstash) Writeln(message string) error