transport

Documentation

Index

• func NewMuxInboundTransport(u *url.URL, inner InboundTransport) (*muxInboundTransport, error)
• func NewMuxOutboundTransport(u *url.URL, inner OutboundTransport) (*muxOutboundTransport, error)
• func NewTLSInboundTransport(u *url.URL, inner InboundTransport) (*tlsInboundTransport, error)
• func NewTLSOutboundTransport(u *url.URL, inner OutboundTransport) (*tlsOutboundTransport, error)
• type InboundTransport
  • func CreateInboundTransport(name string, u *url.URL, inner InboundTransport) (InboundTransport, error)
• type OutboundTransport
  • func CreateOutboundTransport(name string, u *url.URL, inner OutboundTransport) (OutboundTransport, error)
• type TLSTransport
• type TcpInboundTransport
  • func NewDefaultTcpInboundTransport(u *url.URL) (TcpInboundTransport, error)
  • func RequireTcpInboundTransport(u *url.URL, inner InboundTransport) (TcpInboundTransport, error)
• type TcpOutboundTransport
  • func NewDefaultTcpOutboundTransport(u *url.URL) (TcpOutboundTransport, error)
  • func RequireTcpOutboundTransport(u *url.URL, inner OutboundTransport) (TcpOutboundTransport, error)

Functions

func NewMuxInboundTransport

func NewMuxInboundTransport(u *url.URL, inner InboundTransport) (*muxInboundTransport, error)

func NewMuxOutboundTransport

func NewMuxOutboundTransport(u *url.URL, inner OutboundTransport) (*muxOutboundTransport, error)

func NewTLSInboundTransport

func NewTLSInboundTransport(u *url.URL, inner InboundTransport) (*tlsInboundTransport, error)

func NewTLSOutboundTransport

func NewTLSOutboundTransport(u *url.URL, inner OutboundTransport) (*tlsOutboundTransport, error)

Types

type InboundTransport

type InboundTransport interface {
	InboundTransportName() string
	io.Closer
}

func CreateInboundTransport

func CreateInboundTransport(name string, u *url.URL, inner InboundTransport) (InboundTransport, error)

type OutboundTransport

type OutboundTransport interface {
	OutboundTransportName() string
}

func CreateOutboundTransport

func CreateOutboundTransport(name string, u *url.URL, inner OutboundTransport) (OutboundTransport, error)

type TLSTransport

type TLSTransport interface {
	TLSConfig() *tls.Config
}

type TcpInboundTransport

type TcpInboundTransport interface {
	InboundTransport
	net.Listener
}

func NewDefaultTcpInboundTransport

func NewDefaultTcpInboundTransport(u *url.URL) (TcpInboundTransport, error)

func RequireTcpInboundTransport

func RequireTcpInboundTransport(u *url.URL, inner InboundTransport) (TcpInboundTransport, error)

type TcpOutboundTransport

type TcpOutboundTransport interface {
	OutboundTransport
	OpenConnection() (net.Conn, error)
}

func NewDefaultTcpOutboundTransport

func NewDefaultTcpOutboundTransport(u *url.URL) (TcpOutboundTransport, error)

func RequireTcpOutboundTransport

func RequireTcpOutboundTransport(u *url.URL, inner OutboundTransport) (TcpOutboundTransport, error)