transport

package
v0.8.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Mar 20, 2023 License: BSD-2-Clause Imports: 17 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	// Transport for different sip messages. GO uses lowercase, but for message parsing, we should
	// use this constants for setting message Transport
	TransportUDP = "UDP"
	TransportTCP = "TCP"
	TransportTLS = "TLS"
	TransportWS  = "WS"
)

Variables

View Source 
var (
	// UDPReadWorkers defines how many listeners will work
	// Best performance is achieved with low value, to remove high concurency
	UDPReadWorkers int = 1

	UDPbufferSize uint16 = 65535

	UDPMTUSize = 1500

	ErrUDPMTUCongestion = errors.New("size of packet larger than MTU")
)
View Source 
var (
	ErrNetworkExists = errors.New("network is already served")
)
View Source 
var (
	SIPDebug bool
)

Functions

func IsReliable 

func IsReliable(network string) bool

func IsStreamed 

func IsStreamed(network string) bool

func NetworkToLower 

func NetworkToLower(network string) string

NetworkToLower is faster function converting UDP, TCP to udp, tcp

Types

type Connection 

type Connection interface {
	// WriteMsg marshals message and sends to socket
	WriteMsg(msg sip.Message) error
	// Reference of connection can be increased/decreased to prevent closing to earlyss
	Ref(i int)
	// Close decreases reference and if ref = 0 closes connection. Returns last ref. If 0 then it is closed
	TryClose() (int, error)
}

type ConnectionPool 

type ConnectionPool struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

func NewConnectionPool 

func NewConnectionPool() ConnectionPool

func (*ConnectionPool) Add 

func (p *ConnectionPool) Add(a string, c Connection)

func (*ConnectionPool) Del 

func (p *ConnectionPool) Del(a string)

func (*ConnectionPool) Get 

func (p *ConnectionPool) Get(a string) (c Connection)

type Layer 

type Layer struct {

	// Parser used by transport layer. It can be overrided before setuping network transports
	Parser sip.Parser
	// ConnectionReuse will force connection reuse when passing request
	ConnectionReuse bool
	// contains filtered or unexported fields
}

Layer implementation.

func NewLayer 

func NewLayer(
	dnsResolver *net.Resolver,
) *Layer

NewLayer creates transport layer. hostAddr - address of host dns Resolver

func (*Layer) ClientRequestConnection 

func (l *Layer) ClientRequestConnection(req *sip.Request) (c Connection, err error)

ClientRequestConnection is based on https://www.rfc-editor.org/rfc/rfc3261#section-18.1.1 It is wrapper for getting and creating connection

func (*Layer) Close 

func (l *Layer) Close() error

func (*Layer) CreateConnection 

func (l *Layer) CreateConnection(network, addr string) (Connection, error)

func (*Layer) GetConnection 

func (l *Layer) GetConnection(network, addr string) (Connection, error)

GetConnection gets existing or creates new connection based on addr

func (*Layer) ListenAndServe added in v0.7.0 

func (l *Layer) ListenAndServe(ctx context.Context, network string, addr string) error

Serve on any network. This function will block Network supported: udp, tcp, ws

func (*Layer) ListenAndServeTLS added in v0.7.0 

func (l *Layer) ListenAndServeTLS(ctx context.Context, network string, addr string, conf *tls.Config) error

Serve on any tls network. This function will block Network supported: tcp

func (*Layer) OnMessage 

func (l *Layer) OnMessage(h sip.MessageHandler)

OnMessage is main function which will be called on any new message by transport layer

func (*Layer) ServeTCP 

func (l *Layer) ServeTCP(c net.Listener) error

ServeTCP will listen on tcp connection

func (*Layer) ServeTLS added in v0.7.0 

func (l *Layer) ServeTLS(c net.Listener, conf *tls.Config) error

ServeTLS will listen on tcp connection. rootPems can be nil if there is no need for client use

func (*Layer) ServeUDP 

func (l *Layer) ServeUDP(c net.PacketConn) error

ServeUDP will listen on udp connection

func (*Layer) ServeWS 

func (l *Layer) ServeWS(c net.Listener) error

ServeWS will listen on ws connection

func (*Layer) WriteMsg 

func (l *Layer) WriteMsg(msg sip.Message) error

func (*Layer) WriteMsgTo 

func (l *Layer) WriteMsgTo(msg sip.Message, addr string, network string) error

type TCPConnection 

type TCPConnection struct {
	net.Conn
	// contains filtered or unexported fields
}

func (*TCPConnection) Close 

func (c *TCPConnection) Close() error

func (*TCPConnection) Read 

func (c *TCPConnection) Read(b []byte) (n int, err error)

func (*TCPConnection) Ref 

func (c *TCPConnection) Ref(i int)

func (*TCPConnection) TryClose added in v0.7.0 

func (c *TCPConnection) TryClose() (int, error)

func (*TCPConnection) Write 

func (c *TCPConnection) Write(b []byte) (n int, err error)

func (*TCPConnection) WriteMsg 

func (c *TCPConnection) WriteMsg(msg sip.Message) error

type TCPPool 

type TCPPool struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

func NewTCPPool 

func NewTCPPool() TCPPool

func (*TCPPool) Add 

func (p *TCPPool) Add(a string, c *net.TCPConn)

func (*TCPPool) Del 

func (p *TCPPool) Del(a string)

func (*TCPPool) Get 

func (p *TCPPool) Get(a string) (c *net.TCPConn)

type TCPTransport 

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

TCP transport implementation

func NewTCPTransport 

func NewTCPTransport(addr string, par sip.Parser) *TCPTransport

func (*TCPTransport) Accept 

func (t *TCPTransport) Accept() error

func (*TCPTransport) Addr 

func (t *TCPTransport) Addr() string

func (*TCPTransport) Close 

func (t *TCPTransport) Close() error

func (*TCPTransport) CreateConnection 

func (t *TCPTransport) CreateConnection(addr string) (Connection, error)

func (*TCPTransport) GetConnection 

func (t *TCPTransport) GetConnection(addr string) (Connection, error)

func (*TCPTransport) ListenAndServe added in v0.7.0 

func (t *TCPTransport) ListenAndServe(handler sip.MessageHandler) error

TODO This is more generic way to provide listener and it is blocking

func (*TCPTransport) Network 

func (t *TCPTransport) Network() string

func (*TCPTransport) ResolveAddr 

func (t *TCPTransport) ResolveAddr(addr string) (net.Addr, error)

func (*TCPTransport) Serve 

func (t *TCPTransport) Serve(l net.Listener, handler sip.MessageHandler) error

Serve is direct way to provide conn on which this worker will listen

func (*TCPTransport) String 

func (t *TCPTransport) String() string

type TLSTransport added in v0.7.0 

type TLSTransport struct {
	*TCPTransport
	// contains filtered or unexported fields
}

TLS transport implementation

func NewTLSTransport added in v0.7.0 

func NewTLSTransport(addr string, par sip.Parser, tlsConf *tls.Config) *TLSTransport

func (*TLSTransport) CreateConnection added in v0.7.0 

func (t *TLSTransport) CreateConnection(addr string) (Connection, error)

CreateConnection creates TLS connection for TCP transport

func (*TLSTransport) ListenAndServe added in v0.7.0 

func (t *TLSTransport) ListenAndServe(handler sip.MessageHandler) error

This is more generic way to provide listener and it is blocking

func (*TLSTransport) String added in v0.7.0 

func (t *TLSTransport) String() string

type Transport 

type Transport interface {
	Addr() string
	Network() string
	ListenAndServe(handler sip.MessageHandler) error
	GetConnection(addr string) (Connection, error)
	CreateConnection(addr string) (Connection, error)
	String() string
	Close() error
}

Protocol implements network specific features.

type UDPConnection 

type UDPConnection struct {
	net.PacketConn
}

func (*UDPConnection) Close 

func (c *UDPConnection) Close() error

func (*UDPConnection) ReadFrom added in v0.7.0 

func (c *UDPConnection) ReadFrom(b []byte) (n int, addr net.Addr, err error)

func (*UDPConnection) Ref 

func (c *UDPConnection) Ref(i int)

func (*UDPConnection) TryClose added in v0.7.0 

func (c *UDPConnection) TryClose() (int, error)

func (*UDPConnection) WriteMsg 

func (c *UDPConnection) WriteMsg(msg sip.Message) error

func (*UDPConnection) WriteTo added in v0.7.0 

func (c *UDPConnection) WriteTo(b []byte, addr net.Addr) (n int, err error)

type UDPTransport 

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

UDP transport implementation

func NewUDPTransport 

func NewUDPTransport(addr string, par sip.Parser) *UDPTransport

func (*UDPTransport) Addr 

func (t *UDPTransport) Addr() string

func (*UDPTransport) Close 

func (t *UDPTransport) Close() error

func (*UDPTransport) CreateConnection 

func (t *UDPTransport) CreateConnection(addr string) (Connection, error)

CreateConnection will return same listener connection

func (*UDPTransport) GetConnection 

func (t *UDPTransport) GetConnection(addr string) (Connection, error)

GetConnection will return same listener connection

func (*UDPTransport) ListenAndServe added in v0.7.0 

func (t *UDPTransport) ListenAndServe(handler sip.MessageHandler) error

TODO This is more generic way to provide listener and it is blocking

func (*UDPTransport) Network 

func (t *UDPTransport) Network() string

func (*UDPTransport) ResolveAddr 

func (t *UDPTransport) ResolveAddr(addr string) (net.Addr, error)

func (*UDPTransport) Serve 

func (t *UDPTransport) Serve(conn net.PacketConn, handler sip.MessageHandler) error

ServeConn is direct way to provide conn on which this worker will listen UDPReadWorkers are used to create more workers

func (*UDPTransport) String 

func (t *UDPTransport) String() string

type WSConnection 

type WSConnection struct {
	net.Conn
	// contains filtered or unexported fields
}

func (*WSConnection) Close 

func (c *WSConnection) Close() error

func (*WSConnection) Read 

func (c *WSConnection) Read(b []byte) (n int, err error)

func (*WSConnection) Ref 

func (c *WSConnection) Ref(i int)

func (*WSConnection) TryClose added in v0.7.0 

func (c *WSConnection) TryClose() (int, error)

func (*WSConnection) Write 

func (c *WSConnection) Write(b []byte) (n int, err error)

func (*WSConnection) WriteMsg 

func (c *WSConnection) WriteMsg(msg sip.Message) error

type WSTransport 

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

WS transport implementation

func NewWSTransport 

func NewWSTransport(addr string, par sip.Parser) *WSTransport

func (*WSTransport) Accept 

func (t *WSTransport) Accept() error

func (*WSTransport) Addr 

func (t *WSTransport) Addr() string

func (*WSTransport) Close 

func (t *WSTransport) Close() error

func (*WSTransport) CreateConnection 

func (t *WSTransport) CreateConnection(addr string) (Connection, error)

func (*WSTransport) GetConnection 

func (t *WSTransport) GetConnection(addr string) (Connection, error)

func (*WSTransport) ListenAndServe added in v0.7.0 

func (t *WSTransport) ListenAndServe(handler sip.MessageHandler) error

This is more generic way to provide listener and it is blocking

func (*WSTransport) Network 

func (t *WSTransport) Network() string

func (*WSTransport) ResolveAddr 

func (t *WSTransport) ResolveAddr(addr string) (net.Addr, error)

func (*WSTransport) Serve 

func (t *WSTransport) Serve(l net.Listener, handler sip.MessageHandler) error

Serve is direct way to provide conn on which this worker will listen

func (*WSTransport) String 

func (t *WSTransport) String() string

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.