Versions in this module Expand all Collapse all v0 v0.19.5 Jan 10, 2021 Changes in this version + type MockConnectionFlowController struct + func NewMockConnectionFlowController(ctrl *gomock.Controller) *MockConnectionFlowController + func (m *MockConnectionFlowController) AddBytesRead(arg0 protocol.ByteCount) + func (m *MockConnectionFlowController) AddBytesSent(arg0 protocol.ByteCount) + func (m *MockConnectionFlowController) EXPECT() *MockConnectionFlowControllerMockRecorder + func (m *MockConnectionFlowController) GetWindowUpdate() protocol.ByteCount + func (m *MockConnectionFlowController) IsNewlyBlocked() (bool, protocol.ByteCount) + func (m *MockConnectionFlowController) SendWindowSize() protocol.ByteCount + func (m *MockConnectionFlowController) UpdateSendWindow(arg0 protocol.ByteCount) + type MockConnectionFlowControllerMockRecorder struct + func (mr *MockConnectionFlowControllerMockRecorder) AddBytesRead(arg0 interface{}) *gomock.Call + func (mr *MockConnectionFlowControllerMockRecorder) AddBytesSent(arg0 interface{}) *gomock.Call + func (mr *MockConnectionFlowControllerMockRecorder) GetWindowUpdate() *gomock.Call + func (mr *MockConnectionFlowControllerMockRecorder) IsNewlyBlocked() *gomock.Call + func (mr *MockConnectionFlowControllerMockRecorder) SendWindowSize() *gomock.Call + func (mr *MockConnectionFlowControllerMockRecorder) UpdateSendWindow(arg0 interface{}) *gomock.Call + type MockCryptoSetup struct + func NewMockCryptoSetup(ctrl *gomock.Controller) *MockCryptoSetup + func (m *MockCryptoSetup) ChangeConnectionID(arg0 protocol.ConnectionID) + func (m *MockCryptoSetup) Close() error + func (m *MockCryptoSetup) ConnectionState() qtls.ConnectionState + func (m *MockCryptoSetup) EXPECT() *MockCryptoSetupMockRecorder + func (m *MockCryptoSetup) Get0RTTOpener() (handshake.LongHeaderOpener, error) + func (m *MockCryptoSetup) Get0RTTSealer() (handshake.LongHeaderSealer, error) + func (m *MockCryptoSetup) Get1RTTOpener() (handshake.ShortHeaderOpener, error) + func (m *MockCryptoSetup) Get1RTTSealer() (handshake.ShortHeaderSealer, error) + func (m *MockCryptoSetup) GetHandshakeOpener() (handshake.LongHeaderOpener, error) + func (m *MockCryptoSetup) GetHandshakeSealer() (handshake.LongHeaderSealer, error) + func (m *MockCryptoSetup) GetInitialOpener() (handshake.LongHeaderOpener, error) + func (m *MockCryptoSetup) GetInitialSealer() (handshake.LongHeaderSealer, error) + func (m *MockCryptoSetup) GetSessionTicket() ([]byte, error) + func (m *MockCryptoSetup) HandleMessage(arg0 []byte, arg1 protocol.EncryptionLevel) bool + func (m *MockCryptoSetup) RunHandshake() + func (m *MockCryptoSetup) SetHandshakeConfirmed() + func (m *MockCryptoSetup) SetLargest1RTTAcked(arg0 protocol.PacketNumber) error + type MockCryptoSetupMockRecorder struct + func (mr *MockCryptoSetupMockRecorder) ChangeConnectionID(arg0 interface{}) *gomock.Call + func (mr *MockCryptoSetupMockRecorder) Close() *gomock.Call + func (mr *MockCryptoSetupMockRecorder) ConnectionState() *gomock.Call + func (mr *MockCryptoSetupMockRecorder) Get0RTTOpener() *gomock.Call + func (mr *MockCryptoSetupMockRecorder) Get0RTTSealer() *gomock.Call + func (mr *MockCryptoSetupMockRecorder) Get1RTTOpener() *gomock.Call + func (mr *MockCryptoSetupMockRecorder) Get1RTTSealer() *gomock.Call + func (mr *MockCryptoSetupMockRecorder) GetHandshakeOpener() *gomock.Call + func (mr *MockCryptoSetupMockRecorder) GetHandshakeSealer() *gomock.Call + func (mr *MockCryptoSetupMockRecorder) GetInitialOpener() *gomock.Call + func (mr *MockCryptoSetupMockRecorder) GetInitialSealer() *gomock.Call + func (mr *MockCryptoSetupMockRecorder) GetSessionTicket() *gomock.Call + func (mr *MockCryptoSetupMockRecorder) HandleMessage(arg0, arg1 interface{}) *gomock.Call + func (mr *MockCryptoSetupMockRecorder) RunHandshake() *gomock.Call + func (mr *MockCryptoSetupMockRecorder) SetHandshakeConfirmed() *gomock.Call + func (mr *MockCryptoSetupMockRecorder) SetLargest1RTTAcked(arg0 interface{}) *gomock.Call + type MockLongHeaderOpener struct + func NewMockLongHeaderOpener(ctrl *gomock.Controller) *MockLongHeaderOpener + func (m *MockLongHeaderOpener) DecodePacketNumber(arg0 protocol.PacketNumber, arg1 protocol.PacketNumberLen) protocol.PacketNumber + func (m *MockLongHeaderOpener) DecryptHeader(arg0 []byte, arg1 *byte, arg2 []byte) + func (m *MockLongHeaderOpener) EXPECT() *MockLongHeaderOpenerMockRecorder + func (m *MockLongHeaderOpener) Open(arg0, arg1 []byte, arg2 protocol.PacketNumber, arg3 []byte) ([]byte, error) + type MockLongHeaderOpenerMockRecorder struct + func (mr *MockLongHeaderOpenerMockRecorder) DecodePacketNumber(arg0, arg1 interface{}) *gomock.Call + func (mr *MockLongHeaderOpenerMockRecorder) DecryptHeader(arg0, arg1, arg2 interface{}) *gomock.Call + func (mr *MockLongHeaderOpenerMockRecorder) Open(arg0, arg1, arg2, arg3 interface{}) *gomock.Call + type MockSendAlgorithmWithDebugInfos struct + func NewMockSendAlgorithmWithDebugInfos(ctrl *gomock.Controller) *MockSendAlgorithmWithDebugInfos + func (m *MockSendAlgorithmWithDebugInfos) CanSend(arg0 protocol.ByteCount) bool + func (m *MockSendAlgorithmWithDebugInfos) EXPECT() *MockSendAlgorithmWithDebugInfosMockRecorder + func (m *MockSendAlgorithmWithDebugInfos) GetCongestionWindow() protocol.ByteCount + func (m *MockSendAlgorithmWithDebugInfos) HasPacingBudget() bool + func (m *MockSendAlgorithmWithDebugInfos) InRecovery() bool + func (m *MockSendAlgorithmWithDebugInfos) InSlowStart() bool + func (m *MockSendAlgorithmWithDebugInfos) MaybeExitSlowStart() + func (m *MockSendAlgorithmWithDebugInfos) OnPacketAcked(arg0 protocol.PacketNumber, arg1, arg2 protocol.ByteCount, arg3 time.Time) + func (m *MockSendAlgorithmWithDebugInfos) OnPacketLost(arg0 protocol.PacketNumber, arg1, arg2 protocol.ByteCount) + func (m *MockSendAlgorithmWithDebugInfos) OnPacketSent(arg0 time.Time, arg1 protocol.ByteCount, arg2 protocol.PacketNumber, ...) + func (m *MockSendAlgorithmWithDebugInfos) OnRetransmissionTimeout(arg0 bool) + func (m *MockSendAlgorithmWithDebugInfos) TimeUntilSend(arg0 protocol.ByteCount) time.Time + type MockSendAlgorithmWithDebugInfosMockRecorder struct + func (mr *MockSendAlgorithmWithDebugInfosMockRecorder) CanSend(arg0 interface{}) *gomock.Call + func (mr *MockSendAlgorithmWithDebugInfosMockRecorder) GetCongestionWindow() *gomock.Call + func (mr *MockSendAlgorithmWithDebugInfosMockRecorder) HasPacingBudget() *gomock.Call + func (mr *MockSendAlgorithmWithDebugInfosMockRecorder) InRecovery() *gomock.Call + func (mr *MockSendAlgorithmWithDebugInfosMockRecorder) InSlowStart() *gomock.Call + func (mr *MockSendAlgorithmWithDebugInfosMockRecorder) MaybeExitSlowStart() *gomock.Call + func (mr *MockSendAlgorithmWithDebugInfosMockRecorder) OnPacketAcked(arg0, arg1, arg2, arg3 interface{}) *gomock.Call + func (mr *MockSendAlgorithmWithDebugInfosMockRecorder) OnPacketLost(arg0, arg1, arg2 interface{}) *gomock.Call + func (mr *MockSendAlgorithmWithDebugInfosMockRecorder) OnPacketSent(arg0, arg1, arg2, arg3, arg4 interface{}) *gomock.Call + func (mr *MockSendAlgorithmWithDebugInfosMockRecorder) OnRetransmissionTimeout(arg0 interface{}) *gomock.Call + func (mr *MockSendAlgorithmWithDebugInfosMockRecorder) TimeUntilSend(arg0 interface{}) *gomock.Call + type MockShortHeaderOpener struct + func NewMockShortHeaderOpener(ctrl *gomock.Controller) *MockShortHeaderOpener + func (m *MockShortHeaderOpener) DecodePacketNumber(arg0 protocol.PacketNumber, arg1 protocol.PacketNumberLen) protocol.PacketNumber + func (m *MockShortHeaderOpener) DecryptHeader(arg0 []byte, arg1 *byte, arg2 []byte) + func (m *MockShortHeaderOpener) EXPECT() *MockShortHeaderOpenerMockRecorder + func (m *MockShortHeaderOpener) Open(arg0, arg1 []byte, arg2 time.Time, arg3 protocol.PacketNumber, ...) ([]byte, error) + type MockShortHeaderOpenerMockRecorder struct + func (mr *MockShortHeaderOpenerMockRecorder) DecodePacketNumber(arg0, arg1 interface{}) *gomock.Call + func (mr *MockShortHeaderOpenerMockRecorder) DecryptHeader(arg0, arg1, arg2 interface{}) *gomock.Call + func (mr *MockShortHeaderOpenerMockRecorder) Open(arg0, arg1, arg2, arg3, arg4, arg5 interface{}) *gomock.Call + type MockShortHeaderSealer struct + func NewMockShortHeaderSealer(ctrl *gomock.Controller) *MockShortHeaderSealer + func (m *MockShortHeaderSealer) EXPECT() *MockShortHeaderSealerMockRecorder + func (m *MockShortHeaderSealer) EncryptHeader(arg0 []byte, arg1 *byte, arg2 []byte) + func (m *MockShortHeaderSealer) KeyPhase() protocol.KeyPhaseBit + func (m *MockShortHeaderSealer) Overhead() int + func (m *MockShortHeaderSealer) Seal(arg0, arg1 []byte, arg2 protocol.PacketNumber, arg3 []byte) []byte + type MockShortHeaderSealerMockRecorder struct + func (mr *MockShortHeaderSealerMockRecorder) EncryptHeader(arg0, arg1, arg2 interface{}) *gomock.Call + func (mr *MockShortHeaderSealerMockRecorder) KeyPhase() *gomock.Call + func (mr *MockShortHeaderSealerMockRecorder) Overhead() *gomock.Call + func (mr *MockShortHeaderSealerMockRecorder) Seal(arg0, arg1, arg2, arg3 interface{}) *gomock.Call + type MockStreamFlowController struct + func NewMockStreamFlowController(ctrl *gomock.Controller) *MockStreamFlowController + func (m *MockStreamFlowController) Abandon() + func (m *MockStreamFlowController) AddBytesRead(arg0 protocol.ByteCount) + func (m *MockStreamFlowController) AddBytesSent(arg0 protocol.ByteCount) + func (m *MockStreamFlowController) EXPECT() *MockStreamFlowControllerMockRecorder + func (m *MockStreamFlowController) GetWindowUpdate() protocol.ByteCount + func (m *MockStreamFlowController) IsNewlyBlocked() (bool, protocol.ByteCount) + func (m *MockStreamFlowController) SendWindowSize() protocol.ByteCount + func (m *MockStreamFlowController) UpdateHighestReceived(arg0 protocol.ByteCount, arg1 bool) error + func (m *MockStreamFlowController) UpdateSendWindow(arg0 protocol.ByteCount) + type MockStreamFlowControllerMockRecorder struct + func (mr *MockStreamFlowControllerMockRecorder) Abandon() *gomock.Call + func (mr *MockStreamFlowControllerMockRecorder) AddBytesRead(arg0 interface{}) *gomock.Call + func (mr *MockStreamFlowControllerMockRecorder) AddBytesSent(arg0 interface{}) *gomock.Call + func (mr *MockStreamFlowControllerMockRecorder) GetWindowUpdate() *gomock.Call + func (mr *MockStreamFlowControllerMockRecorder) IsNewlyBlocked() *gomock.Call + func (mr *MockStreamFlowControllerMockRecorder) SendWindowSize() *gomock.Call + func (mr *MockStreamFlowControllerMockRecorder) UpdateHighestReceived(arg0, arg1 interface{}) *gomock.Call + func (mr *MockStreamFlowControllerMockRecorder) UpdateSendWindow(arg0 interface{}) *gomock.Call