Package atomic provides common primitive types with atomic accessors.

Package dtfmt provides time formatter support with pattern syntax mostly similar to joda DateTimeFormat.

Package flowhash provides the ability to hash flows.

Package schema contains helper utilities to parse, convert, rename, and reorganize data from the format returned by the various monitored systems to the data model used by Metricbeat.

Package streambuf provides helpers for buffering multiple packet payloads and some general parsing functions.

AddTags appends a tag to the tags field of ms.

AddTagsWithKey appends a tag to the key field of ms.

ConcatFields concatenates two Fields lists into a new list.

ConfigOverwriteFlag defines a new flag updating a setting in an Config object.

ConvertToGenericEvent normalizes the types contained in the given MapStr.

DeDot a string by replacing all .

DeDotJSON replaces in keys all .

DumpInCSVFormat takes a set of fields and rows and returns a string representing the CSV representation for the fields and rows.

Recursively generates the correct key based on the dots The mapping requires "properties" between each layer.

Ipv4_Ntoa transforms an IP4 address in it's dotted notation.

IsLoopback check if a particular IP notation corresponds to a loopback interface.

IsStrictPerms returns true if strict permission checking on config files is enabled.

LocalIPAddrs finds the IP addresses of the hosts on which the shipper currently runs on.

LocalIPAddrsAsStrings finds the IP addresses of the hosts on which the shipper currently runs on and returns them as an array of strings.

MakeEndpointPair returns source and destination endpoints from a TCP or IP tuple and a command-line tuple.

MakeURL creates the url based on the url configuration.

MapStrUnion creates a new MapStr containing the union of the key-value pairs of the two maps.

MergeFields merges the top-level keys and values in each source map (it does not perform a deep merge).

MergeFieldsDeep recursively merges the keys and values from `from` into `target`, either into ms itself (if underRoot == true) or into ms["fields"] (if underRoot == false).

MustNewConfigFrom creates a new Config object from the given input.

MustNewVersion creates a version from the given version string.

MustParseTime is a convenience equivalent of the ParseTime function that panics in case of errors.

NewCache creates and returns a new Cache.

NewCacheWithRemovalListener creates and returns a new Cache and register a RemovalListener callback function.

NewConfigFrom creates a new Config object from the given input.

NewMapStrPointer initializes and returns a pointer to the given MapStr.

NewSettingsFlag creates a new SettingsFlag instance, not registered with any FlagSet.

NewStringsFlag creates a new, but unregistered StringsFlag instance.

NewVersion expects a string in the format: major.minor.bugfix(-meta).

OverwriteConfigOpts allow to change the globally set config option.

ParseTime parses a time in the TsLayout format.

RandomBytes return a slice of random bytes of the defined length.

ReadString extracts the first null terminated string from a slice of bytes.

RemoveChars takes a string candidate and a string of chars to remove from the candidate.

Round rounds the given float64 value and ensures that it has a maximum of "precision" decimal places.

SettingFlag defines a setting flag, name and it's usage.

SettingVarFlag defines a setting flag, name and it's usage.

StringArrFlag creates and registers a new StringsFlag with the given FlagSet.

StringArrVarFlag creates and registers a new StringsFlag with the given FlagSet.

TryToInt tries to coerce the given interface to an int.

standardized status values.

DefaultDecimalPlacesCount is the default number of decimal places.

standardized status values.

Event metadata constants.

standardized status values.

standardized status values.

Event metadata constants.

TsLayout is the layout to be used in the timestamp marshaling/unmarshaling everywhere.

ErrKeyNotFound indicates that the specified key was not found.

Cache is a semi-persistent mapping of keys to values.

CmdlineTuple contains the source and destination process names, as found by the proc module.

ConfigNamespace storing at most one configuration section by name and sub-section.

Endpoint represents an endpoint in the communication.

EventMetadata contains fields and tags that can be added to an event via configuration.

MapStrPointer stores a pointer to atomically get/set a MapStr object This should give faster access for use cases with lots of reads and a few changes.

ObjectTypeCfg defines type and configuration of object attributes.

StringsFlag collects multiple usages of the same flag into an array of strings.

Key type used in the cache.

Value type held in the cache.

Config object to store hierarchical configurations into.

MapStr is a map[string]interface{} wrapper with utility methods for common map operations like converting to JSON.

NetString store the byte length of the data that follows, making it easier to unambiguously pass text and byte data between programs that could be sensitive to values that could be interpreted as delimiters or terminators (such as a null character).

RemovalListener is the callback function type that can be registered with the cache to receive notification of the removal of expired elements.

SettingsFlag captures key/values pairs into an Config object.

Time is an abstraction for the time.Time type.