diago

package module

Go to main page

Versions in this module

v0

v0.13.0

Jan 20, 2025

Changes in this version

type DialogMedia

+ func (d *DialogMedia) Echo() error

+ func (d *DialogMedia) StartRTP(rw int8, dur time.Duration)

+ func (d *DialogMedia) StopRTP(rw int8, dur time.Duration)

type RegisterOptions

+ ProxyHost string

v0.12.0

Dec 26, 2024

v0.11.0

Dec 19, 2024

Changes in this version

type DialogServerSession

+ func (d *DialogServerSession) AnswerLate() error

+ func (d *DialogServerSession) ReadAck(req *sip.Request, tx sip.ServerTransaction) error

v0.10.0

Dec 11, 2024

Changes in this version

type AudioReaderOption

+ func WithAudioReaderRTPStats(hook media.OnRTPReadStats) AudioReaderOption

type AudioWriterOption

+ func WithAudioWriterRTPStats(hook media.OnRTPWriteStats) AudioWriterOption

v0.9.1

Dec 1, 2024

v0.9.0

Dec 1, 2024

Changes in this version

+ var ErrDigestAuthBadCreds = errors.New("bad credentials")

+ var ErrDigestAuthNoChallenge = errors.New("no challenge")

+ type DigestAuth struct

+ Expire time.Duration

+ Password string

+ Realm string

+ Username string

+ type DigestAuthServer struct

+ func NewDigestServer() *DigestAuthServer

+ func (s *DigestAuthServer) AuthorizeDialog(d *DialogServerSession, auth DigestAuth) error

+ func (s *DigestAuthServer) AuthorizeRequest(req *sip.Request, auth DigestAuth) (res *sip.Response, err error)

type InviteOptions

+ TransportID string

type Transport

+ ID string

v0.8.0

Nov 25, 2024

Changes in this version

type DTMFReader

+ func (d *DTMFReader) OnDTMF(onDTMF func(dtmf rune) error)

+ func (d *DTMFReader) Read(buf []byte) (n int, err error)

type DTMFWriter

+ func (w *DTMFWriter) AudioWriter() *media.RTPDtmfWriter

+ func (w *DTMFWriter) Write(buf []byte) (n int, err error)

type DiagoOption

+ func WithLogger(l zerolog.Logger) DiagoOption

type DialogMedia

+ func (d *DialogMedia) RTPSession() *media.RTPSession

type Transport

+ RewriteContact bool

v0.7.1

Nov 15, 2024

v0.7.0

Nov 14, 2024

Changes in this version

type Transport

+ MediaExternalIP net.IP

v0.6.0

Nov 3, 2024

Changes in this version

type Transport

+ ExternalMediaIP net.IP

v0.5.0

Oct 30, 2024

Changes in this version

type Diago

+ func (dg *Diago) HandleFunc(f ServeDialogFunc)

type InviteOptions

+ func (o *InviteOptions) SetAnonymousCaller()

+ func (o *InviteOptions) SetCaller(displayName string, callerID string)

v0.4.0

Oct 9, 2024

Changes in this version

+ type AnswerOptions struct

+ OnRTPSession func(rtpSess *media.RTPSession)

type DialogServerSession

+ func (d *DialogServerSession) AnswerOptions(opt AnswerOptions) error

type InviteOptions

+ OnRTPSession func(rtpSess *media.RTPSession)

v0.3.0

Oct 2, 2024

Changes in this version

+ func NewConnRecorder() *connRecorder

type Diago

+ func (dg *Diago) RegisterTransaction(ctx context.Context, recipient sip.Uri, opts RegisterOptions) (*RegisterTransaction, error)

type DiagoOption

+ func WithClient(client *sipgo.Client) DiagoOption

type DialogServerSession

+ func (d *DialogServerSession) Refer(ctx context.Context, referTo sip.Uri) error

type RegisterOptions

+ UserAgent string

+ UserAgentHostname string

v0.2.0

Sep 26, 2024

Changes in this version

+ var ErrRegisterFail = fmt.Errorf("register failed")

+ var ErrRegisterUnathorized = fmt.Errorf("register unathorized")

type Diago

+ func (dg *Diago) Register(ctx context.Context, recipient sip.Uri, opts RegisterOptions) error

+ type RegisterOptions struct

+ AllowHeaders []string

+ Expiry time.Duration

+ Password string

+ RetryInterval time.Duration

+ UnregisterAll bool

+ Username string

+ type RegisterResponseError struct

+ Msg string

+ RegisterReq *sip.Request

+ RegisterRes *sip.Response

+ func (e *RegisterResponseError) StatusCode() sip.StatusCode

+ func (e RegisterResponseError) Error() string

+ type RegisterTransaction struct

+ Origin *sip.Request

+ func NewRegisterTransaction(log zerolog.Logger, client *sipgo.Client, recipient sip.Uri, ...) *RegisterTransaction

+ func (p *RegisterTransaction) Register(ctx context.Context) error

+ func (t *RegisterTransaction) QualifyLoop(ctx context.Context) error

+ func (t *RegisterTransaction) Terminate() error

+ func (t *RegisterTransaction) Unregister(ctx context.Context) error

v0.1.1

Sep 11, 2024

Changes in this version

+ var HTTPDebug = os.Getenv("HTTP_DEBUG") == "true"

+ var PlaybackBufferSize = 320

+ func MatchDialog(req *sip.Request) (*DialogServerSession, *DialogClientSession, error)

+ type AudioPlayback struct

+ BitDepth int

+ NumChannels int

+ func NewAudioPlayback(writer io.Writer, codec media.Codec) AudioPlayback

+ func (p *AudioPlayback) Play(reader io.Reader, mimeType string) (int64, error)

+ func (p *AudioPlayback) PlayFile(filename string) (int64, error)

+ func (p *AudioPlayback) PlayURL(urlStr string) (int64, error)

+ type AudioPlaybackControl struct

+ func (p *AudioPlaybackControl) Mute(mute bool)

+ func (p *AudioPlaybackControl) Stop()

+ type AudioReaderOption func(d *DialogMedia) error

+ func WithAudioReaderMediaProps(p *MediaProps) AudioReaderOption

+ type AudioWriterOption func(d *DialogMedia) error

+ func WithAudioWriterMediaProps(p *MediaProps) AudioWriterOption

+ type Bridge struct

+ Originator DialogSession

+ func NewBridge() Bridge

+ func (b *Bridge) AddDialogSession(d DialogSession) error

+ func (b *Bridge) GetDialogs() []DialogSession

+ type Bridger interface

+ AddDialogSession func(d DialogSession) error

+ type DTMFReader struct

+ func (d *DTMFReader) AudioRead(buf []byte, onDTMF func(dtmf rune) error, dur time.Duration) (n int, err error)

+ func (d *DTMFReader) Listen(onDTMF func(dtmf rune) error, dur time.Duration) error

+ type DTMFWriter struct

+ func (w *DTMFWriter) WriteDTMF(dtmf rune) error

+ type Diago struct

+ func NewDiago(ua *sipgo.UserAgent, opts ...DiagoOption) *Diago

+ func (dg *Diago) Invite(ctx context.Context, recipient sip.Uri, opts InviteOptions) (d *DialogClientSession, err error)

+ func (dg *Diago) InviteBridge(ctx context.Context, recipient sip.Uri, bridge *Bridge, opts InviteOptions) (d *DialogClientSession, err error)

+ func (dg *Diago) Serve(ctx context.Context, f ServeDialogFunc) error

+ func (dg *Diago) ServeBackground(ctx context.Context, f ServeDialogFunc) error

+ type DiagoOption func(dg *Diago)

+ func WithAuth(auth sipgo.DigestAuth) DiagoOption

+ func WithClientOptions(opts ...sipgo.ClientOption) DiagoOption

+ func WithMediaConfig(conf MediaConfig) DiagoOption

+ func WithServer(srv *sipgo.Server) DiagoOption

+ func WithServerOptions(opts ...sipgo.ServerOption) DiagoOption

+ func WithTransport(t Transport) DiagoOption

+ type DialogCache interface

+ DialogDelete func(ctx context.Context, id string) error

+ DialogLoad func(ctx context.Context, id string) (T, error)

+ DialogRange func(ctx context.Context, f func(id string, d T) bool) error

+ DialogStore func(ctx context.Context, id string, v T) error

+ var DialogsClientCache DialogCache[*DialogClientSession] = &dialogCacheMap[*DialogClientSession]{ ... }

+ var DialogsServerCache DialogCache[*DialogServerSession] = &dialogCacheMap[*DialogServerSession]{ ... }

+ type DialogClientSession struct

+ func MatchDialogClient(req *sip.Request) (*DialogClientSession, error)

+ func (d *DialogClientSession) Close()

+ func (d *DialogClientSession) DialogSIP() *sipgo.Dialog

+ func (d *DialogClientSession) FromUser() string

+ func (d *DialogClientSession) Hangup(ctx context.Context) error

+ func (d *DialogClientSession) Id() string

+ func (d *DialogClientSession) ReInvite(ctx context.Context) error

+ func (d *DialogClientSession) RemoteContact() *sip.ContactHeader

+ func (d *DialogClientSession) ToUser() string

+ type DialogData struct

+ InviteRequest sip.Request

+ State sip.DialogState

+ type DialogMedia struct

+ RTPPacketReader *media.RTPPacketReader

+ RTPPacketWriter *media.RTPPacketWriter

+ func (d *DialogMedia) AudioReader(opts ...AudioReaderOption) (io.Reader, error)

+ func (d *DialogMedia) AudioWriter(opts ...AudioWriterOption) (io.Writer, error)

+ func (d *DialogMedia) Close()

+ func (d *DialogMedia) InitMediaSession(m *media.MediaSession, r *media.RTPPacketReader, w *media.RTPPacketWriter)

+ func (d *DialogMedia) Listen() error

+ func (d *DialogMedia) ListenContext(ctx context.Context) error

+ func (d *DialogMedia) ListenUntil(dur time.Duration) error

+ func (d *DialogMedia) Media() *DialogMedia

+ func (d *DialogMedia) OnClose(f func())

+ func (d *DialogMedia) PlaybackControlCreate() (AudioPlaybackControl, error)

+ func (d *DialogMedia) PlaybackCreate() (AudioPlayback, error)

+ func (d *DialogMedia) SetAudioReader(r io.Reader)

+ func (d *DialogMedia) SetAudioWriter(r io.Writer)

+ func (m *DialogMedia) AudioReaderDTMF() *DTMFReader

+ func (m *DialogMedia) AudioWriterDTMF() *DTMFWriter

+ type DialogServerSession struct

+ func MatchDialogServer(req *sip.Request) (*DialogServerSession, error)

+ func (d *DialogServerSession) Answer() error

+ func (d *DialogServerSession) AnswerSession(rtpSess *media.RTPSession) error

+ func (d *DialogServerSession) Close()

+ func (d *DialogServerSession) DialogSIP() *sipgo.Dialog

+ func (d *DialogServerSession) FromUser() string

+ func (d *DialogServerSession) Hangup(ctx context.Context) error

+ func (d *DialogServerSession) Id() string

+ func (d *DialogServerSession) Progress() error

+ func (d *DialogServerSession) ReInvite(ctx context.Context) error

+ func (d *DialogServerSession) RemoteContact() *sip.ContactHeader

+ func (d *DialogServerSession) Respond(statusCode sip.StatusCode, reason string, body []byte, headers ...sip.Header) error

+ func (d *DialogServerSession) RespondSDP(body []byte) error

+ func (d *DialogServerSession) Ringing() error

+ func (d *DialogServerSession) ToUser() string

+ func (d *DialogServerSession) Transport() string

+ type DialogSession interface

+ Context func() context.Context

+ DialogSIP func() *sipgo.Dialog

+ Hangup func(ctx context.Context) error

+ Id func() string

+ Media func() *DialogMedia

+ type InviteOptions struct

+ Headers []sip.Header

+ OnResponse func(res *sip.Response) error

+ Password string

+ Username string

+ type MediaConfig struct

+ Formats sdp.Formats

+ type MediaProps struct

+ Codec media.Codec

+ Laddr string

+ Raddr string

+ type ServeDialogFunc func(d *DialogServerSession)

+ type Transport struct

+ BindHost string

+ BindPort int

+ ExternalHost string

+ ExternalPort int

+ TLSConf *tls.Config

+ Transport string

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL