reuseport

package module
Version: v1.5.0 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Oct 29, 2019 License: MIT Imports: 8 Imported by: 100

README

GO_REUSEPORT

Build Status codecov GoDoc

GO_REUSEPORT is a little expirement to create a net.Listener that supports SO_REUSEPORT socket option.

For now, Darwin and Linux (from 3.9) systems are supported. I'll be pleased if you'll test other systems and tell me the results. documentation on godoc.org.

Example

package main

import (
  "fmt"
  "html"
  "net/http"
  "os"
  "runtime"
  "github.com/kavu/go_reuseport"
)

func main() {
  listener, err := reuseport.Listen("tcp", "localhost:8881")
  if err != nil {
    panic(err)
  }
  defer listener.Close()

  server := &http.Server{}
  http.HandleFunc("/", func(w http.ResponseWriter, r *http.Request) {
    fmt.Println(os.Getgid())
    fmt.Fprintf(w, "Hello, %q\n", html.EscapeString(r.URL.Path))
  })

  panic(server.Serve(listener))
}

Now you can run several instances of this tiny server without Address already in use errors.

Thanks

Inspired by Artur Siekielski post about SO_REUSEPORT.

Documentation

Overview

Package reuseport provides a function that returns a net.Listener powered by a net.FileListener with a SO_REUSEPORT option set to the socket.

Index

Examples

Constants

This section is empty.

Variables

This section is empty.

Functions

func Listen added in v1.2.0

func Listen(proto, addr string) (l net.Listener, err error)

Listen function is an alias for NewReusablePortListener.

func ListenPacket added in v1.2.0

func ListenPacket(proto, addr string) (l net.PacketConn, err error)

ListenPacket is an alias for NewReusablePortPacketConn.

func NewReusablePortListener

func NewReusablePortListener(proto, addr string) (l net.Listener, err error)

NewReusablePortListener returns net.FileListener that created from a file discriptor for a socket with SO_REUSEPORT option.

Example
listener, err := NewReusablePortListener("tcp", ":8881")
if err != nil {
	panic(err)
}
defer listener.Close()

server := &http.Server{}
http.HandleFunc("/", func(w http.ResponseWriter, r *http.Request) {
	fmt.Println(os.Getgid())
	fmt.Fprintf(w, "Hello, %q\n", html.EscapeString(r.URL.Path))
})

panic(server.Serve(listener))
Output:

func NewReusablePortPacketConn added in v1.2.0

func NewReusablePortPacketConn(proto, addr string) (l net.PacketConn, err error)

NewReusablePortPacketConn returns net.FilePacketConn that created from a file discriptor for a socket with SO_REUSEPORT option.

Types

This section is empty.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL