dslengine

Documentation

Index

• type MinimalRuntime
  • func NewMinimalRuntime(logger model.Logger, zeroTime time.Time, options ...Option) *MinimalRuntime
  • func (p *MinimalRuntime) ActiveConnections() *dslvm.Semaphore
  • func (p *MinimalRuntime) ActiveDNSLookups() *dslvm.Semaphore
  • func (p *MinimalRuntime) IDGenerator() *atomic.Int64
  • func (p *MinimalRuntime) Logger() model.Logger
  • func (p *MinimalRuntime) NewTrace(index int64, zeroTime time.Time, tags ...string) dslvm.Trace
  • func (p *MinimalRuntime) Observations() *dslvm.Observations
  • func (p *MinimalRuntime) SaveObservations(obs ...*dslvm.Observations)
  • func (p *MinimalRuntime) ZeroTime() time.Time
• type Option
  • func OptionMaxActiveConns(count int) Option
  • func OptionMaxActiveDNSLookups(count int) Option
  • func OptionMeasuringNetwork(netx model.MeasuringNetwork) Option
• type RuntimeMeasurexLite
  • func NewRuntimeMeasurexLite(logger model.Logger, zeroTime time.Time, options ...Option) *RuntimeMeasurexLite
  • func (p *RuntimeMeasurexLite) NewTrace(index int64, zeroTime time.Time, tags ...string) dslvm.Trace

Types

type MinimalRuntime

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

MinimalRuntime is a minimal [Runtime] implementation.

func NewMinimalRuntime

func NewMinimalRuntime(logger model.Logger, zeroTime time.Time, options ...Option) *MinimalRuntime

NewMinimalRuntime creates a minimal [Runtime] implementation.

This [Runtime] implementation does not collect any [*Observations].

func (*MinimalRuntime) ActiveConnections

func (p *MinimalRuntime) ActiveConnections() *dslvm.Semaphore

ActiveConnections implements [Runtime].

func (*MinimalRuntime) ActiveDNSLookups

func (p *MinimalRuntime) ActiveDNSLookups() *dslvm.Semaphore

ActiveDNSLookups implements [Runtime].

func (*MinimalRuntime) IDGenerator

func (p *MinimalRuntime) IDGenerator() *atomic.Int64

IDGenerator implements Runtime.

func (*MinimalRuntime) Logger

func (p *MinimalRuntime) Logger() model.Logger

Logger implements Runtime.

func (*MinimalRuntime) NewTrace

func (p *MinimalRuntime) NewTrace(index int64, zeroTime time.Time, tags ...string) dslvm.Trace

NewTrace implements Runtime.

func (*MinimalRuntime) Observations

func (p *MinimalRuntime) Observations() *dslvm.Observations

Observations implements Runtime.

func (*MinimalRuntime) SaveObservations

func (p *MinimalRuntime) SaveObservations(obs ...*dslvm.Observations)

SaveObservations implements Runtime.

func (*MinimalRuntime) ZeroTime

func (p *MinimalRuntime) ZeroTime() time.Time

ZeroTime implements Runtime.

type Option

type Option func(opts *optionsValues)

Option is an option for configuring a runtime.

func OptionMaxActiveConns

func OptionMaxActiveConns(count int) Option

OptionMaxActiveConns configures the maximum number of endpoint measurements that we may run in parallel. If the provided value is <= 1, we set a maximum of 1 measurements in parallel.

func OptionMaxActiveDNSLookups

func OptionMaxActiveDNSLookups(count int) Option

OptionMaxActiveDNSLookups configures the maximum number of DNS lookup measurements that we may run in parallel. If the provided value is <= 1, we set a maximum of 1 measurements in parallel.

func OptionMeasuringNetwork

func OptionMeasuringNetwork(netx model.MeasuringNetwork) Option

OptionMeasuringNetwork configures the model.MeasuringNetwork to use.

type RuntimeMeasurexLite

type RuntimeMeasurexLite struct {
	*MinimalRuntime
	// contains filtered or unexported fields
}

RuntimeMeasurexLite uses measurexlite to collect [*Observations.]

func NewRuntimeMeasurexLite

func NewRuntimeMeasurexLite(logger model.Logger, zeroTime time.Time, options ...Option) *RuntimeMeasurexLite

NewRuntimeMeasurexLite creates a [Runtime] using measurexlite to collect [*Observations].

func (*RuntimeMeasurexLite) NewTrace

func (p *RuntimeMeasurexLite) NewTrace(index int64, zeroTime time.Time, tags ...string) dslvm.Trace

NewTrace implements Runtime.