The highest tagged major version is v2.

tcp

package

v1.11.5 Latest Latest Go to latest Published: Jan 23, 2024 License: MIT Imports: 7 Imported by: 19

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/influxdata/influxdb

Links

Open Source Insights

Documentation ¶

Overview ¶

Package tcp provides a simple multiplexer over TCP.

Index ¶

Constants
func Dial(network, address string, header byte) (net.Conn, error)
func MuxLogger(w io.Writer) *log.Logger
type Mux
- func NewMux(log *log.Logger) *Mux

Constants ¶

View Source

const (
	// DefaultTimeout is the default length of time to wait for first byte.
	DefaultTimeout = 30 * time.Second
)

Variables ¶

This section is empty.

Functions ¶

func Dial ¶ added in v0.9.4

func Dial(network, address string, header byte) (net.Conn, error)

Dial connects to a remote mux listener with a given header byte.

func MuxLogger ¶ added in v1.9.0

func MuxLogger(w io.Writer) *log.Logger

Types ¶

type Mux ¶

type Mux struct {

	// The amount of time to wait for the first header byte.
	Timeout time.Duration

	// Out-of-band error logger
	Logger *log.Logger
	// contains filtered or unexported fields
}

Mux multiplexes a network connection.

func NewMux ¶

func NewMux(log *log.Logger) *Mux

NewMux returns a new instance of Mux.

func (*Mux) DefaultListener ¶ added in v1.0.0

func (mux *Mux) DefaultListener() net.Listener

DefaultListener will return a net.Listener that will pass-through any connections with non-registered values for the first byte of the connection. The connections returned from this listener's Accept() method will replay the first byte of the connection as a short first Read().

This can be used to pass to an HTTP server, so long as there are no conflicts with registered listener bytes and the first character of the HTTP request: 71 ('G') for GET, etc.

func (*Mux) Listen ¶

func (mux *Mux) Listen(header byte) net.Listener

Listen returns a listener identified by header. Any connection accepted by mux is multiplexed based on the initial header byte.

func (*Mux) Serve ¶

func (mux *Mux) Serve(ln net.Listener) error

Serve handles connections from ln and multiplexes then across registered listeners.

Source Files ¶

View all Source files

mux.go

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