util

Documentation

Index

• Constants
• Variables
• func BackoffRetry(ctx context.Context, callback func() error, exp float32, ...) error
• func ByteCountIEC(b uint64) string
• func CalculateBackOff(retries int, exp float32, base, min, max time.Duration) time.Duration
• func ExtractConnRemoteURL(Conn net.Conn) *url.URL
• func GenerateDirectAccessAddresses(protocol string, addresses []string, port string, queryMap url.Values) ([]url.URL, error)
• func NewHookedListener(raw net.Listener, hook ListenerHook) net.Listener
• func Relay(RuntimeContext context.Context, peerA io.ReadWriteCloser, ...) error
• func ResolveIPForInterface(devName string) ([]string, error)
• type DefaultLogger
  • func (*DefaultLogger) Errorf(format string, args ...interface{})
  • func (*DefaultLogger) Printf(format string, args ...interface{})
• type HookedListener
  • func (l *HookedListener) Accept() (net.Conn, error)
  • func (l *HookedListener) Addr() net.Addr
• type InmemoryListener
  • func NewInMemoryListener() *InmemoryListener
  • func (l *InmemoryListener) Accept() (net.Conn, error)
  • func (l *InmemoryListener) Addr() net.Addr
  • func (l *InmemoryListener) Close() error
  • func (l *InmemoryListener) Dial() (net.Conn, error)
  • func (l *InmemoryListener) IsClosed() bool
• type ListenerHook
• type Logger
• type LoggerTracker
  • func (l *LoggerTracker) Close() error
• type NopLogger
  • func (*NopLogger) Errorf(string, ...interface{})
  • func (*NopLogger) Printf(string, ...interface{})
• type NopTracer
  • func (*NopTracer) Close() error
  • func (*NopTracer) Errorf(string, ...interface{})
  • func (*NopTracer) Printf(string, ...interface{})
• type Timer
  • func NewTimer(whenExpired func()) *Timer
  • func (timer *Timer) Del()
  • func (timer *Timer) DelSync()
  • func (timer *Timer) IsPending() bool
  • func (timer *Timer) Mod(d time.Duration)
• type TraceWrapper
  • func (t *TraceWrapper) Close() error
  • func (t *TraceWrapper) Errorf(format string, args ...interface{})
  • func (t *TraceWrapper) Printf(format string, args ...interface{})
• type Tracer
• type TracerFunc
• type URLAddr
  • func (u *URLAddr) Network() string
  • func (u *URLAddr) String() string

Constants

const DiscoveryDirectProtocol = "xtcp"

Variables

var (
	XConnVersion   = "2"
	YukinetVersion = "Unknown"
	BuildDate      = ""
)

var BiCopyInflight = atomic.Int64{}

Functions

func BackoffRetry

func BackoffRetry(ctx context.Context, callback func() error, exp float32, base, min, max time.Duration, maxConsectiveRetries int) error

func ByteCountIEC

func ByteCountIEC(b uint64) string

func CalculateBackOff

func CalculateBackOff(retries int, exp float32, base, min, max time.Duration) time.Duration

func ExtractConnRemoteURL

func ExtractConnRemoteURL(Conn net.Conn) *url.URL

func GenerateDirectAccessAddresses

func GenerateDirectAccessAddresses(protocol string, addresses []string, port string, queryMap url.Values) ([]url.URL, error)

func NewHookedListener

func NewHookedListener(raw net.Listener, hook ListenerHook) net.Listener

func Relay

func Relay(RuntimeContext context.Context, peerA io.ReadWriteCloser, peerB io.ReadWriteCloser) error

func ResolveIPForInterface

func ResolveIPForInterface(devName string) ([]string, error)

`devName` can be a list of interface names separated by `,`.

Types

type DefaultLogger

type DefaultLogger struct{}

func (*DefaultLogger) Errorf

func (*DefaultLogger) Errorf(format string, args ...interface{})

func (*DefaultLogger) Printf

func (*DefaultLogger) Printf(format string, args ...interface{})

type HookedListener

type HookedListener struct {
	net.Listener
	// contains filtered or unexported fields
}

HookedListener is a listener with a customized hook function.

func (*HookedListener) Accept

func (l *HookedListener) Accept() (net.Conn, error)

func (*HookedListener) Addr

func (l *HookedListener) Addr() net.Addr

type InmemoryListener

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

InmemoryListener implements a listener for testing purpose.

func NewInMemoryListener

func NewInMemoryListener() *InmemoryListener

NewInMemoryListener creates an inmemory listener.

func (*InmemoryListener) Accept

func (l *InmemoryListener) Accept() (net.Conn, error)

Accept returns a connection just like net.Listener.

func (*InmemoryListener) Addr

func (l *InmemoryListener) Addr() net.Addr

Addr returns the address of the listener.

func (*InmemoryListener) Close

func (l *InmemoryListener) Close() error

Close closes the listener. Will immeidately return nil if the listener is already closed.

func (*InmemoryListener) Dial

func (l *InmemoryListener) Dial() (net.Conn, error)

Dial creates a connection to the InMemoryListener directly.

func (*InmemoryListener) IsClosed

func (l *InmemoryListener) IsClosed() bool

IsClosed returns if the listener is closed.

type ListenerHook

type ListenerHook func(net.Conn, error) (bool, net.Conn, error)

ListenerHook specifies a callback that is invoked after inner listener returns a result from Accept(). If `skip` is true, returned connection will be closed (if not error) and will re-invoke the Accept for the next result.

type Logger

type Logger interface {
	Printf(string, ...interface{})
	Errorf(string, ...interface{})
}

Logger is a generic logging interface.

type LoggerTracker

type LoggerTracker struct{ Logger }

func (*LoggerTracker) Close

func (l *LoggerTracker) Close() error

type NopLogger

type NopLogger struct{}

NopLogger drops all loggings.

func (*NopLogger) Errorf

func (*NopLogger) Errorf(string, ...interface{})

func (*NopLogger) Printf

func (*NopLogger) Printf(string, ...interface{})

type NopTracer

type NopTracer struct{}

func (*NopTracer) Close

func (*NopTracer) Close() error

func (*NopTracer) Errorf

func (*NopTracer) Errorf(string, ...interface{})

func (*NopTracer) Printf

func (*NopTracer) Printf(string, ...interface{})

type Timer

type Timer struct {
	*time.Timer
	// contains filtered or unexported fields
}

Timer roughly copies the interface of the Linux kernel's struct timer_list.

func NewTimer

func NewTimer(whenExpired func()) *Timer

func (*Timer) Del

func (timer *Timer) Del()

func (*Timer) DelSync

func (timer *Timer) DelSync()

func (*Timer) IsPending

func (timer *Timer) IsPending() bool

func (*Timer) Mod

func (timer *Timer) Mod(d time.Duration)

type TraceWrapper

type TraceWrapper struct {
	Trace trace.Trace
	// contains filtered or unexported fields
}

func (*TraceWrapper) Close

func (t *TraceWrapper) Close() error

func (*TraceWrapper) Errorf

func (t *TraceWrapper) Errorf(format string, args ...interface{})

func (*TraceWrapper) Printf

func (t *TraceWrapper) Printf(format string, args ...interface{})

type Tracer

type Tracer interface {
	Logger
	io.Closer
}

Tracer is a generic trace interface, it will close the trace if Close() is called.

type TracerFunc

type TracerFunc func(Conn net.Conn, Family string, Instance string) Tracer

type URLAddr

type URLAddr struct {
	URL *url.URL
}

func (*URLAddr) Network

func (u *URLAddr) Network() string

func (*URLAddr) String

func (u *URLAddr) String() string