datachannels

Documentation

Index

• type Option
• type QUICGoConnection
  • func NewQUICGoConnection(conn *quic.Conn) *QUICGoConnection
  • func (c *QUICGoConnection) AcceptUniStream(ctx context.Context) (quicdc.ReceiveStream, error)
  • func (c *QUICGoConnection) CloseWithError(code uint64, reason string) error
  • func (c *QUICGoConnection) OpenUniStream() (quicdc.SendStream, error)
  • func (c *QUICGoConnection) OpenUniStreamSync(ctx context.Context) (quicdc.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) Read(buf []byte) (int, error)
• type Sender
  • func (s *Sender) Close() error
  • func (s *Sender) Write(data []byte) (int, error)
• type Transport
  • func New(conn *quic.Conn, opts ...Option) (*Transport, error)
  • func (t *Transport) AddDataChannelReceiver(channelID uint64) (*Receiver, error)
  • func (t *Transport) NewDataChannelSender(channelID uint64, priority uint64, ordered bool) (*Sender, error)
  • func (t *Transport) ReadStream(ctx context.Context, stream quicdc.ReceiveStream, channelID uint64) error

Types

type Option

type Option func(*Transport) error

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) (quicdc.ReceiveStream, error)

func (*QUICGoConnection) CloseWithError

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

func (*QUICGoConnection) OpenUniStream

func (c *QUICGoConnection) OpenUniStream() (quicdc.SendStream, error)

func (*QUICGoConnection) OpenUniStreamSync

func (c *QUICGoConnection) OpenUniStreamSync(ctx context.Context) (quicdc.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
}

func (*Receiver) Close

func (r *Receiver) Close() error

func (*Receiver) Read

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

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(conn *quic.Conn, opts ...Option) (*Transport, error)

func (*Transport) AddDataChannelReceiver

func (t *Transport) AddDataChannelReceiver(channelID uint64) (*Receiver, error)

func (*Transport) NewDataChannelSender

func (t *Transport) NewDataChannelSender(channelID uint64, priority uint64, ordered bool) (*Sender, error)

func (*Transport) ReadStream

func (t *Transport) ReadStream(ctx context.Context, stream quicdc.ReceiveStream, channelID uint64) error

ReadStream registers a QUIC stream to the quicdc session