mocks

package

Go to main page

Versions in this module

v0

v0.35.0

Feb 10, 2026

v0.34.0

Nov 19, 2025

Changes in this version

type Session

+ MockGeoipDB func() string

+ func (sess *Session) GeoipDB() string

v0.33.0

Sep 6, 2025

v0.32.0

Jun 13, 2025

v0.31.0

Apr 8, 2025

v0.30.0

Nov 26, 2024

Changes in this version

type ExperimentBuilder

+ MockNewTargetLoader func(config *model.ExperimentTargetLoaderConfig) model.ExperimentTargetLoader

+ MockSetOptionsJSON func(value json.RawMessage) error

+ func (eb *ExperimentBuilder) NewTargetLoader(config *model.ExperimentTargetLoaderConfig) model.ExperimentTargetLoader

+ func (eb *ExperimentBuilder) SetOptionsJSON(value json.RawMessage) error

+ type ExperimentTargetLoader struct

+ MockLoad func(ctx context.Context) ([]model.ExperimentTarget, error)

+ func (eil *ExperimentTargetLoader) Load(ctx context.Context) ([]model.ExperimentTarget, error)

type Session

+ MockClose func() error

+ MockFetchOpenVPNConfig func(ctx context.Context, provider, cc string) (*model.OOAPIVPNProviderConfig, error)

+ MockMaybeLookupBackendsContext func(ctx context.Context) error

+ MockMaybeLookupLocationContext func(ctx context.Context) error

+ MockResolverASNString func() string

+ MockResolverNetworkName func() string

+ func (sess *Session) Close() error

+ func (sess *Session) FetchOpenVPNConfig(ctx context.Context, provider, cc string) (*model.OOAPIVPNProviderConfig, error)

+ func (sess *Session) MaybeLookupBackendsContext(ctx context.Context) error

+ func (sess *Session) MaybeLookupLocationContext(ctx context.Context) error

+ func (sess *Session) ResolverASNString() string

+ func (sess *Session) ResolverNetworkName() string

v0.29.0

May 20, 2024

v0.28.0

Mar 26, 2024

v0.27.0

Dec 13, 2023

Changes in this version

type QUICEarlyConnection

+ MockReceiveDatagram func(ctx context.Context) ([]byte, error)

+ MockSendDatagram func(b []byte) error

+ func (s *QUICEarlyConnection) ReceiveDatagram(ctx context.Context) ([]byte, error)

+ func (s *QUICEarlyConnection) SendDatagram(b []byte) error

v0.26.0

Oct 10, 2023

Changes in this version

+ func NewGeoIPASNLookupper(mx map[string]*model.LocationASN) model.GeoIPASNLookupper

+ type ExperimentMeasurer struct

+ MockExperimentName func() string

+ MockExperimentVersion func() string

+ MockGetSummaryKeys func(*model.Measurement) (any, error)

+ MockRun func(ctx context.Context, args *model.ExperimentArgs) error

+ func (em *ExperimentMeasurer) ExperimentName() string

+ func (em *ExperimentMeasurer) ExperimentVersion() string

+ func (em *ExperimentMeasurer) GetSummaryKeys(meas *model.Measurement) (any, error)

+ func (em *ExperimentMeasurer) Run(ctx context.Context, args *model.ExperimentArgs) error

+ type GeoIPASNLookupper struct

+ LookupASNFunc func(ip string) (asn uint, org string, err error)

+ func (gal *GeoIPASNLookupper) LookupASN(ip string) (asn uint, org string, err error)

+ type MeasuringNetwork struct

+ MockNewDialerWithoutResolver func(dl model.DebugLogger, w ...model.DialerWrapper) model.Dialer

+ MockNewParallelDNSOverHTTPSResolver func(logger model.DebugLogger, URL string) model.Resolver

+ MockNewParallelUDPResolver func(logger model.DebugLogger, dialer model.Dialer, address string) model.Resolver

+ MockNewQUICDialerWithoutResolver func(listener model.UDPListener, logger model.DebugLogger, ...) model.QUICDialer

+ MockNewStdlibResolver func(logger model.DebugLogger) model.Resolver

+ MockNewTLSHandshakerStdlib func(logger model.DebugLogger) model.TLSHandshaker

+ MockNewTLSHandshakerUTLS func(logger model.DebugLogger, id *utls.ClientHelloID) model.TLSHandshaker

+ MockNewUDPListener func() model.UDPListener

+ func (mn *MeasuringNetwork) NewDialerWithoutResolver(dl model.DebugLogger, w ...model.DialerWrapper) model.Dialer

+ func (mn *MeasuringNetwork) NewParallelDNSOverHTTPSResolver(logger model.DebugLogger, URL string) model.Resolver

+ func (mn *MeasuringNetwork) NewParallelUDPResolver(logger model.DebugLogger, dialer model.Dialer, address string) model.Resolver

+ func (mn *MeasuringNetwork) NewQUICDialerWithoutResolver(listener model.UDPListener, logger model.DebugLogger, ...) model.QUICDialer

+ func (mn *MeasuringNetwork) NewStdlibResolver(logger model.DebugLogger) model.Resolver

+ func (mn *MeasuringNetwork) NewTLSHandshakerStdlib(logger model.DebugLogger) model.TLSHandshaker

+ func (mn *MeasuringNetwork) NewTLSHandshakerUTLS(logger model.DebugLogger, id *utls.ClientHelloID) model.TLSHandshaker

+ func (mn *MeasuringNetwork) NewUDPListener() model.UDPListener

+ type UDPListener struct

+ MockListen func(addr *net.UDPAddr) (model.UDPLikeConn, error)

+ func (ql *UDPListener) Listen(addr *net.UDPAddr) (model.UDPLikeConn, error)

type UnderlyingNetwork

+ MockDialTimeout func() time.Duration

+ MockListenTCP func(network string, addr *net.TCPAddr) (net.Listener, error)

+ func (un *UnderlyingNetwork) DialTimeout() time.Duration

+ func (un *UnderlyingNetwork) ListenTCP(network string, addr *net.TCPAddr) (net.Listener, error)

v0.25.0

Jun 8, 2023

Changes in this version

+ type Addr struct

+ MockNetwork func() string

+ MockString func() string

+ func (a *Addr) Network() string

+ func (a *Addr) String() string

+ type Conn struct

+ MockClose func() error

+ MockLocalAddr func() net.Addr

+ MockRead func(b []byte) (int, error)

+ MockRemoteAddr func() net.Addr

+ MockSetDeadline func(t time.Time) error

+ MockSetReadDeadline func(t time.Time) error

+ MockSetWriteDeadline func(t time.Time) error

+ MockWrite func(b []byte) (int, error)

+ func (c *Conn) Close() error

+ func (c *Conn) LocalAddr() net.Addr

+ func (c *Conn) Read(b []byte) (int, error)

+ func (c *Conn) RemoteAddr() net.Addr

+ func (c *Conn) SetDeadline(t time.Time) error

+ func (c *Conn) SetReadDeadline(t time.Time) error

+ func (c *Conn) SetWriteDeadline(t time.Time) error

+ func (c *Conn) Write(b []byte) (int, error)

+ type DNSDecoder struct

+ MockDecodeResponse func(data []byte, query model.DNSQuery) (model.DNSResponse, error)

+ func (e *DNSDecoder) DecodeResponse(data []byte, query model.DNSQuery) (model.DNSResponse, error)

+ type DNSEncoder struct

+ MockEncode func(domain string, qtype uint16, padding bool) model.DNSQuery

+ func (e *DNSEncoder) Encode(domain string, qtype uint16, padding bool) model.DNSQuery

+ type DNSQuery struct

+ MockBytes func() ([]byte, error)

+ MockDomain func() string

+ MockID func() uint16

+ MockType func() uint16

+ func (q *DNSQuery) Bytes() ([]byte, error)

+ func (q *DNSQuery) Domain() string

+ func (q *DNSQuery) ID() uint16

+ func (q *DNSQuery) Type() uint16

+ type DNSResponse struct

+ MockBytes func() []byte

+ MockDecodeCNAME func() (string, error)

+ MockDecodeHTTPS func() (*model.HTTPSSvc, error)

+ MockDecodeLookupHost func() ([]string, error)

+ MockDecodeNS func() ([]*net.NS, error)

+ MockQuery func() model.DNSQuery

+ MockRcode func() int

+ func (r *DNSResponse) Bytes() []byte

+ func (r *DNSResponse) DecodeCNAME() (string, error)

+ func (r *DNSResponse) DecodeHTTPS() (*model.HTTPSSvc, error)

+ func (r *DNSResponse) DecodeLookupHost() ([]string, error)

+ func (r *DNSResponse) DecodeNS() ([]*net.NS, error)

+ func (r *DNSResponse) Query() model.DNSQuery

+ func (r *DNSResponse) Rcode() int

+ type DNSTransport struct

+ MockAddress func() string

+ MockCloseIdleConnections func()

+ MockNetwork func() string

+ MockRequiresPadding func() bool

+ MockRoundTrip func(ctx context.Context, query model.DNSQuery) (model.DNSResponse, error)

+ func (txp *DNSTransport) Address() string

+ func (txp *DNSTransport) CloseIdleConnections()

+ func (txp *DNSTransport) Network() string

+ func (txp *DNSTransport) RequiresPadding() bool

+ func (txp *DNSTransport) RoundTrip(ctx context.Context, query model.DNSQuery) (model.DNSResponse, error)

+ type Database struct

+ MockAddTestKeys func(msmt *model.DatabaseMeasurement, tk interface{}) error

+ MockCreateMeasurement func(reportID sql.NullString, testName string, measurementDir string, idx int, ...) (*model.DatabaseMeasurement, error)

+ MockCreateNetwork func(loc model.LocationProvider) (*model.DatabaseNetwork, error)

+ MockCreateOrUpdateURL func(urlStr string, categoryCode string, countryCode string) (int64, error)

+ MockCreateResult func(homePath string, testGroupName string, networkID int64) (*model.DatabaseResult, error)

+ MockDeleteResult func(resultID int64) error

+ MockDone func(msmt *model.DatabaseMeasurement) error

+ MockFailed func(msmt *model.DatabaseMeasurement, failure string) error

+ MockFinished func(result *model.DatabaseResult) error

+ MockGetMeasurementJSON func(msmtID int64) (map[string]interface{}, error)

+ MockListMeasurements func(resultID int64) ([]model.DatabaseMeasurementURLNetwork, error)

+ MockListResults func() ([]model.DatabaseResultNetwork, []model.DatabaseResultNetwork, error)

+ MockUpdateUploadedStatus func(result *model.DatabaseResult) error

+ MockUploadFailed func(msmt *model.DatabaseMeasurement, failure string) error

+ MockUploadSucceeded func(msmt *model.DatabaseMeasurement) error

+ func (d *Database) AddTestKeys(msmt *model.DatabaseMeasurement, tk interface{}) error

+ func (d *Database) CreateMeasurement(reportID sql.NullString, testName string, measurementDir string, idx int, ...) (*model.DatabaseMeasurement, error)

+ func (d *Database) CreateNetwork(loc model.LocationProvider) (*model.DatabaseNetwork, error)

+ func (d *Database) CreateOrUpdateURL(urlStr string, categoryCode string, countryCode string) (int64, error)

+ func (d *Database) CreateResult(homePath string, testGroupName string, networkID int64) (*model.DatabaseResult, error)

+ func (d *Database) DeleteResult(resultID int64) error

+ func (d *Database) Done(msmt *model.DatabaseMeasurement) error

+ func (d *Database) Failed(msmt *model.DatabaseMeasurement, failure string) error

+ func (d *Database) Finished(result *model.DatabaseResult) error

+ func (d *Database) GetMeasurementJSON(msmtID int64) (map[string]interface{}, error)

+ func (d *Database) ListMeasurements(resultID int64) ([]model.DatabaseMeasurementURLNetwork, error)

+ func (d *Database) ListResults() ([]model.DatabaseResultNetwork, []model.DatabaseResultNetwork, error)

+ func (d *Database) UpdateUploadedStatus(result *model.DatabaseResult) error

+ func (d *Database) UploadFailed(msmt *model.DatabaseMeasurement, failure string) error

+ func (d *Database) UploadSucceeded(msmt *model.DatabaseMeasurement) error

+ type Dialer struct

+ MockCloseIdleConnections func()

+ MockDialContext func(ctx context.Context, network, address string) (net.Conn, error)

+ func (d *Dialer) CloseIdleConnections()

+ func (d *Dialer) DialContext(ctx context.Context, network, address string) (net.Conn, error)

+ type Experiment struct

+ MockGetSummaryKeys func(m *model.Measurement) (any, error)

+ MockKibiBytesReceived func() float64

+ MockKibiBytesSent func() float64

+ MockMeasureAsync func(ctx context.Context, input string) (<-chan *model.Measurement, error)

+ MockMeasureWithContext func(ctx context.Context, input string) (measurement *model.Measurement, err error)

+ MockName func() string

+ MockOpenReportContext func(ctx context.Context) error

+ MockReportID func() string

+ MockSaveMeasurement func(measurement *model.Measurement, filePath string) error

+ MockSubmitAndUpdateMeasurementContext func(ctx context.Context, measurement *model.Measurement) error

+ func (e *Experiment) GetSummaryKeys(m *model.Measurement) (any, error)

+ func (e *Experiment) KibiBytesReceived() float64

+ func (e *Experiment) KibiBytesSent() float64

+ func (e *Experiment) MeasureAsync(ctx context.Context, input string) (<-chan *model.Measurement, error)

+ func (e *Experiment) MeasureWithContext(ctx context.Context, input string) (measurement *model.Measurement, err error)

+ func (e *Experiment) Name() string

+ func (e *Experiment) OpenReportContext(ctx context.Context) error

+ func (e *Experiment) ReportID() string

+ func (e *Experiment) SaveMeasurement(measurement *model.Measurement, filePath string) error

+ func (e *Experiment) SubmitAndUpdateMeasurementContext(ctx context.Context, measurement *model.Measurement) error

+ type ExperimentBuilder struct

+ MockInputPolicy func() model.InputPolicy

+ MockInterruptible func() bool

+ MockNewExperiment func() model.Experiment

+ MockOptions func() (map[string]model.ExperimentOptionInfo, error)

+ MockSetCallbacks func(callbacks model.ExperimentCallbacks)

+ MockSetOptionAny func(key string, value any) error

+ MockSetOptionsAny func(options map[string]any) error

+ func (eb *ExperimentBuilder) InputPolicy() model.InputPolicy

+ func (eb *ExperimentBuilder) Interruptible() bool

+ func (eb *ExperimentBuilder) NewExperiment() model.Experiment

+ func (eb *ExperimentBuilder) Options() (map[string]model.ExperimentOptionInfo, error)

+ func (eb *ExperimentBuilder) SetCallbacks(callbacks model.ExperimentCallbacks)

+ func (eb *ExperimentBuilder) SetOptionAny(key string, value any) error

+ func (eb *ExperimentBuilder) SetOptionsAny(options map[string]any) error

+ type ExperimentInputLoader struct

+ MockLoad func(ctx context.Context) ([]model.OOAPIURLInfo, error)

+ func (eil *ExperimentInputLoader) Load(ctx context.Context) ([]model.OOAPIURLInfo, error)

+ type ExperimentInputProcessor struct

+ MockRun func(ctx context.Context) error

+ func (eip *ExperimentInputProcessor) Run(ctx context.Context) error

+ type HTTP3RoundTripper struct

+ MockClose func() error

+ MockRoundTrip func(req *http.Request) (*http.Response, error)

+ func (txp *HTTP3RoundTripper) Close() error

+ func (txp *HTTP3RoundTripper) RoundTrip(req *http.Request) (*http.Response, error)

+ type HTTPClient struct

+ MockCloseIdleConnections func()

+ MockDo func(req *http.Request) (*http.Response, error)

+ func (txp *HTTPClient) CloseIdleConnections()

+ func (txp *HTTPClient) Do(req *http.Request) (*http.Response, error)

+ type HTTPResponseWriter struct

+ MockHeader func() http.Header

+ MockWrite func(b []byte) (int, error)

+ MockWriteHeader func(statusCode int)

+ func (w *HTTPResponseWriter) Header() http.Header

+ func (w *HTTPResponseWriter) Write(b []byte) (int, error)

+ func (w *HTTPResponseWriter) WriteHeader(statusCode int)

+ type HTTPTransport struct

+ MockCloseIdleConnections func()

+ MockNetwork func() string

+ MockRoundTrip func(req *http.Request) (*http.Response, error)

+ func (txp *HTTPTransport) CloseIdleConnections()

+ func (txp *HTTPTransport) Network() string

+ func (txp *HTTPTransport) RoundTrip(req *http.Request) (*http.Response, error)

+ type KeyValueStore struct

+ MockGet func(key string) (value []byte, err error)

+ MockSet func(key string, value []byte) (err error)

+ func (kvs *KeyValueStore) Get(key string) (value []byte, err error)

+ func (kvs *KeyValueStore) Set(key string, value []byte) (err error)

+ type Listener struct

+ MockAccept func() (net.Conn, error)

+ MockAddr func() net.Addr

+ MockClose func() error

+ func (li *Listener) Accept() (net.Conn, error)

+ func (li *Listener) Addr() net.Addr

+ func (li *Listener) Close() error

+ type LocationProvider struct

+ MockProbeASN func() uint

+ MockProbeASNString func() string

+ MockProbeCC func() string

+ MockProbeIP func() string

+ MockProbeNetworkName func() string

+ MockResolverIP func() string

+ func (loc *LocationProvider) ProbeASN() uint

+ func (loc *LocationProvider) ProbeASNString() string

+ func (loc *LocationProvider) ProbeCC() string

+ func (loc *LocationProvider) ProbeIP() string

+ func (loc *LocationProvider) ProbeNetworkName() string

+ func (loc *LocationProvider) ResolverIP() string

+ type Logger struct

+ MockDebug func(message string)

+ MockDebugf func(format string, v ...interface{})

+ MockInfo func(message string)

+ MockInfof func(format string, v ...interface{})

+ MockWarn func(message string)

+ MockWarnf func(format string, v ...interface{})

+ func (lo *Logger) Debug(message string)

+ func (lo *Logger) Debugf(format string, v ...interface{})

+ func (lo *Logger) Info(message string)

+ func (lo *Logger) Infof(format string, v ...interface{})

+ func (lo *Logger) Warn(message string)

+ func (lo *Logger) Warnf(format string, v ...interface{})

+ type QUICDialer struct

+ MockCloseIdleConnections func()

+ MockDialContext func(ctx context.Context, address string, tlsConfig *tls.Config, ...) (quic.EarlyConnection, error)

+ func (qcd *QUICDialer) CloseIdleConnections()

+ func (qcd *QUICDialer) DialContext(ctx context.Context, address string, tlsConfig *tls.Config, ...) (quic.EarlyConnection, error)

+ type QUICEarlyConnection struct

+ MockAcceptStream func(context.Context) (quic.Stream, error)

+ MockAcceptUniStream func(context.Context) (quic.ReceiveStream, error)

+ MockCloseWithError func(code quic.ApplicationErrorCode, reason string) error

+ MockConnectionState func() quic.ConnectionState

+ MockContext func() context.Context

+ MockHandshakeComplete func() context.Context

+ MockLocalAddr func() net.Addr

+ MockNextConnection func() quic.Connection

+ MockOpenStream func() (quic.Stream, error)

+ MockOpenStreamSync func(ctx context.Context) (quic.Stream, error)

+ MockOpenUniStream func() (quic.SendStream, error)

+ MockOpenUniStreamSync func(ctx context.Context) (quic.SendStream, error)

+ MockReceiveMessage func() ([]byte, error)

+ MockRemoteAddr func() net.Addr

+ MockSendMessage func(b []byte) error

+ func (c *QUICEarlyConnection) CloseWithError(code quic.ApplicationErrorCode, reason string) error

+ func (c *QUICEarlyConnection) LocalAddr() net.Addr

+ func (c *QUICEarlyConnection) RemoteAddr() net.Addr

+ func (s *QUICEarlyConnection) AcceptStream(ctx context.Context) (quic.Stream, error)

+ func (s *QUICEarlyConnection) AcceptUniStream(ctx context.Context) (quic.ReceiveStream, error)

+ func (s *QUICEarlyConnection) ConnectionState() quic.ConnectionState

+ func (s *QUICEarlyConnection) Context() context.Context

+ func (s *QUICEarlyConnection) HandshakeComplete() context.Context

+ func (s *QUICEarlyConnection) NextConnection() quic.Connection

+ func (s *QUICEarlyConnection) OpenStream() (quic.Stream, error)

+ func (s *QUICEarlyConnection) OpenStreamSync(ctx context.Context) (quic.Stream, error)

+ func (s *QUICEarlyConnection) OpenUniStream() (quic.SendStream, error)

+ func (s *QUICEarlyConnection) OpenUniStreamSync(ctx context.Context) (quic.SendStream, error)

+ func (s *QUICEarlyConnection) ReceiveMessage() ([]byte, error)

+ func (s *QUICEarlyConnection) SendMessage(b []byte) error

+ type QUICListener struct

+ MockListen func(addr *net.UDPAddr) (model.UDPLikeConn, error)

+ func (ql *QUICListener) Listen(addr *net.UDPAddr) (model.UDPLikeConn, error)

+ type Reader struct

+ MockRead func(b []byte) (int, error)

+ func (r *Reader) Read(b []byte) (int, error)

+ type Resolver struct

+ MockAddress func() string

+ MockCloseIdleConnections func()

+ MockLookupHTTPS func(ctx context.Context, domain string) (*model.HTTPSSvc, error)

+ MockLookupHost func(ctx context.Context, domain string) ([]string, error)

+ MockLookupNS func(ctx context.Context, domain string) ([]*net.NS, error)

+ MockNetwork func() string

+ func (r *Resolver) Address() string

+ func (r *Resolver) CloseIdleConnections()

+ func (r *Resolver) LookupHTTPS(ctx context.Context, domain string) (*model.HTTPSSvc, error)

+ func (r *Resolver) LookupHost(ctx context.Context, domain string) ([]string, error)

+ func (r *Resolver) LookupNS(ctx context.Context, domain string) ([]*net.NS, error)

+ func (r *Resolver) Network() string

+ type Saver struct

+ MockSaveMeasurement func(m *model.Measurement) error

+ func (s *Saver) SaveMeasurement(m *model.Measurement) error

+ type Session struct

+ MockCheckIn func(ctx context.Context, config *model.OOAPICheckInConfig) (*model.OOAPICheckInResultNettests, error)

+ MockDefaultHTTPClient func() model.HTTPClient

+ MockFetchPsiphonConfig func(ctx context.Context) ([]byte, error)

+ MockFetchTorTargets func(ctx context.Context, cc string) (map[string]model.OOAPITorTarget, error)

+ MockGetTestHelpersByName func(name string) ([]model.OOAPIService, bool)

+ MockKeyValueStore func() model.KeyValueStore

+ MockLogger func() model.Logger

+ MockMaybeResolverIP func() string

+ MockNewExperimentBuilder func(name string) (model.ExperimentBuilder, error)

+ MockNewSubmitter func(ctx context.Context) (model.Submitter, error)

+ MockProbeASNString func() string

+ MockProbeCC func() string

+ MockProbeIP func() string

+ MockProbeNetworkName func() string

+ MockProxyURL func() *url.URL

+ MockResolverIP func() string

+ MockSoftwareName func() string

+ MockSoftwareVersion func() string

+ MockTempDir func() string

+ MockTorArgs func() []string

+ MockTorBinary func() string

+ MockTunnelDir func() string

+ MockUserAgent func() string

+ func (sess *Session) CheckIn(ctx context.Context, config *model.OOAPICheckInConfig) (*model.OOAPICheckInResultNettests, error)

+ func (sess *Session) DefaultHTTPClient() model.HTTPClient

+ func (sess *Session) FetchPsiphonConfig(ctx context.Context) ([]byte, error)

+ func (sess *Session) FetchTorTargets(ctx context.Context, cc string) (map[string]model.OOAPITorTarget, error)

+ func (sess *Session) GetTestHelpersByName(name string) ([]model.OOAPIService, bool)

+ func (sess *Session) KeyValueStore() model.KeyValueStore

+ func (sess *Session) Logger() model.Logger

+ func (sess *Session) MaybeResolverIP() string

+ func (sess *Session) NewExperimentBuilder(name string) (model.ExperimentBuilder, error)

+ func (sess *Session) NewSubmitter(ctx context.Context) (model.Submitter, error)

+ func (sess *Session) ProbeASNString() string

+ func (sess *Session) ProbeCC() string

+ func (sess *Session) ProbeIP() string

+ func (sess *Session) ProbeNetworkName() string

+ func (sess *Session) ProxyURL() *url.URL

+ func (sess *Session) ResolverIP() string

+ func (sess *Session) SoftwareName() string

+ func (sess *Session) SoftwareVersion() string

+ func (sess *Session) TempDir() string

+ func (sess *Session) TorArgs() []string

+ func (sess *Session) TorBinary() string

+ func (sess *Session) TunnelDir() string

+ func (sess *Session) UserAgent() string

+ type Submitter struct

+ MockSubmit func(ctx context.Context, m *model.Measurement) error

+ func (s *Submitter) Submit(ctx context.Context, m *model.Measurement) error

+ type TLSConn struct

+ MockConnectionState func() tls.ConnectionState

+ MockHandshakeContext func(ctx context.Context) error

+ MockNetConn func() net.Conn

+ func (c *TLSConn) ConnectionState() tls.ConnectionState

+ func (c *TLSConn) HandshakeContext(ctx context.Context) error

+ func (c *TLSConn) NetConn() net.Conn

+ type TLSDialer struct

+ MockCloseIdleConnections func()

+ MockDialTLSContext func(ctx context.Context, network, address string) (net.Conn, error)

+ func (d *TLSDialer) CloseIdleConnections()

+ func (d *TLSDialer) DialTLSContext(ctx context.Context, network, address string) (net.Conn, error)

+ type TLSHandshaker struct

+ MockHandshake func(ctx context.Context, conn net.Conn, config *tls.Config) (net.Conn, tls.ConnectionState, error)

+ func (th *TLSHandshaker) Handshake(ctx context.Context, conn net.Conn, config *tls.Config) (net.Conn, tls.ConnectionState, error)

+ type Trace struct

+ MockMaybeWrapNetConn func(conn net.Conn) net.Conn

+ MockMaybeWrapUDPLikeConn func(conn model.UDPLikeConn) model.UDPLikeConn

+ MockOnConnectDone func(started time.Time, network, domain, remoteAddr string, err error, ...)

+ MockOnDNSRoundTripForLookupHost func(started time.Time, reso model.Resolver, query model.DNSQuery, ...)

+ MockOnDelayedDNSResponse func(started time.Time, txp model.DNSTransport, query model.DNSQuery, ...) error

+ MockOnQUICHandshakeDone func(started time.Time, remoteAddr string, qconn quic.EarlyConnection, ...)

+ MockOnQUICHandshakeStart func(now time.Time, remoteAddrs string, config *quic.Config)

+ MockOnTLSHandshakeDone func(started time.Time, remoteAddr string, config *tls.Config, ...)

+ MockOnTLSHandshakeStart func(now time.Time, remoteAddr string, config *tls.Config)

+ MockTimeNow func() time.Time

+ func (t *Trace) MaybeWrapNetConn(conn net.Conn) net.Conn

+ func (t *Trace) MaybeWrapUDPLikeConn(conn model.UDPLikeConn) model.UDPLikeConn

+ func (t *Trace) OnConnectDone(started time.Time, network, domain, remoteAddr string, err error, ...)

+ func (t *Trace) OnDNSRoundTripForLookupHost(started time.Time, reso model.Resolver, query model.DNSQuery, ...)

+ func (t *Trace) OnDelayedDNSResponse(started time.Time, txp model.DNSTransport, query model.DNSQuery, ...) error

+ func (t *Trace) OnQUICHandshakeDone(started time.Time, remoteAddr string, qconn quic.EarlyConnection, ...)

+ func (t *Trace) OnQUICHandshakeStart(now time.Time, remoteAddr string, config *quic.Config)

+ func (t *Trace) OnTLSHandshakeDone(started time.Time, remoteAddr string, config *tls.Config, ...)

+ func (t *Trace) OnTLSHandshakeStart(now time.Time, remoteAddr string, config *tls.Config)

+ func (t *Trace) TimeNow() time.Time

+ type UDPLikeConn struct

+ MockClose func() error

+ MockLocalAddr func() net.Addr

+ MockReadFrom func(p []byte) (int, net.Addr, error)

+ MockRemoteAddr func() net.Addr

+ MockSetDeadline func(t time.Time) error

+ MockSetReadBuffer func(n int) error

+ MockSetReadDeadline func(t time.Time) error

+ MockSetWriteDeadline func(t time.Time) error

+ MockSyscallConn func() (syscall.RawConn, error)

+ MockWriteTo func(p []byte, addr net.Addr) (int, error)

+ func (c *UDPLikeConn) Close() error

+ func (c *UDPLikeConn) LocalAddr() net.Addr

+ func (c *UDPLikeConn) ReadFrom(b []byte) (int, net.Addr, error)

+ func (c *UDPLikeConn) RemoteAddr() net.Addr

+ func (c *UDPLikeConn) SetDeadline(t time.Time) error

+ func (c *UDPLikeConn) SetReadBuffer(n int) error

+ func (c *UDPLikeConn) SetReadDeadline(t time.Time) error

+ func (c *UDPLikeConn) SetWriteDeadline(t time.Time) error

+ func (c *UDPLikeConn) SyscallConn() (syscall.RawConn, error)

+ func (c *UDPLikeConn) WriteTo(p []byte, addr net.Addr) (int, error)

+ type UnderlyingNetwork struct

+ MockDefaultCertPool func() *x509.CertPool

+ MockDialContext func(ctx context.Context, timeout time.Duration, network, address string) (net.Conn, error)

+ MockGetaddrinfoLookupANY func(ctx context.Context, domain string) ([]string, string, error)

+ MockGetaddrinfoResolverNetwork func() string

+ MockListenUDP func(network string, addr *net.UDPAddr) (model.UDPLikeConn, error)

+ func (un *UnderlyingNetwork) DefaultCertPool() *x509.CertPool

+ func (un *UnderlyingNetwork) DialContext(ctx context.Context, timeout time.Duration, network, address string) (net.Conn, error)

+ func (un *UnderlyingNetwork) GetaddrinfoLookupANY(ctx context.Context, domain string) ([]string, string, error)

+ func (un *UnderlyingNetwork) GetaddrinfoResolverNetwork() string

+ func (un *UnderlyingNetwork) ListenUDP(network string, addr *net.UDPAddr) (model.UDPLikeConn, error)

+ type Writer struct

+ MockWrite func(b []byte) (int, error)

+ func (r *Writer) Write(b []byte) (int, error)

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL