net

Documentation

Overview

Package net contains common network utilities.

Index

• Constants
• Variables
• type Address
  • func DomainAddress(domain string) Address
  • func IPAddress(ip []byte) Address
  • func ParseAddress(addr string) Address
• type Destination
  • func TCPDestination(address Address, port Port) Destination
  • func UDPDestination(address Address, port Port) Destination
• type IPNet
  • func NewIPNet() *IPNet
  • func NewIPNetInitialValue(data map[uint32]byte) *IPNet
  • func (this *IPNet) Add(ipNet *net.IPNet)
  • func (this *IPNet) Contains(ip net.IP) bool
  • func (this *IPNet) Serialize() []uint32
• type Network
  • func (this Network) AsList() *NetworkList
  • func (this Network) String() string
• type NetworkList
  • func NewNetworkList(networks collect.StringList) NetworkList
  • func (this *NetworkList) HasNetwork(network Network) bool
• type Port
  • func PortFromBytes(port []byte) Port
  • func PortFromInt(v int) (Port, error)
  • func PortFromString(s string) (Port, error)
  • func (this Port) Bytes(b []byte) []byte
  • func (this Port) String() string
  • func (this Port) Value() uint16
• type PortRange
  • func (this PortRange) Contains(port Port) bool
• type TimeOutReader
  • func NewTimeOutReader(timeout int, connection net.Conn) *TimeOutReader
  • func (reader *TimeOutReader) GetTimeOut() int
  • func (reader *TimeOutReader) Read(p []byte) (int, error)
  • func (reader *TimeOutReader) Release()
  • func (reader *TimeOutReader) SetTimeOut(value int)

Constants

const (
	// TCPNetwork represents the TCP network.
	TCPNetwork = Network("tcp")

	// UDPNetwork represents the UDP network.
	UDPNetwork = Network("udp")

	// KCPNetwork represents the KCP network.
	KCPNetwork = Network("kcp")
)

Variables

var (
	LocalHostIP = IPAddress([]byte{127, 0, 0, 1})
	AnyIP       = IPAddress([]byte{0, 0, 0, 0})
)

var (
	// ErrInvalidPortRage indicates an error during port range parsing.
	ErrInvalidPortRange = errors.New("Invalid port range.")
)

Types

type Address

type Address interface {
	IP() net.IP     // IP of this Address
	Domain() string // Domain of this Address

	IsIPv4() bool   // True if this Address is an IPv4 address
	IsIPv6() bool   // True if this Address is an IPv6 address
	IsDomain() bool // True if this Address is an domain address

	String() string // String representation of this Address
	Equals(Address) bool
}

Address represents a network address to be communicated with. It may be an IP address or domain address, not both. This interface doesn't resolve IP address for a given domain.

func DomainAddress

func DomainAddress(domain string) Address

DomainAddress creates an Address with given domain.

func IPAddress

func IPAddress(ip []byte) Address

IPAddress creates an Address with given IP.

func ParseAddress

func ParseAddress(addr string) Address

ParseAddress parses a string into an Address. The return value will be an IPAddress when the string is in the form of IPv4 or IPv6 address, or a DomainAddress otherwise.

type Destination

type Destination interface {
	Network() Network // Protocol of communication (tcp / udp)
	Address() Address // Address of destination
	Port() Port
	String() string // String representation of the destination
	NetAddr() string
	Equals(Destination) bool

	IsTCP() bool // True if destination is reachable via TCP
	IsUDP() bool // True if destination is reachable via UDP
}

Destination represents a network destination including address and protocol (tcp / udp).

func TCPDestination

func TCPDestination(address Address, port Port) Destination

TCPDestination creates a TCP destination with given address

func UDPDestination

func UDPDestination(address Address, port Port) Destination

UDPDestination creates a UDP destination with given address

type IPNet

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

func NewIPNet

func NewIPNet() *IPNet

func NewIPNetInitialValue

func NewIPNetInitialValue(data map[uint32]byte) *IPNet

func (*IPNet) Add

func (this *IPNet) Add(ipNet *net.IPNet)

func (*IPNet) Contains

func (this *IPNet) Contains(ip net.IP) bool

func (*IPNet) Serialize

func (this *IPNet) Serialize() []uint32

type Network

type Network string

Network represents a communication network on internet.

func (Network) AsList

func (this Network) AsList() *NetworkList

func (Network) String

func (this Network) String() string

type NetworkList

type NetworkList []Network

NetworkList is a list of Networks.

func NewNetworkList

func NewNetworkList(networks collect.StringList) NetworkList

NewNetworkList construsts a NetWorklist from the given StringListeralList.

func (*NetworkList) HasNetwork

func (this *NetworkList) HasNetwork(network Network) bool

HashNetwork returns true if the given network is in this NetworkList.

type Port

type Port uint16

Port represents a network port in TCP and UDP protocol.

func PortFromBytes

func PortFromBytes(port []byte) Port

PortFromBytes converts a byte array to a Port, assuming bytes are in big endian order. @unsafe Caller must ensure that the byte array has at least 2 elements.

func PortFromInt

func PortFromInt(v int) (Port, error)

PortFromInt converts an integer to a Port. @error when the integer is not positive or larger then 65535

func PortFromString

func PortFromString(s string) (Port, error)

PortFromString converts a string to a Port. @error when the string is not an integer or the integral value is a not a valid Port.

func (Port) Bytes

func (this Port) Bytes(b []byte) []byte

Bytes returns the correspoding bytes of this Port, in big endian order.

func (Port) String

func (this Port) String() string

String returns the string presentation of this Port.

func (Port) Value

func (this Port) Value() uint16

Value return the correspoding uint16 value of this Port.

type PortRange

type PortRange struct {
	From Port
	To   Port
}

PortRange represents a range of ports.

func (PortRange) Contains

func (this PortRange) Contains(port Port) bool

Contains returns true if the given port is within the range of this PortRange.

type TimeOutReader

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

func NewTimeOutReader

func NewTimeOutReader(timeout int, connection net.Conn) *TimeOutReader

func (*TimeOutReader) GetTimeOut

func (reader *TimeOutReader) GetTimeOut() int

func (*TimeOutReader) Read

func (reader *TimeOutReader) Read(p []byte) (int, error)

func (*TimeOutReader) Release

func (reader *TimeOutReader) Release()

func (*TimeOutReader) SetTimeOut

func (reader *TimeOutReader) SetTimeOut(value int)