Code
Hub
Workspaces
Following
Trending
Connect
MCP
copy
Create free account
hub
/
github.com/DataDog/datadog-agent
/ functions
Functions
32,574 in github.com/DataDog/datadog-agent
⨍
Functions
32,574
◇
Types & classes
5,280
↳
Endpoints
25
↓ 30 callers
Method
With
(fields []zapcore.Field)
pkg/util/log/zap/zapcore.go:39
↓ 30 callers
Function
getClientsIndex
(index, totalCount int)
pkg/network/protocols/grpc/monitor_test.go:79
↓ 30 callers
Method
getWebhookSkeleton
(nameSuffix, path string, operations []admiv1.OperationType, resources []string, namespaceSelector, objectSele
pkg/clusteragent/admission/controllers/webhook/controller_v1.go:281
↓ 30 callers
Function
loadSyscallTester
(t *testing.T, test *testModule, binary string)
pkg/security/tests/syscall_tester.go:23
↓ 30 callers
Method
logAndAdvance
(offset uint64, next GuessWhat)
pkg/network/tracer/offsetguess/tracer.go:1054
↓ 30 callers
Function
path
(allowSymlinkFailure bool)
pkg/util/executable/executable.go:19
↓ 30 callers
Function
procBindEnvAndSetDefault
procBindEnvAndSetDefault is a helper function that generates both "DD_PROCESS_CONFIG_" and "DD_PROCESS_AGENT_" prefixes from a key. We need this helpe
pkg/config/process.go:91
↓ 30 callers
Method
reset
()
pkg/util/cgroups/reporter_for_test.go:28
↓ 30 callers
Method
sample
(metricSample *metrics.MetricSample, timestamp float64)
pkg/aggregator/time_sampler.go:78
↓ 30 callers
Function
serializeOutcome
(retval int64)
pkg/security/serializers/serializers_linux.go:825
↓ 29 callers
Function
BuildAgentKey
BuildAgentKey creates a cache key by joining the constant AgentCachePrefix and path elements passed as arguments. It is to be used by core agent packa
pkg/util/cache/cache.go:35
↓ 29 callers
Method
CallsForPathID
`CallsForPathID` returns the number of callback executions for a given `PathIdentifier`
pkg/network/usm/utils/testutils.go:45
↓ 29 callers
Method
Remove
Remove deletes the connection from tracking state. It does not prevent the connection from re-appearing later, if additional traffic occurs.
pkg/network/tracer/connection/tracer.go:67
↓ 29 callers
Function
RenderStatusTemplate
(w io.Writer, templateName string, stats interface{})
pkg/status/render.go:334
↓ 29 callers
Function
Run
Run runs the tests defined in e2eSuite t is an instance of type [*testing.T]. e2eSuite is a pointer to a structure with a [e2e.Suite] embbeded struc
test/new-e2e/pkg/utils/e2e/e2e.go:408
↓ 29 callers
Function
ShouldLog
ShouldLog returns whether a given log level should be logged by the default logger
pkg/util/log/log.go:857
↓ 29 callers
Function
WithAgentParams
WithAgentParams sets Agent parameters See [agent.Params] for available options for agentParams.
test/new-e2e/pkg/utils/e2e/stack_definition.go:116
↓ 29 callers
Function
getEventFromFile
(filename string)
pkg/serverless/trace/inferredspan/span_enrichment_test.go:1026
↓ 29 callers
Function
smNS
smNS adds `service_monitoring_config` namespace to configuration key
cmd/system-probe/config/ns.go:21
↓ 28 callers
Method
AddFile
AddFile creates a new file in the flare with the content. 'destFile' is a path relative to the flare root (ex: "some/path/to/a/file"). Any necessary
comp/core/flare/types/types.go:46
↓ 28 callers
Method
AddForkEntry
AddForkEntry adds an entry to the local cache and returns the newly created entry
pkg/security/resolvers/process/resolver_linux.go:297
↓ 28 callers
Function
AssertDecodedValue
AssertDecodedValue asserts that either - the field is an error and the decoded string is empty - the field is not an error and the value with its unit
pkg/gohai/utils/test_helpers.go:23
↓ 28 callers
Method
AssertPassedEvent
(f func(t *testing.T, evt *compliance.CheckEvent))
pkg/compliance/tests/helpers.go:184
↓ 28 callers
Method
Enum
()
pkg/proto/pbgo/core/model.pb.go:45
↓ 28 callers
Method
Exec
Exec replace a process
pkg/security/secl/model/process_cache_entry_unix.go:92
↓ 28 callers
Function
GetFlavor
GetFlavor gets the running Agent flavor it MUST NOT be called before the main package is initialized; e.g. in init functions or to initialize package
pkg/util/flavor/flavor.go:46
↓ 28 callers
Method
GetNamespace
()
pkg/proto/pbgo/core/workloadmeta.pb.go:599
↓ 28 callers
Method
Insert
Insert returns an Entry that corresponds to the key. If the key is not in the cache, a new entry is stored in the Store with the tags retrieved from t
pkg/aggregator/internal/tags/store.go:78
↓ 28 callers
Method
LoggerName
LoggerName is the name that appears in the logfile
comp/core/log/params.go:140
↓ 28 callers
Method
Matches
Matches the given filename
pkg/security/secl/compiler/eval/glob.go:119
↓ 28 callers
Function
NewRequestStats
(aggregateByStatusCode bool)
pkg/network/protocols/http/stats.go:135
↓ 28 callers
Function
OTLPConfigFromPorts
OTLPConfigFromPorts creates a test OTLP config map.
comp/otelcol/otlp/internal/testutil/testutil.go:22
↓ 28 callers
Method
Stop
Stop stops the demultiplexer. Resources are released, the instance should not be used after a call to `Stop()`.
pkg/aggregator/demultiplexer.go:32
↓ 28 callers
Method
WithValues
WithValues returns SimpleGauge for this metric with the given tag values.
comp/core/telemetry/gauge.go:23
↓ 28 callers
Function
boolToBinary
(value bool)
pkg/network/usm/ebpf_gotls_helpers.go:228
↓ 28 callers
Function
get_default_build_tags
Build the default list of tags based on the build type and current platform. The container integrations are currently only supported on Linu
tasks/build_tags.py:250
↓ 27 callers
Method
AddReplacer
AddReplacer adds a replacer of the given kind to the scrubber.
pkg/util/scrubber/scrubber.go:92
↓ 27 callers
Function
Agent
Agent returns the Datadog Agent version.
pkg/version/version.go:28
↓ 27 callers
Method
Allow
()
pkg/serverless/appsec/limiter_test.go:300
↓ 27 callers
Method
AppendFieldValue
AppendFieldValue append a FieldValue
pkg/security/secl/compiler/eval/strings.go:45
↓ 27 callers
Method
Delete
Delete deletes the value for the Gauge with the given tags.
comp/core/telemetry/gauge.go:21
↓ 27 callers
Function
FormatGUID
FormatGUID converts a guid structure to a go string
pkg/util/winutil/etw/etw-utils.go:214
↓ 27 callers
Method
GetFloat64
(key string)
pkg/config/model/types.go:33
↓ 27 callers
Method
Info
(v ...interface{})
pkg/trace/log/logger.go:39
↓ 27 callers
Method
Name
Name returns the protocol name.
pkg/network/protocols/protocols.go:56
↓ 27 callers
Function
NewKey
NewKey generates a new Key
pkg/network/protocols/http/stats.go:84
↓ 27 callers
Function
NewSingleDomainResolvers
NewSingleDomainResolvers converts a map of domain/api keys into a map of SingleDomainResolver
pkg/config/resolver/domain_resolver.go:56
↓ 27 callers
Method
NextPipelineChan
()
pkg/logs/pipeline/provider.go:26
↓ 27 callers
Method
Patch
Patch returns the patch number of the version code
pkg/util/kernel/version.go:39
↓ 27 callers
Function
RegisterLiveness
RegisterLiveness registers a component for liveness check with the default 30 seconds timeout, returns a token
pkg/status/health/global.go:22
↓ 27 callers
Method
Start
()
pkg/logs/auditor/auditor.go:56
↓ 27 callers
Method
StopActivityDump
(name, containerid, comm string)
pkg/security/agent/client.go:36
↓ 27 callers
Function
bin_name
Generate platform dependent names for binaries
tasks/utils.py:51
↓ 27 callers
Function
createIntPointer
(value float64)
pkg/util/docker/storage_test.go:19
↓ 27 callers
Method
process
(message *message.Message)
pkg/logs/internal/decoder/auto_multiline_handler.go:120
↓ 27 callers
Function
run
(call string)
rtloader/test/datadog_agent/datadog_agent.go:106
↓ 27 callers
Function
sendMessage
(endpoint, data, method, callback, callbackErr)
cmd/agent/gui/views/private/js/javascript.js:29
↓ 27 callers
Method
start
(stopCh <-chan struct{})
pkg/clusteragent/admission/patch/provider.go:19
↓ 26 callers
Method
Add
Add will record new sourcePort and destPort for a specific sourceAddr and destAddr
comp/netflow/portrollup/portrollup.go:75
↓ 26 callers
Method
Debug
(v ...interface{})
pkg/trace/log/logger.go:37
↓ 26 callers
Method
Get
Get is identical to Wait, except that it returns LogUnknown immediately in any situation where Wait would wait.
pkg/logs/internal/util/containersorpods/containers_or_pods.go:79
↓ 26 callers
Method
GetStatus
()
pkg/security/agent/client.go:40
↓ 26 callers
Method
HandleMessage
HandleMessage buffers a message for diagnostic processing
pkg/logs/diagnostic/message_receiver.go:96
↓ 26 callers
Function
Infof
Infof is used to print an error
pkg/security/seclog/logger.go:234
↓ 26 callers
Function
NewProcessor
NewProcessor creates a new processor for a resource type.
pkg/collector/corechecks/cluster/orchestrator/processors/processor.go:106
↓ 26 callers
Function
RemoveLastAppliedConfigurationAnnotation
RemoveLastAppliedConfigurationAnnotation redacts the whole "kubectl.kubernetes.io/last-applied-configuration" annotation value. As it may contain dupl
pkg/orchestrator/redact/pod.go:19
↓ 26 callers
Function
SetDefaultTagger
SetDefaultTagger sets the global Tagger instance
pkg/tagger/global.go:229
↓ 26 callers
Method
SetInt
SetInt adds an Integer PDU with the given OID and value
pkg/collector/corechecks/snmp/internal/session/fake_session.go:243
↓ 26 callers
Method
Type
Type returns the type of this item
pkg/process/util/api/weighted_queue.go:18
↓ 26 callers
Method
UnmarshalKey
UnmarshalKey Unmarshal a configuration key into a struct
pkg/config/model/types.go:61
↓ 26 callers
Method
WaitForNumberOfSamples
WaitForNumberOfSamples returns the samples received by the demultiplexer. Note that it waits until at least the requested number of samples are availa
pkg/aggregator/demultiplexer_mock.go:94
↓ 26 callers
Method
isExcludedByAnnotation
isExcludedByAnnotation identifies whether a container should be excluded based on the contents of the supplied annotations.
pkg/util/containers/filter.go:381
↓ 26 callers
Method
loadCertFileMeta
https://github.com/kubernetes/kubernetes/blob/ad18954259eae3db51bac2274ed4ca7304b923c4/cmd/kubeadm/test/kubeconfig/util.go#L77-L87
pkg/compliance/k8sconfig/loader.go:298
↓ 26 callers
Function
newMessage
(name, typ, source, service string)
pkg/logs/diagnostic/message_receiver_test.go:216
↓ 26 callers
Method
setCgroupV2File
for cgroup v2 only
pkg/util/cgroups/file_for_test.go:90
↓ 25 callers
Function
CreateGetNextPacket
(oid string, varType gosnmp.Asn1BER, value interface{})
pkg/collector/corechecks/snmp/internal/session/testing_utils.go:73
↓ 25 callers
Method
CurrentState
CurrentState returns all of the information needed to make an update for new configurations.
pkg/remoteconfig/state/repository.go:326
↓ 25 callers
Method
Err
Err returns the first error encountered by the scanner.
pkg/network/netlink/attribute_scanner.go:103
↓ 25 callers
Method
Flush
Flush will flush the contents of the logs to the sinks
comp/core/log/component.go:64
↓ 25 callers
Method
GetColumnAsString
GetColumnAsString get column value as string
pkg/collector/corechecks/snmp/internal/metadata/store.go:49
↓ 25 callers
Method
GetContainerID
(context.Context, http.Header)
pkg/trace/api/container_linux.go:62
↓ 25 callers
Method
GetExtraConfig
GetExtraConfig returns data from configuration
pkg/autodiscovery/listeners/snmp.go:381
↓ 25 callers
Method
GetOrInitializeLanguageset
GetOrInitializeLanguageset initializes the language set of a specific container if it doesn't exist, then it returns it
pkg/languagedetection/util/containerslanguages.go:23
↓ 25 callers
Method
GetResolvers
GetResolvers returns the resolvers of Probe
pkg/security/probe/probe.go:79
↓ 25 callers
Method
ID
ID provides a unique identifier for every check instance
pkg/collector/check/check.go:36
↓ 25 callers
Method
IsCOSKernel
IsCOSKernel returns whether the kernel is a suse kernel
pkg/security/ebpf/kernel/kernel.go:264
↓ 25 callers
Function
NewDefaultForwarder
NewDefaultForwarder returns a new DefaultForwarder. TODO: (components) Remove this method and other exported methods in comp/forwarder.
comp/forwarder/defaultforwarder/default_forwarder.go:217
↓ 25 callers
Function
NewInfoRegistry
NewInfoRegistry creates a new InfoRegistry instance
pkg/logs/internal/status/info.go:120
↓ 25 callers
Function
NewInput
NewInput returns a new decoder input. A decoder input is an unstructured message of raw bytes as the content. Some of the tailers using this are the f
pkg/logs/internal/decoder/decoder.go:28
↓ 25 callers
Function
NewListingError
NewListingError creates an error that wraps the cause of a listing failure.
pkg/collector/corechecks/cluster/orchestrator/collectors/errors.go:23
↓ 25 callers
Method
Poll
Poll retrieves the head of the queue or blocks until an item is available or the WeightedQueue is stopped. Returns the head of the queue and true or
pkg/process/util/api/weighted_queue.go:92
↓ 25 callers
Function
RandomBucket
RandomBucket returns a bucket made from n random spans, useful to run benchmarks and tests
pkg/trace/testutil/stats.go:46
↓ 25 callers
Method
Register
(clientID string)
pkg/process/net/shared.go:15
↓ 25 callers
Method
SetConfigType
(in string)
pkg/config/model/types.go:124
↓ 25 callers
Method
SetFromInvocation
SetFromInvocation sets the execution context based on an invocation
pkg/serverless/executioncontext/executioncontext.go:100
↓ 25 callers
Method
Trim
()
pkg/network/tracer/process_cache.go:165
↓ 25 callers
Method
Unmarshal
([]byte)
pkg/process/encoding/request/encoding.go:33
↓ 25 callers
Function
defaultLabelsMapper
defaultLabelsMapper returns a map that contains the default labels to tag names mapping
pkg/collector/corechecks/cluster/ksm/kubernetes_state_defaults.go:95
↓ 25 callers
Method
error
error records an error and switches to the error state.
pkg/obfuscate/json_scanner.go:541
↓ 25 callers
Method
getWebhookName
()
pkg/clusteragent/admission/controllers/webhook/config.go:51
← previous
next →
501–600 of 32,574, ranked by callers