NewLogSource creates a new log source.

push adds an event to the RingStore buffer This function is not thread-safe and should only be called internally by the RingStore routine or during te

NewMockSender initiates the aggregator and returns a functional mocked Sender for testing

ReadAll batches from eBPF (concurrently) and execute the given callback function for each batch

Create creates a new flare locally and returns the path to the flare file.

NewCounter creates a Counter with default options for telemetry purpose. Current implementation used: Prometheus Counter

Run() implements all application logic and is run when the service status is SERVICE_RUNNING. The provided context is cancellable. Run() must monitor

Since records the duration for the given metric name as *time passed since start*. If name does not exist, as defined by NewSet, it creates it.

opens a browser window at the specified URL

New returns a configuration with the default values.

Add adds the value to the Gauge value.

GetFieldValue returns the value of the given Field

Get gets the value of the gauge.

Get gets the conntrack record for a connection. Similar to Exists, but returns the full connection information.

Remove deletes the entries associated with the given keys from the cache.

Exit a process

Errorf is used to print an error

Error logs at the error level and returns an error containing the formated log message

Is returns whether two ControllerNotFoundError targets the same controller

Bytes returns a byte slice representing the Address. You may want to consider using `WriteTo` instead to avoid allocations

TestOneShotSubcommand is a helper for testing commands implemented with fxutil.OneShot. It takes an array of commands, and attaches all to a temporar

GetDelta returns a Delta object for the given client when provided the latest set of active connections

Handle returns the underlying handle returned by EvtOpenSession

IsInRangeCloseOpen returns whether the kernel version is between the begin version (included) and the end version (excluded)

OneShot runs the given function in an fx.App using the supplied options. The function's arguments are supplied by Fx and can be any provided type. The

call calls the underlying function. The fx.App must have already supplied the arguments at this time. If the delayed function has no return value, t

Int implements pprof Flag interface

VersionCode returns a Version computed from the individual parts of a x.x.x version

IsZero reports whether a is its zero value

Each type method accepts an index argument that determines which element in the array to return.

nolint:deadcode,unused

Execute executes a command and returns its output.

General -- Run runs all demultiplexer parts

LocalAddr returns the local network address of the listener.

Delete deletes a set of keys from the database and invokes the specified callback for each key before committing the transaction.

Warn logs at the warn level and returns an error containing the formated log message

NewValue initializes a Value[T] with the given value of type T and no error.

API implemented by viper.Viper

CoreV1 retrieves the CoreV1Client

NewMessage constructs an unstructured message with content, status, origin and the ingestion timestamp.

nolint:deadcode,unused

CompositeTagsFromSlice creates a new CompositeTags from a slice

Decode decodes an activity dump from a file

UpdateFieldValues updates the field values

AddLow adds a new low cardinality tag to the list, or replace if already exists. It will skip empty values/names, so it's safe to use without verifyin

ResetMemoryStats resets allocations and frees counters to zero

AssertMemoryUsage makes sure the allocations and frees match

SetupAcceptAll sets mock expectations to accept any call in the Sender interface