srt

Documentation

Index

• type ModSrtOption
• type Publisher
  • func NewPublisher(ctx context.Context, conn srt.Conn, streamName string, srv *SrtServer) *Publisher
  • func (p *Publisher) Run()
  • func (p *Publisher) SetSession(session logic.ICustomizePubSessionContext)
• type SrtOption
• type SrtServer
  • func NewSrtServer(addr string, lal logic.ILalServer, modOptions ...ModSrtOption) *SrtServer
  • func (s *SrtServer) Remove(host string, ss logic.ICustomizePubSessionContext)
  • func (s *SrtServer) Run(ctx context.Context)
• type StreamID
• type StreamInfo
• type Subscriber
  • func NewSubscriber(ctx context.Context, conn srt.Conn, streamName string, maxSendPacketSize int) *Subscriber
  • func (s *Subscriber) OnMsg(msg base.RtmpMsg)
  • func (s *Subscriber) OnStop()
  • func (s *Subscriber) Run()

Types

type ModSrtOption

type ModSrtOption func(option *SrtOption)

type Publisher

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

func NewPublisher

func NewPublisher(ctx context.Context, conn srt.Conn, streamName string, srv *SrtServer) *Publisher

func (*Publisher) Run

func (p *Publisher) Run()

func (*Publisher) SetSession

func (p *Publisher) SetSession(session logic.ICustomizePubSessionContext)

type SrtOption

type SrtOption struct {
	Latency           int
	RecvLatency       int
	PeerLatency       int
	TlpktDrop         bool
	TsbpdMode         bool
	RecvBuf           int
	SendBuf           int
	MaxSendPacketSize int
}

type SrtServer

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

func NewSrtServer

func NewSrtServer(addr string, lal logic.ILalServer, modOptions ...ModSrtOption) *SrtServer

func (*SrtServer) Remove

func (s *SrtServer) Remove(host string, ss logic.ICustomizePubSessionContext)

func (*SrtServer) Run

func (s *SrtServer) Run(ctx context.Context)

type StreamID

type StreamID struct {
	User      string
	Host      string
	Resource  string
	SessionID string
	Type      string
	Mode      string
}

type StreamInfo

type StreamInfo struct {
	StreamName string
	Mode       srt.ConnType
}

type Subscriber

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

func NewSubscriber

func NewSubscriber(ctx context.Context, conn srt.Conn, streamName string, maxSendPacketSize int) *Subscriber

func (*Subscriber) OnMsg

func (s *Subscriber) OnMsg(msg base.RtmpMsg)

func (*Subscriber) OnStop

func (s *Subscriber) OnStop()

func (*Subscriber) Run

func (s *Subscriber) Run()