Versions in this module Expand all Collapse all v0 v0.1.0 Jun 17, 2016 Changes in this version + var ErrListenerClosed = errors.New("listener closed") + var ErrNoVersionEnabled = errors.New("No protocol version enabled") + type Option func(*options) error + 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 + func V1(b bool) Option + func V2(b bool) Option + type Server interface + Close func() error + Receive func() *lj.Batch + ReceiveChan func() <-chan *lj.Batch + 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)
Go to main page