net

Documentation

Overview

Package net implements functions for running network servers.

Index

• func StartAcceptLoop(l net.Listener, rOpts retry.Options) (<-chan net.Conn, <-chan error)
• func StartForeverAcceptLoop(l net.Listener, rOpts retry.Options) (<-chan net.Conn, <-chan error)
• type ListenerOption
  • func ListenerReusePort(value bool) ListenerOption
• type ListenerOptions
  • func NewListenerOptions(opts ...ListenerOption) ListenerOptions
  • func (o ListenerOptions) Listen(protocol, address string) (gonet.Listener, error)

Examples

• StartForeverAcceptLoop

Functions

func StartAcceptLoop

func StartAcceptLoop(l net.Listener, rOpts retry.Options) (<-chan net.Conn, <-chan error)

StartAcceptLoop starts an accept loop for the given listener, returning accepted connections via a channel while handling temporary network errors. Fatal errors are returned via the error channel with the listener closed on return.

func StartForeverAcceptLoop

func StartForeverAcceptLoop(l net.Listener, rOpts retry.Options) (<-chan net.Conn, <-chan error)

StartForeverAcceptLoop starts an accept loop for the given listener that retries forever, returning accepted connections via a channel while handling temporary network errors. Fatal errors are returned via the error channel with the listener closed on return.

Example

Types

type ListenerOption

type ListenerOption func(o *ListenerOptions)

ListenerOption is a listener option that can be applied to a set of listener options.

func ListenerReusePort

func ListenerReusePort(value bool) ListenerOption

ListenerReusePort is a listener option to reuse ports.

type ListenerOptions

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

ListenerOptions is a set of listener options that can create listeners.

func NewListenerOptions

func NewListenerOptions(opts ...ListenerOption) ListenerOptions

NewListenerOptions creates a set of listener options with supplied options.

func (ListenerOptions) Listen

func (o ListenerOptions) Listen(
	protocol, address string,
) (gonet.Listener, error)

Listen creates a new listener based on options.