transaction

Documentation

Index

• Constants
• type ClientTransaction
  • func (tx *ClientTransaction) Ack()
  • func (tx *ClientTransaction) Delete()
  • func (tx *ClientTransaction) Destination() string
  • func (tx *ClientTransaction) Errors() <-chan error
  • func (tx *ClientTransaction) MakeBye() (*base.Request, error)
  • func (tx *ClientTransaction) MakeNonInviteMessage(method base.Method) (*base.Request, error)
  • func (tx *ClientTransaction) Ok()
  • func (tx *ClientTransaction) Origin() *base.Request
  • func (tx *ClientTransaction) Receive(m base.SipMessage)
  • func (tx *ClientTransaction) Requests() <-chan *base.Request
  • func (tx *ClientTransaction) Responses() <-chan *base.Response
  • func (tx *ClientTransaction) Terminate()
  • func (tx *ClientTransaction) Transport() transport.Manager
• type Manager
  • func NewManager(t transport.Manager, addr string) (*Manager, error)
  • func (mng *Manager) LocalAddress(addr string) (net.Addr, error)
  • func (mng *Manager) Requests() <-chan *ServerTransaction
  • func (mng *Manager) Send(r *base.Request, dest string) *ClientTransaction
  • func (mng *Manager) Stop()
• type ServerTransaction
  • func (tx *ServerTransaction) Ack() <-chan *base.Request
  • func (tx *ServerTransaction) Delete()
  • func (tx *ServerTransaction) Destination() string
  • func (tx *ServerTransaction) Origin() *base.Request
  • func (tx *ServerTransaction) Receive(m base.SipMessage)
  • func (tx *ServerTransaction) Respond(r *base.Response)
  • func (tx *ServerTransaction) Transport() transport.Manager
• type Transaction

Constants

const (
	T1 = 500 * time.Millisecond
	T2 = 4 * time.Second
)

Types

type ClientTransaction

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

func (*ClientTransaction) Ack

func (tx *ClientTransaction) Ack()

Send an automatic ACK.

func (*ClientTransaction) Delete

func (tx *ClientTransaction) Delete()

func (*ClientTransaction) Destination

func (tx *ClientTransaction) Destination() string

func (*ClientTransaction) Errors

func (tx *ClientTransaction) Errors() <-chan error

Return the channel we send errors on.

func (*ClientTransaction) MakeBye

func (tx *ClientTransaction) MakeBye() (*base.Request, error)

func (*ClientTransaction) MakeNonInviteMessage

func (tx *ClientTransaction) MakeNonInviteMessage(method base.Method) (*base.Request, error)

func (*ClientTransaction) Ok

func (tx *ClientTransaction) Ok()

Send an automatic Ok.

func (*ClientTransaction) Origin

func (tx *ClientTransaction) Origin() *base.Request

func (*ClientTransaction) Receive

func (tx *ClientTransaction) Receive(m base.SipMessage)

func (*ClientTransaction) Requests

func (tx *ClientTransaction) Requests() <-chan *base.Request

Return the channel we send requests on.

func (*ClientTransaction) Responses

func (tx *ClientTransaction) Responses() <-chan *base.Response

Return the channel we send responses on.

func (*ClientTransaction) Terminate

func (tx *ClientTransaction) Terminate()

Terminate this transaction

func (*ClientTransaction) Transport

func (tx *ClientTransaction) Transport() transport.Manager

type Manager

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

func NewManager

func NewManager(t transport.Manager, addr string) (*Manager, error)

func (*Manager) LocalAddress

func (mng *Manager) LocalAddress(addr string) (net.Addr, error)

func (*Manager) Requests

func (mng *Manager) Requests() <-chan *ServerTransaction

func (*Manager) Send

func (mng *Manager) Send(r *base.Request, dest string) *ClientTransaction

Create Client transaction.

func (*Manager) Stop

func (mng *Manager) Stop()

Stop the manager and close down all processing on it, losing all transactions in progress.

type ServerTransaction

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

func (*ServerTransaction) Ack

func (tx *ServerTransaction) Ack() <-chan *base.Request

func (*ServerTransaction) Delete

func (tx *ServerTransaction) Delete()

func (*ServerTransaction) Destination

func (tx *ServerTransaction) Destination() string

func (*ServerTransaction) Origin

func (tx *ServerTransaction) Origin() *base.Request

func (*ServerTransaction) Receive

func (tx *ServerTransaction) Receive(m base.SipMessage)

func (*ServerTransaction) Respond

func (tx *ServerTransaction) Respond(r *base.Response)

func (*ServerTransaction) Transport

func (tx *ServerTransaction) Transport() transport.Manager

type Transaction

type Transaction interface {
	Receive(m base.SipMessage)
	Origin() *base.Request
	Destination() string
	Transport() transport.Manager
	Delete()
}