Package atomic provides common primitive types with atomic accessors.

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

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.

ConvertToGenericEvent normalizes the types contained in the given MapStr.

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

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.

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).

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.

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

ParseTime parses a time in the TsLayout format.

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

standardized status values.

standardized status values.

Event metadata constants.

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.

A Backoff waits on errors with exponential backoff (limited by maximum backoff).

BeatInfo stores a beats instance meta data.

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

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.

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.

Time is an abstraction for the time.Time type.