dialer

Oct 11, 2024

Changes in this version

type Dialer

+ func (d *Dialer) Clone() *Dialer

type GlobalOption

+ func NewGlobalOption(global *config.Global, log *logrus.Logger) *GlobalOption

Jun 16, 2024

Changes in this version

type Dialer

+ func (d *Dialer) ReportUnavailable(typ *NetworkType, err error)

Jan 23, 2024

Changes in this version

type InstanceOption

+ DisableCheck bool

Dec 26, 2023

Changes in this version

+ func TransparentControl(c syscall.RawConn) error

type AliveDialerSet

+ func (a *AliveDialerSet) SortingLatency(d *Dialer) time.Duration

type Property

+ SubscriptionTag string

Jul 17, 2023

Changes in this version

+ const AnnotationKey_AddLatency

+ const Timeout

+ type Annotation struct

+ AddLatency time.Duration

+ func NewAnnotation(annotation []*config_parser.Param) (*Annotation, error)

type Dialer

+ InstanceOption InstanceOption

Jul 2, 2023

Changes in this version

type CheckDnsOptionRaw

+ ResolverNetwork string

+ Somark uint32

type GlobalOption

+ TlsImplementation string

+ UtlsImitate string

type TcpCheckOptionRaw

+ ResolverNetwork string

Jun 4, 2023

Changes in this version

type TcpCheckOption

+ Method string

type TcpCheckOptionRaw

+ Method string

Mar 29, 2023

Changes in this version

type TcpCheckOptionRaw

+ Log *logrus.Logger

Mar 14, 2023

Changes in this version

+ const Init

+ const NotAlive

+ var InvalidParameterErr = fmt.Errorf("invalid parameters")

+ var UnexpectedFieldErr = fmt.Errorf("unexpected field")

+ func BindControl(c syscall.RawConn, lAddrPort netip.AddrPort) error

+ func FromLinkRegister(name string, creator FromLinkCreator)

+ func SoMarkControl(c syscall.RawConn, mark int) error

+ func TproxyControl(c syscall.RawConn) error

+ type AliveDialerSet struct

+ CheckTyp *NetworkType

+ func NewAliveDialerSet(log *logrus.Logger, dialerGroupName string, networkType *NetworkType, ...) *AliveDialerSet

+ func (a *AliveDialerSet) GetMinLatency() (d *Dialer, latency time.Duration)

+ func (a *AliveDialerSet) GetRand() *Dialer

+ func (a *AliveDialerSet) NotifyLatencyChange(dialer *Dialer, alive bool)

+ type AliveDialerSetSet map[*AliveDialerSet]int

+ type CheckDnsOption struct

+ DnsHost string

+ DnsPort uint16

+ func ParseCheckDnsOption(ctx context.Context, dnsHostPort string) (opt *CheckDnsOption, err error)

+ type CheckDnsOptionRaw struct

+ Raw string

+ func (c *CheckDnsOptionRaw) Option() (opt *CheckDnsOption, err error)

+ type CheckOption struct

+ CheckFunc func(ctx context.Context, typ *NetworkType) (ok bool, err error)

+ type Dialer struct

+ func NewBlockDialer(option *GlobalOption, dialCallback func()) *Dialer

+ func NewDialer(dialer netproxy.Dialer, option *GlobalOption, iOption InstanceOption, ...) *Dialer

+ func NewDirectDialer(option *GlobalOption, fullcone bool) *Dialer

+ func NewFromLink(gOption *GlobalOption, iOption InstanceOption, link string) (dialer *Dialer, err error)

+ func (d *Dialer) ActivateCheck()

+ func (d *Dialer) Check(timeout time.Duration, opts *CheckOption) (ok bool, err error)

+ func (d *Dialer) Close() error

+ func (d *Dialer) DnsCheck(ctx context.Context, dns netip.AddrPort, tcp bool) (ok bool, err error)

+ func (d *Dialer) HttpCheck(ctx context.Context, u *netutils.URL, ip netip.Addr) (ok bool, err error)

+ func (d *Dialer) MustGetAlive(typ *NetworkType) bool

+ func (d *Dialer) MustGetLatencies10(typ *NetworkType) *LatenciesN

+ func (d *Dialer) NotifyCheck()

+ func (d *Dialer) Property() Property

+ func (d *Dialer) RegisterAliveDialerSet(a *AliveDialerSet)

+ func (d *Dialer) UnregisterAliveDialerSet(a *AliveDialerSet)

+ type FromLinkCreator func(gOption *GlobalOption, iOption InstanceOption, link string) (dialer *Dialer, err error)

+ type GlobalOption struct

+ AllowInsecure bool

+ CheckDnsOptionRaw CheckDnsOptionRaw

+ CheckDnsTcp bool

+ CheckInterval time.Duration

+ CheckTolerance time.Duration

+ Log *logrus.Logger

+ TcpCheckOptionRaw TcpCheckOptionRaw

+ type InstanceOption struct

+ CheckEnabled bool

+ type LatenciesN struct

+ LastNLatencies *list.List

+ N int

+ SumNLatencies time.Duration

+ func NewLatenciesN(n int) *LatenciesN

+ func (ln *LatenciesN) AppendLatency(l time.Duration)

+ func (ln *LatenciesN) AvgLatency() (time.Duration, bool)

+ func (ln *LatenciesN) LastLatency() (time.Duration, bool)

+ type NetworkType struct

+ IpVersion consts.IpVersionStr

+ IsDns bool

+ L4Proto consts.L4ProtoStr

+ func (t *NetworkType) String() string

+ func (t *NetworkType) StringWithoutDns() string

+ type Property struct

+ Address string

+ Link string

+ Name string

+ Protocol string

+ type TcpCheckOption struct

+ Url *netutils.URL

+ func ParseTcpCheckOption(ctx context.Context, rawURL string) (opt *TcpCheckOption, err error)

+ type TcpCheckOptionRaw struct

+ Raw string

+ func (c *TcpCheckOptionRaw) Option() (opt *TcpCheckOption, err error)