Stop the event subscription and free resources. The subscription can be started again after it is stopped. Stop will automatically close any outstand

Tick represents one or more events passing through the circuit breaker.

UnmarshalEasyJSON supports easyjson.Unmarshaler interface

Expects controller to exist, see controllerMounted

sanitize config parameters

AssertSerieEqual evaluate if two are equal.

Build initializes and registers all enabled stores. Returns metric writers.

Context mocks base method.

Generate returns the ContextKey hash for the given parameters. tagsBuf is re-arranged in place and truncated to only contain unique tags.

GetEnvVars returns a list of the env vars that the config supports. These have had the EnvPrefix applied, as well as the EnvKeyReplacer.

GetNewState returns the current state if the given version is different from the local version.

GetScalarAsString get scalar value as string

This function gets a snapshot of the current service mapping without modifying it.

GetTags returns the tagset of the currently executing lambda function

InitAndStartAgentDemultiplexerForTest initializes an aggregator for tests.

IsOracleUEKKernel returns whether the kernel is an oracle uek kernel

IsSLESKernel returns whether the kernel is a sles kernel

MakeContextMetrics returns a new ContextMetrics

MarshalMsg implements msgp.Marshaler

NewAgent returns a new Agent object, ready to be started. It takes a context which may be cancelled in order to gracefully stop the agent.

NewBufferedAggregator instantiates a BufferedAggregator

NewClient creates a new uptane client

NewOpUnknownError returns a new ErrAstToEval error when an unknown operator was used

NewReplaceableSource returns a new ReplaceableSource

NewResolver returns a new process resolver

NewResolverOpts returns a new set of process resolver options

NewWeightedQueue returns a new WeightedQueue with the given maximum size & weight

OpenSCManager connects to SCM https://learn.microsoft.com/en-us/windows/win32/api/winsvc/nf-winsvc-openscmanagerw

RegisterMetadataAvail adds a MetadataAvailDiagnose

SetMessage sets a message with a unique key

SetMeta sets the metadata at key to the val on the span s.

Valid is a validation check required for InputSpec to be executed.

processMessage performs logic about metrics and tags on the message

the following range functions use the index of the current `GuessWhat` value, to select only the ranges of fields guessed beforehand, offset against t

AddHigh adds a new high cardinality tag to the map, or replace if already exists. It will skip empty values/names, so it's safe to use without verifyi

Samples API -- AggregateSample sends a MetricSample to the DogStatsD time sampler. In sharded implementation, the metric is sent to the first time sam

Close closes the cache.

CreateSources creates sources

Enter schedules a `Check`s for execution accordingly to the `Check.Interval()` value. If the interval is 0, the check is supposed to run only once.

Expire returns a list of entities (containers and pods) that are not listed in the podlist anymore. It must be called immediately after a PullChanges.

Gauge calls Gauge on the global Client, if set.

GetIPCAddress returns the IPC address or an error if the address is not local

GetResourcesNamespace is used to fetch the namespace of the resources used by the Kubernetes check (e.g. Leader Election, Event collection).

GetStackManager returns a stack manager, initialising on first call

IsEmpty returns true if the buffer is empty.

LogOnPanic catches panics and logs them on the fly. It also flushes the log file, ensuring the message appears. Then it propagates the panic so that t

NewDefaultDataScrubber creates a DataScrubber with the default behavior: enabled and matching the default sensitive words

NewDefaultEvent returns a new event using the default field handlers

NewParams creates a new instance of Params

NewRunningChecksTracker is a contructor for a RunningChecksTracker