util

Documentation

Index

• func Diff(a, b []string) ([]string, []string)
• func IsClosedErr(err error) bool
• func Member(list []string, a string) bool
• func NewFileConn(file *os.File) net.Conn
• func Remove(ss []string, e string) []string
• func Unique(s []string) []string
• type FileConn
  • func (f *FileConn) Close() error
  • func (f *FileConn) LocalAddr() net.Addr
  • func (f *FileConn) Read(b []byte) (n int, err error)
  • func (f *FileConn) RemoteAddr() net.Addr
  • func (f *FileConn) SetDeadline(t time.Time) error
  • func (f *FileConn) SetReadDeadline(t time.Time) error
  • func (f *FileConn) SetWriteDeadline(t time.Time) error
  • func (f *FileConn) Write(b []byte) (n int, err error)
• type FileConnAddr
  • func (s *FileConnAddr) Network() string
  • func (s *FileConnAddr) String() string
• type PacketConnPool
  • func NewPacketConnPool(vnet transport.Net, threadNum int) PacketConnPool

Functions

func Diff

func Diff(a, b []string) ([]string, []string)

Diff computes the diff of two string slices a and b, returns a-b and b-a

func IsClosedErr

func IsClosedErr(err error) bool

IsClosedErr is a helper function to check for "already closed" errors, which are usually harmless but still show up in logs, code adapted from https://stackoverflow.com/questions/44974984/how-to-check-a-net-conn-is-closed

func Member

func Member(list []string, a string) bool

check is list contains element a

func NewFileConn

func NewFileConn(file *os.File) net.Conn

NewFileConn returns a wrapper that shows an os.File as a net.Conn.

func Remove

func Remove(ss []string, e string) []string

Remove removes a given element from string slice

func Unique

func Unique(s []string) []string

Unique returns unique elements in a string slice

Types

type FileConn

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

func (*FileConn) Close

func (f *FileConn) Close() error

func (*FileConn) LocalAddr

func (f *FileConn) LocalAddr() net.Addr

func (*FileConn) Read

func (f *FileConn) Read(b []byte) (n int, err error)

func (*FileConn) RemoteAddr

func (f *FileConn) RemoteAddr() net.Addr

func (*FileConn) SetDeadline

func (f *FileConn) SetDeadline(t time.Time) error

func (*FileConn) SetReadDeadline

func (f *FileConn) SetReadDeadline(t time.Time) error

func (*FileConn) SetWriteDeadline

func (f *FileConn) SetWriteDeadline(t time.Time) error

func (*FileConn) Write

func (f *FileConn) Write(b []byte) (n int, err error)

type FileConnAddr

type FileConnAddr struct {
	File *os.File
}

func (*FileConnAddr) Network

func (s *FileConnAddr) Network() string

func (*FileConnAddr) String

func (s *FileConnAddr) String() string

type PacketConnPool

type PacketConnPool interface {
	// Make creates a PacketConnPool, caller must make sure to close the sockets.
	Make(network, address string) ([]net.PacketConn, error)
	// Size returns the number of sockets in the pool.
	Size() int
}

PacketConnPool is a factory to create pools of related PacketConns, which may either be a set of PacketConns bound to the same local IP using SO_REUSEPORT (on unix, under certain circumstances) that can do multithreaded readloops, or a single PacketConn as a fallback for non-unic architectures and for testing.

func NewPacketConnPool

func NewPacketConnPool(vnet transport.Net, threadNum int) PacketConnPool

NewPacketConnPool creates a new packet connection pool. Pooling is disabled if threadNum is zero or if we are running on top of transport.VNet (which does not support reuseport), or if we are on non-unix, see the fallback in socketpool.go.