logstash

Documentation

Index

• Variables
• type LogstashClient
  • func NewLogstashClient(hostname string, port int, socketTimeoutMS int) *LogstashClient
  • func (logstash *LogstashClient) Connect() (*net.TCPConn, error)
  • func (logstash *LogstashClient) ReadEventsFromBacklog()
  • func (logstash *LogstashClient) Send(message string) error
  • func (logstash *LogstashClient) SendEventToBacklog(message string)

Variables

var (
	EventChannel  chan string = make(chan string, 20)
	ConsoleOutput bool
)

Types

type LogstashClient

type LogstashClient struct {
	Hostname      string
	Port          int
	Connection    *net.TCPConn
	SocketTimeout int
}

func NewLogstashClient

func NewLogstashClient(hostname string, port int, socketTimeoutMS int) *LogstashClient

func (*LogstashClient) Connect

func (logstash *LogstashClient) Connect() (*net.TCPConn, error)

func (*LogstashClient) ReadEventsFromBacklog

func (logstash *LogstashClient) ReadEventsFromBacklog()

func (*LogstashClient) Send

func (logstash *LogstashClient) Send(message string) error

func (*LogstashClient) SendEventToBacklog

func (logstash *LogstashClient) SendEventToBacklog(message string)