roq

Documentation

Index

• type Option
  • func EnableRoqLogs(filepath string) Option
• type QUICGoConnection
  • func NewQUICGoConnection(conn *quic.Conn) *QUICGoConnection
  • func (c *QUICGoConnection) AcceptUniStream(ctx context.Context) (roq.ReceiveStream, error)
  • func (c *QUICGoConnection) CloseWithError(code uint64, reason string) error
  • func (c *QUICGoConnection) OpenUniStreamSync(ctx context.Context) (roq.SendStream, error)
  • func (c *QUICGoConnection) ReceiveDatagram(ctx context.Context) ([]byte, error)
  • func (c *QUICGoConnection) SendDatagram(payload []byte) error
• type QuicGoReceiveStream
  • func NewQuicGoReceiveStream(stream *quic.ReceiveStream) *QuicGoReceiveStream
  • func (s *QuicGoReceiveStream) CancelRead(c uint64)
  • func (s *QuicGoReceiveStream) ID() int64
  • func (c *QuicGoReceiveStream) Read(p []byte) (n int, err error)
• type QuicGoSendStream
  • func NewQuicstream(stream *quic.SendStream) *QuicGoSendStream
  • func (s *QuicGoSendStream) CancelWrite(c uint64)
  • func (s *QuicGoSendStream) Close() error
  • func (s *QuicGoSendStream) ID() int64
  • func (s *QuicGoSendStream) SetIncremental(i bool)
  • func (s *QuicGoSendStream) SetPriority(p uint32)
  • func (s *QuicGoSendStream) Write(b []byte) (int, error)
• type Receiver
  • func (r *Receiver) Close() error
  • func (r *Receiver) ID() uint64
  • func (r *Receiver) Read(buf []byte) (int, error)
  • func (r *Receiver) SetReadDeadline(t time.Time) error
• type SendMode
• type Sender
  • func (s *Sender) Close() error
  • func (s *Sender) Write(data []byte) (int, error)
• type Transport
  • func New(ctx context.Context, quicConn *quic.Conn, opts ...Option) (*Transport, error)
  • func (t *Transport) Close() error
  • func (t *Transport) CloseLogFile() error
  • func (t *Transport) HandleDatagram(datagram []byte)
  • func (t *Transport) HandleUniStreamWithFlowID(flowID uint64, rs roq.ReceiveStream)
  • func (t *Transport) NewReceiveFlow(id uint64, logRTPpackets bool) (*Receiver, error)
  • func (t *Transport) NewSendFlow(id uint64, sendMode SendMode, logRTPpackets bool) (*Sender, error)

Types

type Option

type Option func(*Transport) error

func EnableRoqLogs

func EnableRoqLogs(filepath string) Option

type QUICGoConnection

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

func NewQUICGoConnection

func NewQUICGoConnection(conn *quic.Conn) *QUICGoConnection

func (*QUICGoConnection) AcceptUniStream

func (c *QUICGoConnection) AcceptUniStream(ctx context.Context) (roq.ReceiveStream, error)

func (*QUICGoConnection) CloseWithError

func (c *QUICGoConnection) CloseWithError(code uint64, reason string) error

func (*QUICGoConnection) OpenUniStreamSync

func (c *QUICGoConnection) OpenUniStreamSync(ctx context.Context) (roq.SendStream, error)

func (*QUICGoConnection) ReceiveDatagram

func (c *QUICGoConnection) ReceiveDatagram(ctx context.Context) ([]byte, error)

func (*QUICGoConnection) SendDatagram

func (c *QUICGoConnection) SendDatagram(payload []byte) error

type QuicGoReceiveStream

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

func NewQuicGoReceiveStream

func NewQuicGoReceiveStream(stream *quic.ReceiveStream) *QuicGoReceiveStream

func (*QuicGoReceiveStream) CancelRead

func (s *QuicGoReceiveStream) CancelRead(c uint64)

func (*QuicGoReceiveStream) ID

func (s *QuicGoReceiveStream) ID() int64

func (*QuicGoReceiveStream) Read

func (c *QuicGoReceiveStream) Read(p []byte) (n int, err error)

type QuicGoSendStream

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

func NewQuicstream

func NewQuicstream(stream *quic.SendStream) *QuicGoSendStream

func (*QuicGoSendStream) CancelWrite

func (s *QuicGoSendStream) CancelWrite(c uint64)

func (*QuicGoSendStream) Close

func (s *QuicGoSendStream) Close() error

func (*QuicGoSendStream) ID

func (s *QuicGoSendStream) ID() int64

func (*QuicGoSendStream) SetIncremental

func (s *QuicGoSendStream) SetIncremental(i bool)

func (*QuicGoSendStream) SetPriority

func (s *QuicGoSendStream) SetPriority(p uint32)

func (*QuicGoSendStream) Write

func (s *QuicGoSendStream) Write(b []byte) (int, error)

type Receiver

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

Receiver is a wrapper for roq.ReceiveFlow that supports logging RTP packets.

func (*Receiver) Close

func (r *Receiver) Close() error

func (*Receiver) ID

func (r *Receiver) ID() uint64

func (*Receiver) Read

func (r *Receiver) Read(buf []byte) (int, error)

func (*Receiver) SetReadDeadline

func (r *Receiver) SetReadDeadline(t time.Time) error

type SendMode

type SendMode int

const (
	SendModeDatagram SendMode = iota
	SendModeStreamPerPacket
	SendModeSingleStream
)

type Sender

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

func (*Sender) Close

func (s *Sender) Close() error

func (*Sender) Write

func (s *Sender) Write(data []byte) (int, error)

type Transport

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

func New

func New(ctx context.Context, quicConn *quic.Conn, opts ...Option) (*Transport, error)

func (*Transport) Close

func (t *Transport) Close() error

func (*Transport) CloseLogFile

func (t *Transport) CloseLogFile() error

func (*Transport) HandleDatagram

func (t *Transport) HandleDatagram(datagram []byte)

func (*Transport) HandleUniStreamWithFlowID

func (t *Transport) HandleUniStreamWithFlowID(flowID uint64, rs roq.ReceiveStream)

func (*Transport) NewReceiveFlow

func (t *Transport) NewReceiveFlow(id uint64, logRTPpackets bool) (*Receiver, error)

func (*Transport) NewSendFlow

func (t *Transport) NewSendFlow(id uint64, sendMode SendMode, logRTPpackets bool) (*Sender, error)