Versions in this module Expand all Collapse all v0 v0.0.3 Jun 16, 2022 v0.0.2 Jun 16, 2022 Changes in this version + type ClientDataTime struct + type Forwarder struct + 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 struct + 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 struct + 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 struct + Data []byte + Duration time.Duration + Pkg *rtp.Packet + Type *string
Go to main page