Package atomic provides common primitive types with atomic accessors.

Package cleanup provides common helpers for common cleanup patterns on defer Use the helpers with `defer`.

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

Package flowhash provides the ability to hash flows.

https://github.com/Shopify/sarama/blob/master/examples/sasl_scram_client/scram_client.go.

Package productorigin defines the Elastic product origin header.

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.

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

DebugString prints a human readable representation of the underlying config using JSON formatting.

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.

GetCapabilities gets the capabilities of this process.

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.

NewCacheWithExpireOnAdd creates and returns a new Cache that does not updated the expiration time when the object is accessed.

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

NewConfigFrom creates a new Config object from the given input.

NewGenericEventConverter creates an EventConverter with the given configuration options.

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.

OwnerHasExclusiveWritePerms asserts that the current user or root is the owner of the config file and that the config file is (at most) writable by the owner or root (e.g.

ParseTime parses a time in the TsLayout format.

ParseURL tries to parse a URL and return the parsed result.

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.

TryToFloat64 tries to coerce the given interface to an float64.

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.

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

Endpoint represents an endpoint in the communication.

ErrInputNotFinished struct for reporting errors related to not finished inputs.

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

GenericEventConverter is used to normalize MapStr objects for publishing.

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.

Process contains process information.

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

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

EventConverter is used to convert MapStr objects for publishing.

Key type used in the cache.

Value type held in the cache.

Capabilities contains the capability sets of a process.

Config object to store hierarchical configurations into.

Float is a float64 wrapper that implements the encoding/json Marshaler interface to add a decimal point to all float values.

JSONBlob is a custom type that can unpack raw JSON strings or objects into a json.RawMessage.

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.