v2

Documentation

Overview

Package v2 implements the lumberjack server supporting protocol version 2.

Index

• Variables
• type Option
  • func Channel(c chan *lj.Batch) Option
  • func JSONDecoder(decoder func([]byte, interface{}) error) Option
  • func Keepalive(kl time.Duration) Option
  • func TLS(tls *tls.Config) Option
  • func Timeout(to time.Duration) Option
• type Server
  • func ListenAndServe(addr string, opts ...Option) (*Server, error)
  • func ListenAndServeWith(binder func(network, addr string) (net.Listener, error), addr string, ...) (*Server, error)
  • func NewWithListener(l net.Listener, opts ...Option) (*Server, error)
  • func (s *Server) Close() error
  • func (s *Server) Receive() *lj.Batch
  • func (s *Server) ReceiveChan() <-chan *lj.Batch

Variables

var (
	// ErrProtocolError is returned if an protocol error was detected in the
	// conversation with lumberjack server.
	ErrProtocolError = errors.New("lumberjack protocol error")
)

Types

type Option

type Option func(*options) error

Option type for configuring server run options.

func Channel

func Channel(c chan *lj.Batch) Option

Channel option is used to register custom channel received batches will be forwarded to.

func JSONDecoder

func JSONDecoder(decoder func([]byte, interface{}) error) Option

JSONDecoder sets an alternative json decoder for parsing events. The default is json.Unmarshal.

func Keepalive

func Keepalive(kl time.Duration) Option

Keepalive configures the keepalive interval returning an ACK of length 0 to lumberjack client, notifying clients the batch being still active.

func TLS

func TLS(tls *tls.Config) Option

TLS enables and configures TLS support in lumberjack server.

func Timeout

func Timeout(to time.Duration) Option

Timeout configures server network timeouts.

type Server

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

Server serves multiple lumberjack clients supporting protocol version 2.

func ListenAndServe

func ListenAndServe(addr string, opts ...Option) (*Server, error)

ListenAndServe listens on the TCP network address addr and handles batch requests from accepted lumberjack clients.

func ListenAndServeWith

func ListenAndServeWith(
	binder func(network, addr string) (net.Listener, error),
	addr string,
	opts ...Option,
) (*Server, error)

ListenAndServeWith uses binder to create a listener for establishing a lumberjack endpoint.

func NewWithListener

func NewWithListener(l net.Listener, opts ...Option) (*Server, error)

NewWithListener creates a new Server using an existing net.Listener.

func (*Server) Close

func (s *Server) Close() error

Close stops the listener, closes all active connections and closes the receiver channel returned from ReceiveChan().

func (*Server) Receive

func (s *Server) Receive() *lj.Batch

Receive returns the next received batch from the receiver channel. Batches returned by Receive must be ACKed.

func (*Server) ReceiveChan

func (s *Server) ReceiveChan() <-chan *lj.Batch

ReceiveChan returns a channel all received batch requests will be made available on. Batches read from channel must be ACKed.