netext

package

v1.6.1 Latest Latest Go to latest Published: Apr 2, 2026 License: AGPL-3.0 Imports: 13 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/daudcanugerah/k6

Links

Open Source Insights

Documentation ¶

Overview ¶

Package netext provides extensions to the standard net package

Index ¶

Constants
func ParseTLSConnState(tlsState *tls.ConnectionState) (TLSInfo, OCSP)
type BlackListedIPError
- func (b BlackListedIPError) Error() string
type BlockedHostError
- func (b BlockedHostError) Error() string
type Conn
- func (c *Conn) Read(b []byte) (int, error)
- func (c *Conn) Write(b []byte) (int, error)
type Dialer
- func NewDialer(dialer net.Dialer, resolver Resolver) *Dialer
type MultiResolver
type OCSP
type Resolver
- func NewResolver(actRes MultiResolver, ttl time.Duration, sel types.DNSSelect, ...) Resolver
type TLSInfo

Constants ¶

View Source

const (
	OCSP_STATUS_GOOD                   = "good"
	OCSP_STATUS_REVOKED                = "revoked"
	OCSP_STATUS_SERVER_FAILED          = "server_failed"
	OCSP_STATUS_UNKNOWN                = "unknown"
	OCSP_REASON_UNSPECIFIED            = "unspecified"
	OCSP_REASON_KEY_COMPROMISE         = "key_compromise"
	OCSP_REASON_CA_COMPROMISE          = "ca_compromise"
	OCSP_REASON_AFFILIATION_CHANGED    = "affiliation_changed"
	OCSP_REASON_SUPERSEDED             = "superseded"
	OCSP_REASON_CESSATION_OF_OPERATION = "cessation_of_operation"
	OCSP_REASON_CERTIFICATE_HOLD       = "certificate_hold"
	OCSP_REASON_REMOVE_FROM_CRL        = "remove_from_crl"
	OCSP_REASON_PRIVILEGE_WITHDRAWN    = "privilege_withdrawn"
	OCSP_REASON_AA_COMPROMISE          = "aa_compromise"
	TLS_1_0                            = "tls1.0"
	TLS_1_1                            = "tls1.1"
	TLS_1_2                            = "tls1.2"
	TLS_1_3                            = "tls1.3"
)

Variables ¶

This section is empty.

Functions ¶

func ParseTLSConnState ¶

func ParseTLSConnState(tlsState *tls.ConnectionState) (TLSInfo, OCSP)

ParseTLSConnState parses tls.ConnectionState and returns TLS and OCSP details

Types ¶

type BlackListedIPError ¶

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

BlackListedIPError is an error that is returned when a given IP is blacklisted

func (BlackListedIPError) Error ¶

func (b BlackListedIPError) Error() string

type BlockedHostError ¶

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

BlockedHostError is returned when a given hostname is blocked

func (BlockedHostError) Error ¶

func (b BlockedHostError) Error() string

type Conn ¶

type Conn struct {
	net.Conn

	BytesRead, BytesWritten *int64
}

Conn wraps net.Conn and keeps track of sent and received data size

func (*Conn) Read ¶

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

func (*Conn) Write ¶

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

type Dialer ¶

type Dialer struct {
	net.Dialer

	Resolver         Resolver
	Blacklist        []*lib.IPNet
	BlockedHostnames *types.HostnameTrie
	Hosts            *types.Hosts

	BytesRead    int64
	BytesWritten int64
}

Dialer wraps net.Dialer and provides k6 specific functionality - tracing, blacklists and DNS cache and aliases.

func NewDialer ¶

func NewDialer(dialer net.Dialer, resolver Resolver) *Dialer

NewDialer constructs a new Dialer with the given DNS resolver.

func (*Dialer) DialContext ¶

func (d *Dialer) DialContext(ctx context.Context, proto, addr string) (net.Conn, error)

DialContext wraps the net.Dialer.DialContext and handles the k6 specifics

func (*Dialer) IOSamples ¶

func (d *Dialer) IOSamples(
	sampleTime time.Time, ctm metrics.TagsAndMeta, builtinMetrics *metrics.BuiltinMetrics,
) metrics.SampleContainer

IOSamples returns samples for data send and received since it last call and zeros out. It uses the provided time as the sample time and tags and builtinMetrics to build the samples.

func (*Dialer) ResolveAddr ¶

func (d *Dialer) ResolveAddr(addr string) (net.IP, int, error)

ResolveAddr looks up the IP address for the given host and optionally port. The address is expected in the form "host:port" or just "host". It returns the resolved IP, and an error if any.

type MultiResolver ¶

type MultiResolver func(host string) ([]net.IP, error)

MultiResolver returns all IP addresses for the given host.

type OCSP ¶

type OCSP struct {
	ProducedAt       int64  `json:"produced_at"`
	ThisUpdate       int64  `json:"this_update"`
	NextUpdate       int64  `json:"next_update"`
	RevokedAt        int64  `json:"revoked_at"`
	RevocationReason string `json:"revocation_reason"`
	Status           string `json:"status"`
}

OCSP keeps Online Certificate Status Protocol (OCSP) details

type Resolver ¶

type Resolver interface {
	LookupIP(host string) (net.IP, error)
}

Resolver is an interface that returns DNS information about a given host.

func NewResolver ¶

func NewResolver(
	actRes MultiResolver, ttl time.Duration, sel types.DNSSelect, pol types.DNSPolicy,
) Resolver

NewResolver returns a new DNS resolver. If ttl is not 0, responses will be cached per host for the specified period. The IP returned from LookupIP() will be selected based on the given sel and pol values.

type TLSInfo ¶

type TLSInfo struct {
	Version     string
	CipherSuite string
}

TLSInfo keeps TLS details

Source Files ¶

View all Source files

Directories ¶

Path	Synopsis
httpext Package httpext provides extensions to the standard net/http package	Package httpext provides extensions to the standard net/http package

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