newTestServer returns a new, started HTTP test server. Its URL is available as a field. To control its responses, send it payloads created by expectRe

scan checks all the files we're expected to tail, compares them to the currently tailed files, and triggers the required updates. For instance, when a

setMetaOTLP sets the k/v OTLP attribute pair as a tag on span s.

Helper functions to run tests and benchmarks for context resolver, time and check samplers.

AddMessage adds a new dogstatsd message to the buffer

ConcatenateTags is a fast way to concatenate multiple tag arrays in a single one.

Debug logs the given arguments, separated by spaces, at the debug level

Get returns the status of the logs-agent computed on the fly.

GetInferredSpan returns the generated inferred span of the currently executing lambda function

HandleUnary performs a gRPC unary call to SayHello RPC of the greeter service.

Hash calculates the cumulative XOR of all unique tags in the builder. As a side-effect, it sorts and deduplicates the hashes contained in the builder

IsCheckTelemetryEnabled returns if we want telemetry for the given check. Returns true if a * is present in the telemetry.checks list.

KillAgent kills any agent that was started by this runner.

MatchTagsContains is a mock.argumentMatcher builder to be used in asserts. It allows to check if tags are emitted, ignoring unexpected ones and order.

NewConfig creates a config with ebpf-related settings

NewCounter returns a new metric of type `Counter`

NewServer creates a new fake intake server and starts it on localhost:port options accept WithPort and WithReadyChan. Call Server.Start() to start the

NewTestServerWithOptions creates a new test server with concurrency and response control

OpenService opens a handle for serviceName https://learn.microsoft.com/en-us/windows/win32/api/winsvc/nf-winsvc-openservicew

Push sends an event to be stored. An optional channel can be passed to acknowledge when the event is successfully written

RandomSpan generates a wide-variety of spans, useful to test robustness & performance

Extra interface to ease working with MockStore SetEntity generates a Set event

SetWorkerStats is used to add individual worker stats or update them if they were already present

SetupMock configures DMI variables with provided values

WithNS executes the given function in the given network namespace, and then switches back to the previous namespace.

WithProcFSRoot confiugres the procfs directory that the probe reads from

Benchmark

Return a bool value if all the elements of expected are inside the actual array

matchAll matches when all of the given functions match

processNodeStatus keeps the node's status in the store, and returns true if the last configuration change matches the one sent by the node agent.

requireNotLocked tries to lock a clusterStore to make sure it is not left locked after an operation

shouldDrop returns true if the entry should be dropped, returns false otherwise.

AsJSON takes a structure and returns a marshal-able object representing the fields of the struct, the lists of errors for fields for which the collect

Commands returns the config commands

Compute returns four string arrays in the format "tag:value" - low cardinality - orchestrator cardinality - high cardinality - standard tags

The number of values

Criticalf logs with format at the critical level and returns an error containing the formated log message

FastDigest returns an hash value representing the data stored in this configuration. Difference with Digest is that FastDigest does not consider that

FilesToTail returns all the Files matching paths in sources, it cannot return more than filesLimit Files. Files are collected according to the filePro

GetExecutionInfo returns the trace and payload information of the currently executing lambda function

get the hostname

GetLogLevel returns a seelog native representation of the current log level

GetVariableMetadata returns VariableMetadata for a given variableOID and trapOID. The trapOID should not be needed in theory but the Datadog Agent all

HostCPUCount returns the number of logical CPUs from host

Init bootstraps the CloudService.

Interval returns the interval time for the check

IsAmazonLinuxKernel returns whether the kernel is an amazon linux kernel

Max returns max(s, other)

MockSystemProbe is creating and returning a mock system-probe config

NewFakeTagger returns a new fake Tagger

NewKeyGenerator creates a new key generator

NewListenerConfig parses configuration and returns a built ListenerConfig

NewMockProvider returns a new mockProvider

NewReceiverStats returns a new ReceiverStats

NewStore returns new empty Store.

Run executes the check

RunCheck sends a Check in the execution queue

Stop halts all network data collection.