sip

Documentation

Index

• type Gb28181Serve
• type Transport
• type UacMsg
  • func NewUacMsg(uacConn net.Addr, msg *sip.Msg) *UacMsg
• type UacRequest
  • func (this *UacRequest) ToUacMsg() (*UacMsg, error)
• type Uas
  • func NewUas(sysConf *config.Bootstrap) *Uas
  • func (this *Uas) Catalog(uacMsg *UacMsg, catalog *message.Query) error
  • func (this *Uas) CatalogReceive(uacMsg *UacMsg) error
  • func (this *Uas) GenSSRC(isRTP int) string
  • func (this *Uas) Keepalive(uacMsg *UacMsg) error
  • func (this *Uas) Play(uacAddr net.Addr, req *message.PlayReq) (streamId string, err error)
  • func (this *Uas) PlayRespone(uacMsg *UacMsg) (err error)
  • func (this *Uas) Register(uacMsg *UacMsg) error
  • func (this *Uas) Run()
• type UdpTransport
  • func NewUdpTransport(port uint16, uacMsgQueue chan *UacMsg) *UdpTransport
  • func (this *UdpTransport) Write(uacMsg *UacMsg) error

Types

type Gb28181Serve

type Gb28181Serve interface {
	Catalog(uacMsg *UacMsg, catalog *message.Query) error
	Play(uacAddr net.Addr, req *message.PlayReq) (streamId string, err error)
	PlayRespone(uacMsg *UacMsg) (err error)
}

type Transport

type Transport interface {
	Write(uacMsg *UacMsg) error
}

type UacMsg

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

User Agent Client SIP信令消息

func NewUacMsg

func NewUacMsg(uacConn net.Addr, msg *sip.Msg) *UacMsg

type UacRequest

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

User Agent Client 请求报文

func (*UacRequest) ToUacMsg

func (this *UacRequest) ToUacMsg() (*UacMsg, error)

type Uas

type Uas struct {
	*service.Service
	Transport Transport
	// contains filtered or unexported fields
}

func NewUas

func NewUas(sysConf *config.Bootstrap) *Uas

func (*Uas) Catalog

func (this *Uas) Catalog(uacMsg *UacMsg, catalog *message.Query) error

向UAC发送catalog

func (*Uas) CatalogReceive

func (this *Uas) CatalogReceive(uacMsg *UacMsg) error

func (*Uas) GenSSRC

func (this *Uas) GenSSRC(isRTP int) string

isRTP 0=实时流，1=历史流

func (*Uas) Keepalive

func (this *Uas) Keepalive(uacMsg *UacMsg) error

func (*Uas) Play

func (this *Uas) Play(uacAddr net.Addr, req *message.PlayReq) (streamId string, err error)

func (*Uas) PlayRespone

func (this *Uas) PlayRespone(uacMsg *UacMsg) (err error)

func (*Uas) Register

func (this *Uas) Register(uacMsg *UacMsg) error

func (*Uas) Run

func (this *Uas) Run()

type UdpTransport

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

func NewUdpTransport

func NewUdpTransport(port uint16, uacMsgQueue chan *UacMsg) *UdpTransport

func (*UdpTransport) Write

func (this *UdpTransport) Write(uacMsg *UacMsg) error