dialchain

Documentation

Index

• func LayerCBDialer(cb DialLayerCallback, d transport.Dialer) transport.Dialer
• func LayerDeltaCBDialer(cb DialLayerCallback, dialer transport.Dialer, ...) (transport.DialerFunc, error)
• type DialLayerCallback
• type DialerChain
  • func (c *DialerChain) AddLayer(l Layer)
  • func (c *DialerChain) Build() (d transport.Dialer, err error)
  • func (c *DialerChain) BuildWith(makeCB func(string) DialLayerCallback) (d transport.Dialer, err error)
  • func (c *DialerChain) BuildWithMeasures(event common.MapStr) (transport.Dialer, error)
  • func (c *DialerChain) Clone() *DialerChain
  • func (c *DialerChain) Dial(network, host string) (conn net.Conn, err error)
  • func (c *DialerChain) DialWithMeasurements(network, host string) (fields common.MapStr, conn net.Conn, err error)
  • func (c *DialerChain) TestBuild() error
• type Layer
  • func ConstAddrLayer(addr string, l Layer) Layer
  • func SOCKS5Layer(name string, config *transport.ProxyConfig) Layer
  • func TLSLayer(name string, config *transport.TLSConfig, timeout time.Duration) Layer
• type MeasureCallback
• type MeasureLayerRTTCB
  • func (cb *MeasureLayerRTTCB) Done(_ error)
  • func (cb *MeasureLayerRTTCB) Start()
• type NetDialer
  • func ConstAddrDialer(name, addr string, to time.Duration) NetDialer
  • func TCPDialer(name string, to time.Duration) NetDialer
  • func UDPDialer(name string, to time.Duration) NetDialer

Functions

func LayerCBDialer

func LayerCBDialer(cb DialLayerCallback, d transport.Dialer) transport.Dialer

func LayerDeltaCBDialer

func LayerDeltaCBDialer(
	cb DialLayerCallback,
	dialer transport.Dialer,
	layer func(transport.Dialer) (transport.Dialer, error),
) (transport.DialerFunc, error)

Types

type DialLayerCallback

type DialLayerCallback interface {
	Start()
	Done(err error)
}

type DialerChain

type DialerChain struct {
	Net    NetDialer
	Layers []Layer
}

func (*DialerChain) AddLayer

func (c *DialerChain) AddLayer(l Layer)

func (*DialerChain) Build

func (c *DialerChain) Build() (d transport.Dialer, err error)

func (*DialerChain) BuildWith

func (c *DialerChain) BuildWith(makeCB func(string) DialLayerCallback) (d transport.Dialer, err error)

func (*DialerChain) BuildWithMeasures

func (c *DialerChain) BuildWithMeasures(event common.MapStr) (transport.Dialer, error)

func (*DialerChain) Clone

func (c *DialerChain) Clone() *DialerChain

func (*DialerChain) Dial

func (c *DialerChain) Dial(network, host string) (conn net.Conn, err error)

func (*DialerChain) DialWithMeasurements

func (c *DialerChain) DialWithMeasurements(network, host string) (fields common.MapStr, conn net.Conn, err error)

func (*DialerChain) TestBuild

func (c *DialerChain) TestBuild() error

type Layer

type Layer struct {
	Name    string
	Builder func(transport.Dialer) (transport.Dialer, error)
}

func ConstAddrLayer

func ConstAddrLayer(addr string, l Layer) Layer

func SOCKS5Layer

func SOCKS5Layer(name string, config *transport.ProxyConfig) Layer

func TLSLayer

func TLSLayer(name string, config *transport.TLSConfig, timeout time.Duration) Layer

type MeasureCallback

type MeasureCallback func(start, end time.Time)

type MeasureLayerRTTCB

type MeasureLayerRTTCB struct {
	Callback MeasureCallback
	// contains filtered or unexported fields
}

func (*MeasureLayerRTTCB) Done

func (cb *MeasureLayerRTTCB) Done(_ error)

func (*MeasureLayerRTTCB) Start

func (cb *MeasureLayerRTTCB) Start()

type NetDialer

type NetDialer struct {
	Name   string
	Dialer transport.Dialer
}

func ConstAddrDialer

func ConstAddrDialer(name, addr string, to time.Duration) NetDialer

func TCPDialer

func TCPDialer(name string, to time.Duration) NetDialer

func UDPDialer

func UDPDialer(name string, to time.Duration) NetDialer