lsquic

Documentation

Index

• func NewQuicApi() adapter.QuicAPI
• func NewQuicBiStream(lsStream *C.lsquic_stream_t, streamCtx *C.lsquic_stream_ctx_t) adapter.QuicBiStream
• func NewQuicConn(lsConn *C.lsquic_conn_t) adapter.QuicConn
• func NewQuicServer(uri, keyfile, certfile string, api adapter.QuicAPI) (adapter.QuicServer, error)
• func NewStreamReader(stream *C.lsquic_stream_t) io.Reader
• type QuicApi
  • func (l *QuicApi) OnCanceledConn(conn adapter.QuicConn)
  • func (l *QuicApi) OnNewBiStream(conn adapter.QuicConn, stream adapter.QuicBiStream)
  • func (l *QuicApi) OnNewConnection(conn adapter.QuicConn)
  • func (l *QuicApi) OnNewUniStream(conn adapter.QuicConn, id adapter.StreamId)
  • func (l *QuicApi) OnReadBiStream(conn adapter.QuicConn, stream adapter.QuicBiStream, reader io.Reader)
  • func (l *QuicApi) OnReadUniStream(conn adapter.QuicConn, id adapter.StreamId, reader io.Reader)
• type QuicBiStream
  • func (l *QuicBiStream) Close(reason adapter.ApplicationError)
  • func (l *QuicBiStream) CloseRead(reason adapter.ApplicationError)
  • func (l *QuicBiStream) CloseWrite(reason adapter.ApplicationError)
  • func (l *QuicBiStream) ID() adapter.StreamId
  • func (l *QuicBiStream) Write(p []byte) (n int, err error)
  • func (l *QuicBiStream) WriteFin()
• type QuicConn
  • func (l *QuicConn) Close(reason adapter.ApplicationError)
  • func (l *QuicConn) CreateUniStream(streamType adapter.StreamType) (adapter.QuicUniStream, error)
  • func (qc *QuicConn) LocalAddress() string
  • func (qc *QuicConn) RemoteAddress() string
  • func (l *QuicConn) String() string
• type QuicServer
  • func (l *QuicServer) Listen() error
• type StreamReader
  • func (s *StreamReader) Read(p []byte) (n int, err error)

Functions

func NewQuicApi

func NewQuicApi() adapter.QuicAPI

func NewQuicBiStream

func NewQuicBiStream(lsStream *C.lsquic_stream_t, streamCtx *C.lsquic_stream_ctx_t) adapter.QuicBiStream

func NewQuicConn

func NewQuicConn(lsConn *C.lsquic_conn_t) adapter.QuicConn

func NewQuicServer

func NewQuicServer(uri, keyfile, certfile string, api adapter.QuicAPI) (adapter.QuicServer, error)

func NewStreamReader

func NewStreamReader(stream *C.lsquic_stream_t) io.Reader

Types

type QuicApi

type QuicApi struct {
}

func (*QuicApi) OnCanceledConn

func (l *QuicApi) OnCanceledConn(conn adapter.QuicConn)

func (*QuicApi) OnNewBiStream

func (l *QuicApi) OnNewBiStream(conn adapter.QuicConn, stream adapter.QuicBiStream)

func (*QuicApi) OnNewConnection

func (l *QuicApi) OnNewConnection(conn adapter.QuicConn)

func (*QuicApi) OnNewUniStream

func (l *QuicApi) OnNewUniStream(conn adapter.QuicConn, id adapter.StreamId)

func (*QuicApi) OnReadBiStream

func (l *QuicApi) OnReadBiStream(conn adapter.QuicConn, stream adapter.QuicBiStream, reader io.Reader)

func (*QuicApi) OnReadUniStream

func (l *QuicApi) OnReadUniStream(conn adapter.QuicConn, id adapter.StreamId, reader io.Reader)

type QuicBiStream

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

func (*QuicBiStream) Close

func (l *QuicBiStream) Close(reason adapter.ApplicationError)

func (*QuicBiStream) CloseRead

func (l *QuicBiStream) CloseRead(reason adapter.ApplicationError)

func (*QuicBiStream) CloseWrite

func (l *QuicBiStream) CloseWrite(reason adapter.ApplicationError)

func (*QuicBiStream) ID

func (l *QuicBiStream) ID() adapter.StreamId

func (*QuicBiStream) Write

func (l *QuicBiStream) Write(p []byte) (n int, err error)

func (*QuicBiStream) WriteFin

func (l *QuicBiStream) WriteFin()

type QuicConn

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

func (*QuicConn) Close

func (l *QuicConn) Close(reason adapter.ApplicationError)

func (*QuicConn) CreateUniStream

func (l *QuicConn) CreateUniStream(streamType adapter.StreamType) (adapter.QuicUniStream, error)

func (*QuicConn) LocalAddress

func (qc *QuicConn) LocalAddress() string

func (*QuicConn) RemoteAddress

func (qc *QuicConn) RemoteAddress() string

func (*QuicConn) String

func (l *QuicConn) String() string

type QuicServer

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

func (*QuicServer) Listen

func (l *QuicServer) Listen() error

type StreamReader

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

func (*StreamReader) Read

func (s *StreamReader) Read(p []byte) (n int, err error)