Versions in this module Expand all Collapse all v0 v0.0.1 Jan 3, 2024 Changes in this version + type EarlyConnectionAcceptStreamCall struct + func (c *EarlyConnectionAcceptStreamCall) Do(f func(context.Context) (quic.Stream, error)) *EarlyConnectionAcceptStreamCall + func (c *EarlyConnectionAcceptStreamCall) DoAndReturn(f func(context.Context) (quic.Stream, error)) *EarlyConnectionAcceptStreamCall + func (c *EarlyConnectionAcceptStreamCall) Return(arg0 quic.Stream, arg1 error) *EarlyConnectionAcceptStreamCall + type EarlyConnectionAcceptUniStreamCall struct + func (c *EarlyConnectionAcceptUniStreamCall) Do(f func(context.Context) (quic.ReceiveStream, error)) *EarlyConnectionAcceptUniStreamCall + func (c *EarlyConnectionAcceptUniStreamCall) DoAndReturn(f func(context.Context) (quic.ReceiveStream, error)) *EarlyConnectionAcceptUniStreamCall + func (c *EarlyConnectionAcceptUniStreamCall) Return(arg0 quic.ReceiveStream, arg1 error) *EarlyConnectionAcceptUniStreamCall + type EarlyConnectionCloseWithErrorCall struct + func (c *EarlyConnectionCloseWithErrorCall) Do(f func(qerr.ApplicationErrorCode, string) error) *EarlyConnectionCloseWithErrorCall + func (c *EarlyConnectionCloseWithErrorCall) DoAndReturn(f func(qerr.ApplicationErrorCode, string) error) *EarlyConnectionCloseWithErrorCall + func (c *EarlyConnectionCloseWithErrorCall) Return(arg0 error) *EarlyConnectionCloseWithErrorCall + type EarlyConnectionConnectionStateCall struct + func (c *EarlyConnectionConnectionStateCall) Do(f func() quic.ConnectionState) *EarlyConnectionConnectionStateCall + func (c *EarlyConnectionConnectionStateCall) DoAndReturn(f func() quic.ConnectionState) *EarlyConnectionConnectionStateCall + func (c *EarlyConnectionConnectionStateCall) Return(arg0 quic.ConnectionState) *EarlyConnectionConnectionStateCall + type EarlyConnectionContextCall struct + func (c *EarlyConnectionContextCall) Do(f func() context.Context) *EarlyConnectionContextCall + func (c *EarlyConnectionContextCall) DoAndReturn(f func() context.Context) *EarlyConnectionContextCall + func (c *EarlyConnectionContextCall) Return(arg0 context.Context) *EarlyConnectionContextCall + type EarlyConnectionHandshakeCompleteCall struct + func (c *EarlyConnectionHandshakeCompleteCall) Do(f func() <-chan struct{}) *EarlyConnectionHandshakeCompleteCall + func (c *EarlyConnectionHandshakeCompleteCall) DoAndReturn(f func() <-chan struct{}) *EarlyConnectionHandshakeCompleteCall + func (c *EarlyConnectionHandshakeCompleteCall) Return(arg0 <-chan struct{}) *EarlyConnectionHandshakeCompleteCall + type EarlyConnectionLocalAddrCall struct + func (c *EarlyConnectionLocalAddrCall) Do(f func() net.Addr) *EarlyConnectionLocalAddrCall + func (c *EarlyConnectionLocalAddrCall) DoAndReturn(f func() net.Addr) *EarlyConnectionLocalAddrCall + func (c *EarlyConnectionLocalAddrCall) Return(arg0 net.Addr) *EarlyConnectionLocalAddrCall + type EarlyConnectionNextConnectionCall struct + func (c *EarlyConnectionNextConnectionCall) Do(f func() quic.Connection) *EarlyConnectionNextConnectionCall + func (c *EarlyConnectionNextConnectionCall) DoAndReturn(f func() quic.Connection) *EarlyConnectionNextConnectionCall + func (c *EarlyConnectionNextConnectionCall) Return(arg0 quic.Connection) *EarlyConnectionNextConnectionCall + type EarlyConnectionOpenStreamCall struct + func (c *EarlyConnectionOpenStreamCall) Do(f func() (quic.Stream, error)) *EarlyConnectionOpenStreamCall + func (c *EarlyConnectionOpenStreamCall) DoAndReturn(f func() (quic.Stream, error)) *EarlyConnectionOpenStreamCall + func (c *EarlyConnectionOpenStreamCall) Return(arg0 quic.Stream, arg1 error) *EarlyConnectionOpenStreamCall + type EarlyConnectionOpenStreamSyncCall struct + func (c *EarlyConnectionOpenStreamSyncCall) Do(f func(context.Context) (quic.Stream, error)) *EarlyConnectionOpenStreamSyncCall + func (c *EarlyConnectionOpenStreamSyncCall) DoAndReturn(f func(context.Context) (quic.Stream, error)) *EarlyConnectionOpenStreamSyncCall + func (c *EarlyConnectionOpenStreamSyncCall) Return(arg0 quic.Stream, arg1 error) *EarlyConnectionOpenStreamSyncCall + type EarlyConnectionOpenUniStreamCall struct + func (c *EarlyConnectionOpenUniStreamCall) Do(f func() (quic.SendStream, error)) *EarlyConnectionOpenUniStreamCall + func (c *EarlyConnectionOpenUniStreamCall) DoAndReturn(f func() (quic.SendStream, error)) *EarlyConnectionOpenUniStreamCall + func (c *EarlyConnectionOpenUniStreamCall) Return(arg0 quic.SendStream, arg1 error) *EarlyConnectionOpenUniStreamCall + type EarlyConnectionOpenUniStreamSyncCall struct + func (c *EarlyConnectionOpenUniStreamSyncCall) Do(f func(context.Context) (quic.SendStream, error)) *EarlyConnectionOpenUniStreamSyncCall + func (c *EarlyConnectionOpenUniStreamSyncCall) DoAndReturn(f func(context.Context) (quic.SendStream, error)) *EarlyConnectionOpenUniStreamSyncCall + func (c *EarlyConnectionOpenUniStreamSyncCall) Return(arg0 quic.SendStream, arg1 error) *EarlyConnectionOpenUniStreamSyncCall + type EarlyConnectionReceiveDatagramCall struct + func (c *EarlyConnectionReceiveDatagramCall) Do(f func(context.Context) ([]byte, error)) *EarlyConnectionReceiveDatagramCall + func (c *EarlyConnectionReceiveDatagramCall) DoAndReturn(f func(context.Context) ([]byte, error)) *EarlyConnectionReceiveDatagramCall + func (c *EarlyConnectionReceiveDatagramCall) Return(arg0 []byte, arg1 error) *EarlyConnectionReceiveDatagramCall + type EarlyConnectionRemoteAddrCall struct + func (c *EarlyConnectionRemoteAddrCall) Do(f func() net.Addr) *EarlyConnectionRemoteAddrCall + func (c *EarlyConnectionRemoteAddrCall) DoAndReturn(f func() net.Addr) *EarlyConnectionRemoteAddrCall + func (c *EarlyConnectionRemoteAddrCall) Return(arg0 net.Addr) *EarlyConnectionRemoteAddrCall + type EarlyConnectionSendDatagramCall struct + func (c *EarlyConnectionSendDatagramCall) Do(f func([]byte) error) *EarlyConnectionSendDatagramCall + func (c *EarlyConnectionSendDatagramCall) DoAndReturn(f func([]byte) error) *EarlyConnectionSendDatagramCall + func (c *EarlyConnectionSendDatagramCall) Return(arg0 error) *EarlyConnectionSendDatagramCall + type MockEarlyConnection struct + func NewMockEarlyConnection(ctrl *gomock.Controller) *MockEarlyConnection + func (m *MockEarlyConnection) AcceptStream(arg0 context.Context) (quic.Stream, error) + func (m *MockEarlyConnection) AcceptUniStream(arg0 context.Context) (quic.ReceiveStream, error) + func (m *MockEarlyConnection) CloseWithError(arg0 qerr.ApplicationErrorCode, arg1 string) error + func (m *MockEarlyConnection) ConnectionState() quic.ConnectionState + func (m *MockEarlyConnection) Context() context.Context + func (m *MockEarlyConnection) EXPECT() *MockEarlyConnectionMockRecorder + func (m *MockEarlyConnection) HandshakeComplete() <-chan struct{} + func (m *MockEarlyConnection) LocalAddr() net.Addr + func (m *MockEarlyConnection) NextConnection() quic.Connection + func (m *MockEarlyConnection) OpenStream() (quic.Stream, error) + func (m *MockEarlyConnection) OpenStreamSync(arg0 context.Context) (quic.Stream, error) + func (m *MockEarlyConnection) OpenUniStream() (quic.SendStream, error) + func (m *MockEarlyConnection) OpenUniStreamSync(arg0 context.Context) (quic.SendStream, error) + func (m *MockEarlyConnection) ReceiveDatagram(arg0 context.Context) ([]byte, error) + func (m *MockEarlyConnection) RemoteAddr() net.Addr + func (m *MockEarlyConnection) SendDatagram(arg0 []byte) error + type MockEarlyConnectionMockRecorder struct + func (mr *MockEarlyConnectionMockRecorder) AcceptStream(arg0 any) *EarlyConnectionAcceptStreamCall + func (mr *MockEarlyConnectionMockRecorder) AcceptUniStream(arg0 any) *EarlyConnectionAcceptUniStreamCall + func (mr *MockEarlyConnectionMockRecorder) CloseWithError(arg0, arg1 any) *EarlyConnectionCloseWithErrorCall + func (mr *MockEarlyConnectionMockRecorder) ConnectionState() *EarlyConnectionConnectionStateCall + func (mr *MockEarlyConnectionMockRecorder) Context() *EarlyConnectionContextCall + func (mr *MockEarlyConnectionMockRecorder) HandshakeComplete() *EarlyConnectionHandshakeCompleteCall + func (mr *MockEarlyConnectionMockRecorder) LocalAddr() *EarlyConnectionLocalAddrCall + func (mr *MockEarlyConnectionMockRecorder) NextConnection() *EarlyConnectionNextConnectionCall + func (mr *MockEarlyConnectionMockRecorder) OpenStream() *EarlyConnectionOpenStreamCall + func (mr *MockEarlyConnectionMockRecorder) OpenStreamSync(arg0 any) *EarlyConnectionOpenStreamSyncCall + func (mr *MockEarlyConnectionMockRecorder) OpenUniStream() *EarlyConnectionOpenUniStreamCall + func (mr *MockEarlyConnectionMockRecorder) OpenUniStreamSync(arg0 any) *EarlyConnectionOpenUniStreamSyncCall + func (mr *MockEarlyConnectionMockRecorder) ReceiveDatagram(arg0 any) *EarlyConnectionReceiveDatagramCall + func (mr *MockEarlyConnectionMockRecorder) RemoteAddr() *EarlyConnectionRemoteAddrCall + func (mr *MockEarlyConnectionMockRecorder) SendDatagram(arg0 any) *EarlyConnectionSendDatagramCall + type MockStream struct + func NewMockStream(ctrl *gomock.Controller) *MockStream + func (m *MockStream) CancelRead(arg0 qerr.StreamErrorCode) + func (m *MockStream) CancelWrite(arg0 qerr.StreamErrorCode) + func (m *MockStream) Close() error + func (m *MockStream) Context() context.Context + func (m *MockStream) EXPECT() *MockStreamMockRecorder + func (m *MockStream) Read(arg0 []byte) (int, error) + func (m *MockStream) SetDeadline(arg0 time.Time) error + func (m *MockStream) SetReadDeadline(arg0 time.Time) error + func (m *MockStream) SetWriteDeadline(arg0 time.Time) error + func (m *MockStream) StreamID() protocol.StreamID + func (m *MockStream) Write(arg0 []byte) (int, error) + type MockStreamMockRecorder struct + func (mr *MockStreamMockRecorder) CancelRead(arg0 any) *StreamCancelReadCall + func (mr *MockStreamMockRecorder) CancelWrite(arg0 any) *StreamCancelWriteCall + func (mr *MockStreamMockRecorder) Close() *StreamCloseCall + func (mr *MockStreamMockRecorder) Context() *StreamContextCall + func (mr *MockStreamMockRecorder) Read(arg0 any) *StreamReadCall + func (mr *MockStreamMockRecorder) SetDeadline(arg0 any) *StreamSetDeadlineCall + func (mr *MockStreamMockRecorder) SetReadDeadline(arg0 any) *StreamSetReadDeadlineCall + func (mr *MockStreamMockRecorder) SetWriteDeadline(arg0 any) *StreamSetWriteDeadlineCall + func (mr *MockStreamMockRecorder) StreamID() *StreamStreamIDCall + func (mr *MockStreamMockRecorder) Write(arg0 any) *StreamWriteCall + type StreamCancelReadCall struct + func (c *StreamCancelReadCall) Do(f func(qerr.StreamErrorCode)) *StreamCancelReadCall + func (c *StreamCancelReadCall) DoAndReturn(f func(qerr.StreamErrorCode)) *StreamCancelReadCall + func (c *StreamCancelReadCall) Return() *StreamCancelReadCall + type StreamCancelWriteCall struct + func (c *StreamCancelWriteCall) Do(f func(qerr.StreamErrorCode)) *StreamCancelWriteCall + func (c *StreamCancelWriteCall) DoAndReturn(f func(qerr.StreamErrorCode)) *StreamCancelWriteCall + func (c *StreamCancelWriteCall) Return() *StreamCancelWriteCall + type StreamCloseCall struct + func (c *StreamCloseCall) Do(f func() error) *StreamCloseCall + func (c *StreamCloseCall) DoAndReturn(f func() error) *StreamCloseCall + func (c *StreamCloseCall) Return(arg0 error) *StreamCloseCall + type StreamContextCall struct + func (c *StreamContextCall) Do(f func() context.Context) *StreamContextCall + func (c *StreamContextCall) DoAndReturn(f func() context.Context) *StreamContextCall + func (c *StreamContextCall) Return(arg0 context.Context) *StreamContextCall + type StreamReadCall struct + func (c *StreamReadCall) Do(f func([]byte) (int, error)) *StreamReadCall + func (c *StreamReadCall) DoAndReturn(f func([]byte) (int, error)) *StreamReadCall + func (c *StreamReadCall) Return(arg0 int, arg1 error) *StreamReadCall + type StreamSetDeadlineCall struct + func (c *StreamSetDeadlineCall) Do(f func(time.Time) error) *StreamSetDeadlineCall + func (c *StreamSetDeadlineCall) DoAndReturn(f func(time.Time) error) *StreamSetDeadlineCall + func (c *StreamSetDeadlineCall) Return(arg0 error) *StreamSetDeadlineCall + type StreamSetReadDeadlineCall struct + func (c *StreamSetReadDeadlineCall) Do(f func(time.Time) error) *StreamSetReadDeadlineCall + func (c *StreamSetReadDeadlineCall) DoAndReturn(f func(time.Time) error) *StreamSetReadDeadlineCall + func (c *StreamSetReadDeadlineCall) Return(arg0 error) *StreamSetReadDeadlineCall + type StreamSetWriteDeadlineCall struct + func (c *StreamSetWriteDeadlineCall) Do(f func(time.Time) error) *StreamSetWriteDeadlineCall + func (c *StreamSetWriteDeadlineCall) DoAndReturn(f func(time.Time) error) *StreamSetWriteDeadlineCall + func (c *StreamSetWriteDeadlineCall) Return(arg0 error) *StreamSetWriteDeadlineCall + type StreamStreamIDCall struct + func (c *StreamStreamIDCall) Do(f func() protocol.StreamID) *StreamStreamIDCall + func (c *StreamStreamIDCall) DoAndReturn(f func() protocol.StreamID) *StreamStreamIDCall + func (c *StreamStreamIDCall) Return(arg0 protocol.StreamID) *StreamStreamIDCall + type StreamWriteCall struct + func (c *StreamWriteCall) Do(f func([]byte) (int, error)) *StreamWriteCall + func (c *StreamWriteCall) DoAndReturn(f func([]byte) (int, error)) *StreamWriteCall + func (c *StreamWriteCall) Return(arg0 int, arg1 error) *StreamWriteCall