tcputil

package

v0.2.0 Latest Latest Go to latest Published: Apr 17, 2023 License: BSD-3-Clause Imports: 5 Imported by: 8

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/vanadium/core

Links

Open Source Insights

Documentation ¶

Overview ¶

package tcputil contains functions commonly used to manipulate TCP connections.

Index ¶

func EnableTCPKeepAlive(conn net.Conn) error
func NewTCPConn(c net.Conn) flow.Conn
func TCPResolveAddrs(ctx *context.T, address string) ([]string, error)
type TCP

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func EnableTCPKeepAlive ¶

func EnableTCPKeepAlive(conn net.Conn) error

EnableTCPKeepAlive enabled the KeepAlive option on a TCP connection.

Some cloud providers (like Google Compute Engine) blackhole inactive TCP connections, we need to set TCP keep alive option to prevent that. See: https://developers.google.com/compute/docs/troubleshooting#communicatewithinternet

The same problem can happen when one end of a TCP connection dies and the TCP FIN or RST packet doesn't reach the other end, e.g. when the machine dies, falls off the network, or when there is packet loss. So, it is best to enable this option for all TCP connections.

func NewTCPConn ¶

func NewTCPConn(c net.Conn) flow.Conn

func TCPResolveAddrs ¶

func TCPResolveAddrs(ctx *context.T, address string) ([]string, error)

Types ¶

type TCP ¶

type TCP struct{}

func (TCP) Dial ¶

func (TCP) Dial(ctx *context.T, network, address string, timeout time.Duration) (flow.Conn, error)

Dial dials a net.Conn to a the specific address and adds framing to the connection.

func (TCP) Listen ¶

func (TCP) Listen(ctx *context.T, network, address string) (flow.Listener, error)

Listen returns a listener that sets KeepAlive on all accepted connections. Connections returned from the listener will be framed.

func (TCP) Resolve ¶

func (TCP) Resolve(ctx *context.T, network, address string) (string, []string, error)

Resolve performs a DNS resolution on the provided network and address.

Source Files ¶

View all Source files

tcputil.go

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