fwd

Documentation

Index

• type ClientDataTime
• type Forwarder
  • func NewForwarder() *Forwarder
  • func (f *Forwarder) Close()
  • func (f *Forwarder) CloseClient(pcID string) bool
  • func (f *Forwarder) GetClient(pcID string) *FwdClient
  • func (f *Forwarder) GetLastTimeReceive() map[string]int64
  • func (f *Forwarder) GetLastTimeReceiveBy(trackID string) int64
  • func (f *Forwarder) Push(trackID string, data []byte) error
  • func (f *Forwarder) Register(pcID string, trackID string) (<-chan *message.Message, error)
  • func (f *Forwarder) UnRegister(pcID string, trackID string) bool
• type FwdClient
  • func NewFwdClient(pcID string) *FwdClient
  • func (c *FwdClient) Close()
  • func (c *FwdClient) GetSub(trackID string) context.CancelFunc
  • func (c *FwdClient) SetMsg(trackID string, chann <-chan *message.Message)
  • func (c *FwdClient) SetSub(trackID string, cancel context.CancelFunc)
  • func (c *FwdClient) UnRegister(trackID string)
• type FwdLog
  • func NewFwdLog() *FwdLog
  • func (l *FwdLog) Debug(msg string, fields watermill.LogFields)
  • func (l *FwdLog) Error(msg string, err error, fields watermill.LogFields)
  • func (l *FwdLog) Info(msg string, fields watermill.LogFields)
  • func (l *FwdLog) Trace(msg string, fields watermill.LogFields)
  • func (l *FwdLog) With(fields watermill.LogFields) watermill.LoggerAdapter
• type Wrapper

Types

type ClientDataTime

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

ClientDataTime linter

type Forwarder

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

Forwarder linter

func NewForwarder

func NewForwarder() *Forwarder

NewForwarder linter

func (*Forwarder) Close

func (f *Forwarder) Close()

func (*Forwarder) CloseClient

func (f *Forwarder) CloseClient(pcID string) bool

func (*Forwarder) GetClient

func (f *Forwarder) GetClient(pcID string) *FwdClient

func (*Forwarder) GetLastTimeReceive

func (f *Forwarder) GetLastTimeReceive() map[string]int64

GetLastTimeReceive linter

func (*Forwarder) GetLastTimeReceiveBy

func (f *Forwarder) GetLastTimeReceiveBy(trackID string) int64

GetLastTimeReceiveBy linter

func (*Forwarder) Push

func (f *Forwarder) Push(trackID string, data []byte) error

Push pushing data to fwd

func (*Forwarder) Register

func (f *Forwarder) Register(pcID string, trackID string) (<-chan *message.Message, error)

Register register to fwd

func (*Forwarder) UnRegister

func (f *Forwarder) UnRegister(pcID string, trackID string) bool

UnRegister linter

type FwdClient

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

FwdClient linter

func NewFwdClient

func NewFwdClient(pcID string) *FwdClient

func (*FwdClient) Close

func (c *FwdClient) Close()

func (*FwdClient) GetSub

func (c *FwdClient) GetSub(trackID string) context.CancelFunc

func (*FwdClient) SetMsg

func (c *FwdClient) SetMsg(trackID string, chann <-chan *message.Message)

func (*FwdClient) SetSub

func (c *FwdClient) SetSub(trackID string, cancel context.CancelFunc)

func (*FwdClient) UnRegister

func (c *FwdClient) UnRegister(trackID string)

type FwdLog

type FwdLog struct {
}

func NewFwdLog

func NewFwdLog() *FwdLog

func (*FwdLog) Debug

func (l *FwdLog) Debug(msg string, fields watermill.LogFields)

func (*FwdLog) Error

func (l *FwdLog) Error(msg string, err error, fields watermill.LogFields)

func (*FwdLog) Info

func (l *FwdLog) Info(msg string, fields watermill.LogFields)

func (*FwdLog) Trace

func (l *FwdLog) Trace(msg string, fields watermill.LogFields)

func (*FwdLog) With

func (l *FwdLog) With(fields watermill.LogFields) watermill.LoggerAdapter

type Wrapper

type Wrapper struct {
	Duration time.Duration
	Pkg      *rtp.Packet // save rtp packet
	Data     []byte      `json:"rtp"`  // packet to write
	Type     *string     `json:"type"` // type off wrapper data - ok - ping - pong
}

Wrapper linter