minipipeline

package

Go to main page

Versions in this module

v3

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

Changes in this version

+ const IPAddressOriginDNS

+ const IPAddressOriginTH

+ func NormalizeDNSLookupResults(values []*model.ArchivalDNSLookupResult)

+ func NormalizeHTTPRequestResults(values []*model.ArchivalHTTPRequestResult)

+ func NormalizeNetworkEvents(values []*model.ArchivalNetworkEvent)

+ func NormalizeTCPConnectResults(values []*model.ArchivalTCPConnectResult)

+ func NormalizeTLSHandshakeResults(values []*model.ArchivalTLSOrQUICHandshakeResult)

+ func SortDNSLookupResults(inputs []*model.ArchivalDNSLookupResult) (outputs []*model.ArchivalDNSLookupResult)

+ func SortNetworkEvents(inputs []*model.ArchivalNetworkEvent) (outputs []*model.ArchivalNetworkEvent)

+ func SortTCPConnectResults(inputs []*model.ArchivalTCPConnectResult) (outputs []*model.ArchivalTCPConnectResult)

+ func SortTLSHandshakeResults(inputs []*model.ArchivalTLSOrQUICHandshakeResult) (outputs []*model.ArchivalTLSOrQUICHandshakeResult)

type Set

+ func (sx Set[T]) String() string

type WebAnalysis

+ ControlExpectations optional.Value[*WebObservationsControlExpectations]

+ DNSLookupSuccess Set[int64]

+ DNSLookupSuccessWithBogonAddresses Set[int64]

+ DNSLookupUnexplainedFailure Set[int64]

+ HTTPRoundTripUnexplainedFailure Set[int64]

+ TCPConnectExpectedFailure Set[int64]

+ TLSHandshakeExpectedFailure Set[int64]

+ func AnalyzeWebObservationsWithLinearAnalysis(lookupper model.GeoIPASNLookupper, container *WebObservationsContainer) *WebAnalysis

+ func AnalyzeWebObservationsWithoutLinearAnalysis(lookupper model.GeoIPASNLookupper, container *WebObservationsContainer) *WebAnalysis

type WebObservation

+ IPAddressOrigin optional.Value[string]

type WebObservationsContainer

+ ControlExpectations optional.Value[*WebObservationsControlExpectations]

+ type WebObservationsControlExpectations struct

+ DNSAddresses Set[string]

+ FinalResponseFailure optional.Value[string]

v3.21.0-alpha

Mar 25, 2024

v3.20.1

Dec 21, 2023

v3.20.0

Dec 13, 2023

Changes in this version

+ const WebObservationTypeDNSLookup

+ const WebObservationTypeHTTPRoundTrip

+ const WebObservationTypeTCPConnect

+ const WebObservationTypeTLSHandshake

+ var ErrNoTestKeys = errors.New("minipipeline: no test keys")

+ func ComputeHTTPDiffBodyProportionFactor(measurement, control int64) float64

+ func ComputeHTTPDiffStatusCodeMatch(measurement, control int64) optional.Value[bool]

+ func ComputeHTTPDiffTitleDifferentLongWords(measurement, control string) map[string]bool

+ func ComputeHTTPDiffUncommonHeadersIntersection(measurement, control map[string]bool) map[string]bool

+ type Set struct

+ func DNSDiffFindCommonASNsIntersection(measurement, control Set[string]) Set[int64]

+ func DNSDiffFindCommonIPAddressIntersection(measurement, control Set[string]) Set[string]

+ func NewSet[T ~string | ~int64](keys ...T) Set[T]

+ func (sx *Set[T]) Add(keys ...T)

+ func (sx *Set[T]) Contains(key T) bool

+ func (sx *Set[T]) UnmarshalJSON(data []byte) error

+ func (sx Set[T]) Keys() []T

+ func (sx Set[T]) Len() int

+ func (sx Set[T]) MarshalJSON() ([]byte, error)

+ func (sx Set[T]) Remove(keys ...T)

+ type WebAnalysis struct

+ DNSExperimentFailure optional.Value[string]

+ DNSLookupExpectedFailure Set[int64]

+ DNSLookupExpectedSuccess Set[int64]

+ DNSLookupSuccessWithInvalidAddresses Set[int64]

+ DNSLookupSuccessWithInvalidAddressesClassic Set[int64]

+ DNSLookupSuccessWithValidAddress Set[int64]

+ DNSLookupSuccessWithValidAddressClassic Set[int64]

+ DNSLookupUnexpectedFailure Set[int64]

+ HTTPFinalResponseDiffBodyProportionFactor optional.Value[float64]

+ HTTPFinalResponseDiffStatusCodeMatch optional.Value[bool]

+ HTTPFinalResponseDiffTitleDifferentLongWords optional.Value[map[string]bool]

+ HTTPFinalResponseDiffUncommonHeadersIntersection optional.Value[map[string]bool]

+ HTTPFinalResponseSuccessTCPWithControl optional.Value[int64]

+ HTTPFinalResponseSuccessTCPWithoutControl optional.Value[int64]

+ HTTPFinalResponseSuccessTLSWithControl optional.Value[int64]

+ HTTPFinalResponseSuccessTLSWithoutControl optional.Value[int64]

+ HTTPRoundTripUnexpectedFailure Set[int64]

+ Linear []*WebObservation

+ TCPConnectUnexpectedFailure Set[int64]

+ TCPConnectUnexpectedFailureDuringConnectivityCheck Set[int64]

+ TCPConnectUnexpectedFailureDuringWebFetch Set[int64]

+ TCPConnectUnexplainedFailure Set[int64]

+ TCPConnectUnexplainedFailureDuringConnectivityCheck Set[int64]

+ TCPConnectUnexplainedFailureDuringWebFetch Set[int64]

+ TLSHandshakeUnexpectedFailure Set[int64]

+ TLSHandshakeUnexpectedFailureDuringConnectivityCheck Set[int64]

+ TLSHandshakeUnexpectedFailureDuringWebFetch Set[int64]

+ TLSHandshakeUnexplainedFailure Set[int64]

+ TLSHandshakeUnexplainedFailureDuringConnectivityCheck Set[int64]

+ TLSHandshakeUnexplainedFailureDuringWebFetch Set[int64]

+ func AnalyzeWebObservations(container *WebObservationsContainer) *WebAnalysis

+ type WebMeasurement struct

+ Input string

+ TestKeys optional.Value[*WebMeasurementTestKeys]

+ type WebMeasurementTestKeys struct

+ Control optional.Value[*model.THResponse]

+ NetworkEvents []*model.ArchivalNetworkEvent

+ QUICHandshakes []*model.ArchivalTLSOrQUICHandshakeResult

+ Queries []*model.ArchivalDNSLookupResult

+ Requests []*model.ArchivalHTTPRequestResult

+ TCPConnect []*model.ArchivalTCPConnectResult

+ TLSHandshakes []*model.ArchivalTLSOrQUICHandshakeResult

+ XControlRequest optional.Value[*model.THRequest]

+ type WebObservation struct

+ ControlDNSDomain optional.Value[string]

+ ControlDNSLookupFailure optional.Value[string]

+ ControlDNSResolvedAddrs optional.Value[Set[string]]

+ ControlHTTPFailure optional.Value[string]

+ ControlHTTPResponseBodyLength optional.Value[int64]

+ ControlHTTPResponseHeadersKeys optional.Value[map[string]bool]

+ ControlHTTPResponseStatusCode optional.Value[int64]

+ ControlHTTPResponseTitle optional.Value[string]

+ ControlTCPConnectFailure optional.Value[string]

+ ControlTLSHandshakeFailure optional.Value[string]

+ DNSDomain optional.Value[string]

+ DNSEngine optional.Value[string]

+ DNSLookupFailure optional.Value[string]

+ DNSQueryType optional.Value[string]

+ DNSResolvedAddrs optional.Value[Set[string]]

+ DNSTransactionID optional.Value[int64]

+ EndpointAddress optional.Value[string]

+ EndpointPort optional.Value[string]

+ EndpointProto optional.Value[string]

+ EndpointTransactionID optional.Value[int64]

+ Failure optional.Value[string]

+ HTTPFailure optional.Value[string]

+ HTTPRequestURL optional.Value[string]

+ HTTPResponseBodyIsTruncated optional.Value[bool]

+ HTTPResponseBodyLength optional.Value[int64]

+ HTTPResponseHeadersKeys optional.Value[map[string]bool]

+ HTTPResponseIsFinal optional.Value[bool]

+ HTTPResponseLocation optional.Value[string]

+ HTTPResponseStatusCode optional.Value[int64]

+ HTTPResponseTitle optional.Value[string]

+ IPAddress optional.Value[string]

+ IPAddressASN optional.Value[int64]

+ IPAddressBogon optional.Value[bool]

+ TCPConnectFailure optional.Value[string]

+ TLSHandshakeFailure optional.Value[string]

+ TLSServerName optional.Value[string]

+ TagDepth optional.Value[int64]

+ TagFetchBody optional.Value[bool]

+ TransactionID int64

+ Type WebObservationType

+ func NewLinearWebAnalysis(input *WebObservationsContainer) (output []*WebObservation)

+ type WebObservationType int64

+ type WebObservationsContainer struct

+ DNSLookupFailures []*WebObservation

+ DNSLookupSuccesses []*WebObservation

+ KnownTCPEndpoints map[int64]*WebObservation

+ func ClassicFilter(input *WebObservationsContainer) (output *WebObservationsContainer)

+ func IngestWebMeasurement(meas *WebMeasurement) (*WebObservationsContainer, error)

+ func NewWebObservationsContainer() *WebObservationsContainer

+ func (c *WebObservationsContainer) IngestControlMessages(req *model.THRequest, resp *model.THResponse) error

+ func (c *WebObservationsContainer) IngestDNSLookupEvents(evs ...*model.ArchivalDNSLookupResult)

+ func (c *WebObservationsContainer) IngestHTTPRoundTripEvents(evs ...*model.ArchivalHTTPRequestResult)

+ func (c *WebObservationsContainer) IngestTCPConnectEvents(evs ...*model.ArchivalTCPConnectResult)

+ func (c *WebObservationsContainer) IngestTLSHandshakeEvents(evs ...*model.ArchivalTLSOrQUICHandshakeResult)

v3.20.0-alpha

Dec 13, 2023

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