Versions in this module Expand all Collapse all v0 v0.1.0 Jun 17, 2016 Changes in this version + type ACKWriter interface + ACK func(int) error + Keepalive func(int) error + type BatchReader interface + ReadBatch func() (*lj.Batch, error) + type Config struct + Channel chan *lj.Batch + Handler HandlerFactory + TLS *tls.Config + type Eventer interface + OnEvents func(*lj.Batch) error + type Handler interface + Run func() + Stop func() + type HandlerFactory func(Eventer, net.Conn) (Handler, error) + func DefaultHandler(keepalive time.Duration, mk ProtocolFactory) HandlerFactory + type ProtocolFactory func(conn net.Conn) (BatchReader, ACKWriter, error) + type Server struct + func ListenAndServe(addr string, opts Config) (*Server, error) + func ListenAndServeWith(binder func(network, addr string) (net.Listener, error), addr string, ...) (*Server, error) + func NewWithListener(l net.Listener, opts Config) (*Server, error) + func (s *Server) Close() error + func (s *Server) Receive() *lj.Batch + func (s *Server) ReceiveChan() <-chan *lj.Batch