transport

Documentation

Index

• func NewConn(baseConn net.Conn, output chan base.SipMessage) *connection
• type Listener
• type Manager
  • func NewManager(transportType string) (m Manager, err error)
• type Tcp
  • func NewTcp(output chan base.SipMessage) (*Tcp, error)
  • func (t *Tcp) GetConn(addr string) *connection
  • func (t *Tcp) Init()
  • func (tcp *Tcp) IsStreamed() bool
  • func (tcp *Tcp) Listen(address string) error
  • func (tcp *Tcp) LocalAddress(addr string) (net.Addr, error)
  • func (t *Tcp) Notify(addr string, conn *connection)
  • func (tcp *Tcp) Send(addr string, msg base.SipMessage) error
  • func (tcp *Tcp) Stop()
• type Udp
  • func NewUdp(output chan base.SipMessage) (*Udp, error)
  • func (udp *Udp) IsStreamed() bool
  • func (udp *Udp) Listen(address string) error
  • func (udp *Udp) LocalAddress(addr string) (net.Addr, error)
  • func (udp *Udp) Send(addr string, msg base.SipMessage) error
  • func (udp *Udp) Stop()

Functions

func NewConn

func NewConn(baseConn net.Conn, output chan base.SipMessage) *connection

Types

type Listener

type Listener chan base.SipMessage

type Manager

type Manager interface {
	Listen(address string) error
	Send(addr string, message base.SipMessage) error
	Stop()
	GetChannel() Listener
	LocalAddress(addr string) (net.Addr, error)
}

func NewManager

func NewManager(transportType string) (m Manager, err error)

type Tcp

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

func NewTcp

func NewTcp(output chan base.SipMessage) (*Tcp, error)

func (*Tcp) GetConn

func (t *Tcp) GetConn(addr string) *connection

Return an existing open socket for the given address, or nil if no such socket exists.

func (*Tcp) Init

func (t *Tcp) Init()

Create a new connection table.

func (*Tcp) IsStreamed

func (tcp *Tcp) IsStreamed() bool

func (*Tcp) Listen

func (tcp *Tcp) Listen(address string) error

func (*Tcp) LocalAddress

func (tcp *Tcp) LocalAddress(addr string) (net.Addr, error)

func (*Tcp) Notify

func (t *Tcp) Notify(addr string, conn *connection)

Push a connection to the connection table, registered under a specific address. If it is a new connection, start the socket expiry timer. If it is a known connection, restart the timer.

func (*Tcp) Send

func (tcp *Tcp) Send(addr string, msg base.SipMessage) error

func (*Tcp) Stop

func (tcp *Tcp) Stop()

type Udp

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

func NewUdp

func NewUdp(output chan base.SipMessage) (*Udp, error)

func (*Udp) IsStreamed

func (udp *Udp) IsStreamed() bool

func (*Udp) Listen

func (udp *Udp) Listen(address string) error

func (*Udp) LocalAddress

func (udp *Udp) LocalAddress(addr string) (net.Addr, error)

TODO: fix later

func (*Udp) Send

func (udp *Udp) Send(addr string, msg base.SipMessage) error

func (*Udp) Stop

func (udp *Udp) Stop()