Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

dslvm

package

Go to main page

Versions in this module

v3

v3.24.0

Nov 25, 2024

v3.24.0-alpha

Nov 25, 2024

v3.23.0

Aug 8, 2024

v3.23.0-alpha

Aug 7, 2024

v3.22.0

May 22, 2024

v3.22.0-alpha

May 14, 2024

v3.21.1

Apr 5, 2024

v3.21.0

Mar 27, 2024

v3.21.0-alpha

Mar 25, 2024

v3.20.1

Dec 21, 2023

v3.20.0

Dec 13, 2023

Changes in this version

+ func Start(ctx context.Context, rtx Runtime, stages ...Stage)

+ func Wait(channels ...<-chan Done)

+ type Closer interface

+ Close func(logger model.Logger) error

+ type DNSLookupUDPStage struct

+ Domain string

+ Output chan<- string

+ Resolver string

+ Tags []string

+ func (sx *DNSLookupUDPStage) Run(ctx context.Context, rtx Runtime)

+ type DedupAddrsStage struct

+ Inputs []<-chan string

+ Output chan<- string

+ func (sx *DedupAddrsStage) Run(ctx context.Context, rtx Runtime)

+ type Done struct

+ type DropStage struct

+ Input <-chan T

+ Output chan Done

+ func (sx *DropStage[T]) Run(ctx context.Context, rtx Runtime)

+ type GetaddrinfoStage struct

+ Domain string

+ Output chan<- string

+ Tags []string

+ func (sx *GetaddrinfoStage) Run(ctx context.Context, rtx Runtime)

+ type HTTPConnection interface

+ AsSingleUseTransport func(logger model.Logger) model.HTTPTransport

+ Network func() string

+ RemoteAddress func() string

+ Scheme func() string

+ TLSNegotiatedProtocol func() string

+ Trace func() Trace

+ type HTTPRoundTripStage struct

+ Accept string

+ AcceptLanguage string

+ Host string

+ Input <-chan T

+ MaxBodySnapshotSize int64

+ Method string

+ Output chan<- Done

+ Referer string

+ URLPath string

+ UserAgent string

+ func (sx *HTTPRoundTripStage[T]) Run(ctx context.Context, rtx Runtime)

+ type MakeEndpointsStage struct

+ Input <-chan string

+ Output chan<- string

+ Port string

+ func (sx *MakeEndpointsStage) Run(ctx context.Context, rtx Runtime)

+ type Observations struct

+ NetworkEvents []*model.ArchivalNetworkEvent

+ QUICHandshakes []*model.ArchivalTLSOrQUICHandshakeResult

+ Queries []*model.ArchivalDNSLookupResult

+ Requests []*model.ArchivalHTTPRequestResult

+ TCPConnect []*model.ArchivalTCPConnectResult

+ TLSHandshakes []*model.ArchivalTLSOrQUICHandshakeResult

+ func NewObservations() *Observations

+ type QUICConnection struct

+ Conn quic.EarlyConnection

+ func (c *QUICConnection) AsSingleUseTransport(logger model.Logger) model.HTTPTransport

+ func (c *QUICConnection) Close(logger model.Logger) error

+ func (c *QUICConnection) Network() string

+ func (c *QUICConnection) RemoteAddress() (addr string)

+ func (c *QUICConnection) Scheme() string

+ func (c *QUICConnection) TLSNegotiatedProtocol() string

+ func (c *QUICConnection) Trace() Trace

+ type QUICHandshakeStage struct

+ Input <-chan string

+ InsecureSkipVerify bool

+ NextProtos []string

+ Output chan<- *QUICConnection

+ RootCAs *x509.CertPool

+ ServerName string

+ Tags []string

+ func (sx *QUICHandshakeStage) Run(ctx context.Context, rtx Runtime)

+ type Runtime interface

+ ActiveConnections func() *Semaphore

+ ActiveDNSLookups func() *Semaphore

+ IDGenerator func() *atomic.Int64

+ Logger func() model.Logger

+ NewTrace func(index int64, zeroTime time.Time, tags ...string) Trace

+ Observations func() *Observations

+ SaveObservations func(obs ...*Observations)

+ ZeroTime func() time.Time

+ type Semaphore struct

+ func NewSemaphore(name string, count int) *Semaphore

+ func (sema *Semaphore) Signal()

+ func (sema *Semaphore) Wait()

+ type Stage interface

+ Run func(ctx context.Context, rtx Runtime)

+ type TCPConnectStage struct

+ Input <-chan string

+ Output chan<- *TCPConnection

+ Tags []string

+ func (sx *TCPConnectStage) Run(ctx context.Context, rtx Runtime)

+ type TCPConnection struct

+ Conn net.Conn

+ func (c *TCPConnection) AsSingleUseTransport(logger model.Logger) model.HTTPTransport

+ func (c *TCPConnection) Close(logger model.Logger) error

+ func (c *TCPConnection) Network() string

+ func (c *TCPConnection) RemoteAddress() (addr string)

+ func (c *TCPConnection) Scheme() string

+ func (c *TCPConnection) TLSNegotiatedProtocol() string

+ func (c *TCPConnection) Trace() Trace

+ type TLSConnection struct

+ Conn model.TLSConn

+ func (c *TLSConnection) AsSingleUseTransport(logger model.Logger) model.HTTPTransport

+ func (c *TLSConnection) Close(logger model.Logger) error

+ func (c *TLSConnection) Network() string

+ func (c *TLSConnection) RemoteAddress() (addr string)

+ func (c *TLSConnection) Scheme() string

+ func (c *TLSConnection) TLSNegotiatedProtocol() string

+ func (c *TLSConnection) Trace() Trace

+ type TLSHandshakeStage struct

+ Input <-chan *TCPConnection

+ InsecureSkipVerify bool

+ NextProtos []string

+ Output chan<- *TLSConnection

+ RootCAs *x509.CertPool

+ ServerName string

+ func (sx *TLSHandshakeStage) Run(ctx context.Context, rtx Runtime)

+ type TakeNStage struct

+ Input <-chan T

+ N int64

+ Output chan<- T

+ func (sx *TakeNStage[T]) Run(ctx context.Context, rtx Runtime)

+ type TeeAddrsStage struct

+ Input <-chan string

+ Outputs []chan<- string

+ func (sx *TeeAddrsStage) Run(ctx context.Context, rtx Runtime)

+ type Trace interface

+ CloneBytesReceivedMap func() (out map[string]int64)

+ DNSLookupsFromRoundTrip func() (out []*model.ArchivalDNSLookupResult)

+ Index func() int64

+ NetworkEvents func() (out []*model.ArchivalNetworkEvent)

+ NewDialerWithoutResolver func(dl model.DebugLogger, wrappers ...model.DialerWrapper) model.Dialer

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

+ NewQUICDialerWithoutResolver func(listener model.UDPListener, dl model.DebugLogger, ...) model.QUICDialer

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

+ NewTLSHandshakerStdlib func(dl model.DebugLogger) model.TLSHandshaker

+ NewUDPListener func() model.UDPListener

+ QUICHandshakes func() (out []*model.ArchivalTLSOrQUICHandshakeResult)

+ TCPConnects func() (out []*model.ArchivalTCPConnectResult)

+ TLSHandshakes func() (out []*model.ArchivalTLSOrQUICHandshakeResult)

+ Tags func() []string

+ TimeSince func(t0 time.Time) time.Duration

+ ZeroTime func() time.Time

v3.20.0-alpha

Dec 13, 2023