package sockets

import "github.com/docker/docker/vendor/github.com/docker/go-connections/sockets"

Package sockets provides helper functions to create and configure Unix or TCP sockets.

Package sockets provides helper functions to create and configure Unix or TCP sockets.

Index ¶

• Variables
• func ConfigureTransport(tr *http.Transport, proto, addr string) error
• func DialPipe(_ string, _ time.Duration) (net.Conn, error)
• func DialerFromEnvironment(direct *net.Dialer) (proxy.Dialer, error)
• func GetProxyEnv(key string) string
• func NewTCPSocket(addr string, tlsConfig *tls.Config) (net.Listener, error)
• func NewUnixSocket(path string, gid int) (net.Listener, error)
• type InmemSocket
• func NewInmemSocket(addr string, bufSize int) *InmemSocket
• func (s *InmemSocket) Accept() (net.Conn, error)
• func (s *InmemSocket) Addr() net.Addr
• func (s *InmemSocket) Close() error
• func (s *InmemSocket) Dial(network, addr string) (net.Conn, error)

Package Files ¶

inmem_socket.go proxy.go sockets.go sockets_unix.go tcp_socket.go unix_socket.go

Variables ¶

var ErrProtocolNotAvailable = errors.New("protocol not available")

ErrProtocolNotAvailable is returned when a given transport protocol is not provided by the operating system.

func ConfigureTransport ¶ Uses

func ConfigureTransport(tr *http.Transport, proto, addr string) error

ConfigureTransport configures the specified Transport according to the specified proto and addr. If the proto is unix (using a unix socket to communicate) or npipe the compression is disabled.

func DialPipe ¶ Uses

func DialPipe(_ string, _ time.Duration) (net.Conn, error)

DialPipe connects to a Windows named pipe. This is not supported on other OSes.

func DialerFromEnvironment ¶ Uses

func DialerFromEnvironment(direct *net.Dialer) (proxy.Dialer, error)

DialerFromEnvironment takes in a "direct" *net.Dialer and returns a proxy.Dialer which will route the connections through the proxy using the given dialer.

func GetProxyEnv ¶ Uses

func GetProxyEnv(key string) string

GetProxyEnv allows access to the uppercase and the lowercase forms of proxy-related variables. See the Go specification for details on these variables. https://golang.org/pkg/net/http/

func NewTCPSocket ¶ Uses

func NewTCPSocket(addr string, tlsConfig *tls.Config) (net.Listener, error)

NewTCPSocket creates a TCP socket listener with the specified address and the specified tls configuration. If TLSConfig is set, will encapsulate the TCP listener inside a TLS one.

func NewUnixSocket ¶ Uses

func NewUnixSocket(path string, gid int) (net.Listener, error)

NewUnixSocket creates a unix socket with the specified path and group.

type InmemSocket ¶ Uses

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

InmemSocket implements net.Listener using in-memory only connections.

func NewInmemSocket ¶ Uses

func NewInmemSocket(addr string, bufSize int) *InmemSocket

NewInmemSocket creates an in-memory only net.Listener The addr argument can be any string, but is used to satisfy the `Addr()` part of the net.Listener interface

func (*InmemSocket) Accept ¶ Uses

func (s *InmemSocket) Accept() (net.Conn, error)

Accept implements the Accept method in the Listener interface; it waits for the next call and returns a generic Conn.

func (*InmemSocket) Addr ¶ Uses

func (s *InmemSocket) Addr() net.Addr

Addr returns the socket's addr string to satisfy net.Listener

func (*InmemSocket) Close ¶ Uses

func (s *InmemSocket) Close() error

Close closes the listener. It will be unavailable for use once closed.

func (*InmemSocket) Dial ¶ Uses

func (s *InmemSocket) Dial(network, addr string) (net.Conn, error)

Dial is used to establish a connection with the in-mem server