Events returns a channel of Event objects (wrapping netlink messages) which receives all new connections added to the Conntrack table.

FetchString is a convenience wrapper around Fetch that returns a string

NewFileProvider returns a new Provider

NewNotFound returns a new error which indicates that the object passed in parameter was not found.

NewOptionsWithResolvers creates new Options with default values

OnInvokeStart is the hook triggered when an invocation has started

PatternMatches matches a pattern against a string

RetrieveUnifiedServiceTags for cluster level resources the `env` is handled special because it being a host level tag.

ToLowHigh converts an address into a pair of uint64 numbers

TracerPayloadWithChunk wraps `chunk` with pb.TraceChunk

TruncateUTF8 truncates the given string to make sure it uses less than limit bytes. If the last character is an utf8 character that would be splitten,

V6Address creates an Address using the uint128 representation of an v6 IP

nolint:deadcode,unused

extractMetadata extracts standard metadata into the protobuf model.

podString returns a string that helps identify the pod

Cancel cancels the check. Cancel is called when the check is unscheduled: - unlike Stop, it is called even if the check is not running when it's unsch

Configure configures the snmp checks

GetKubeUtil returns an instance of KubeUtil.

GetMultipleEndpoints returns the api keys per domain specified in the main agent config

GetTagValue returns the value of the given tag in the given list

NewBytesPayloadsWithoutMetaData creates BytesPayloads without metadata.

NewConfig returns a new Config object.

NewConnectionKey generates a new ConnectionKey

NewOrigin returns a new Origin

Print implements gosnmp.LoggerInterface#Print

SetStr adds an OctetString PDU with the given OID and value

ToFloat64 converts value to float64

add adds MapResult to cache with metric name as key

defaultMetricTransformers returns a map that contains KSM metric names and their corresponding transformer functions These metrics require more than a

Compute the increment between two iostats values, taking into account they can overflow

Utility to make a request to the Gitlab API. See RemoteAPI#request. Adds "PRIVATE-TOKEN: {self.api_token}" to the headers to

netNS adds `network_config` namespace to configuration key

process aggregates multiple lines to form a full multiline message, it stops when a line matches with the new content regular expression. It also make

nolint:deadcode,unused

Callback returns a *testing* callback that can be used as an argument to `FileRegistry.Register()` Note that this method should be called only once.

Clear removes all entries from the cache and closes it.

ComputeTopLevel updates all the spans top-level attribute. A span is considered top-level if: - it's a root span - OR its parent is unknown (other pa

Disconnect closes the current SSH connection.

FreeTCPPort returns a free TCP port. Upon encountering an error, it uses t to fail the test and report it.

Functions relating to check run stats (`checkStats`) GetCheckStats returns the check stats map

GetClusterAgentClient returns or init the DCAClient

GetRegisteredProcesses returns a set with all PIDs currently being tracked by the `FileRegistry`

GetWorkerCount is used to get the value of 'Workers'->'Count' expvar

InitAndStartAgentDemultiplexer creates a new Demultiplexer and runs what's necessary in goroutines. As of today, only the embedded BufferedAggregator

IsErrWillRetry checks whether an `error` is a Retrier temporary fail

MarshalMsg implements msgp.Marshaler

NewClient creates a new fake intake client fakeIntakeURL: the host of the fake Datadog intake server

NewError returns a new ErrAstToEval error

NewFilter creates a new filter for subscribing to workloadmeta events. Only events for entities with one of the given kinds will be delivered. If ki

NewHashingTagsAccumulator returns a new empty HashingTagsAccumulator

NewMockStore returns a MockStore

NewTailer returns a new tailer.

NewTypeError returns a new ErrAstToEval error when an invalid type was used

NewValueFrom returns a Value[T] from a value and an error. If the error is non-nil then it represents this error, otherwise it represents the value.

Process handles an incoming chunk of data. It will call outputFn for any recognized frames. Partial frames are maintained between calls to Process.

RunAgent starts an agent instance using the given YAML configuration.

SetupConf generates and returns a new configuration

V4Address creates an Address using the uint32 representation of an v4 IP

WithArgs sets the Agent arguments

WithTelemetryWrapper returns a http handler function that emits telemetry.

Helper function for reading test file