network

Documentation

Index

• Variables
• func CreateHTTPListener(conf *config.Config) (l net.Listener, err error)
• func CreateScraperSocket(conf *config.Config) (pc net.PacketConn, err error)
• func WrapListener(l net.Listener) net.Listener
• type GracefulHttpCloser
  • func (c *GracefulHttpCloser) Close() error
• type GracefulListener
  • func (l *GracefulListener) Accept() (net.Conn, error)
  • func (l *GracefulListener) Addr() net.Addr
  • func (l *GracefulListener) Close() (err error)

Variables

var ErrListenerStopped = errors.New("listener was stopped")

Functions

func CreateHTTPListener

func CreateHTTPListener(conf *config.Config) (l net.Listener, err error)

CreateHTTPListener creates a net.Listener for main http webapp given main config

func CreateScraperSocket

func CreateScraperSocket(conf *config.Config) (pc net.PacketConn, err error)

CreateScraperSocket creates a UDP Scraper socket

func WrapListener

func WrapListener(l net.Listener) net.Listener

WrapListener wraps a net.Listener such that it can be closed gracefully

Types

type GracefulHttpCloser

type GracefulHttpCloser struct {
	Server   *http.Server
	Listener net.Listener
}

implements io.Closer that gracefully closes an http server

func (*GracefulHttpCloser) Close

func (c *GracefulHttpCloser) Close() error

type GracefulListener

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

GracefulListener provides safe and graceful net.Listener wrapper that prevents error on graceful shutdown

func (*GracefulListener) Accept

func (l *GracefulListener) Accept() (net.Conn, error)

func (*GracefulListener) Addr

func (l *GracefulListener) Addr() net.Addr

func (*GracefulListener) Close

func (l *GracefulListener) Close() (err error)