logreceiver

Documentation

Overview

Package logreceiver implements JSON-over-TCP log receiver.

Index

• type Handler
• type Server
  • func NewServer(logger *zap.Logger, listener net.Listener, handler Handler) *Server
  • func (srv *Server) Serve() error
  • func (srv *Server) Stop()

Types

type Handler

type Handler func(srcAddress netip.Addr, msg map[string]interface{})

Handler is called for each received message.

type Server

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

Server implements TCP server to receive JSON logs.

func NewServer

func NewServer(logger *zap.Logger, listener net.Listener, handler Handler) *Server

NewServer initializes new Server.

func (*Server) Serve

func (srv *Server) Serve() error

Serve runs the TCP server loop.

func (*Server) Stop

func (srv *Server) Stop()

Stop serving.

This has a bug that it doesn't close the connections.