Copy copies the exported fields from src to dest Used for copying the default transport.

CreateTMPDIR creates tmp dir at path configured via RUDDER_TMPDIR env var.

DiskUsage calculates the path's disk usage recursively in bytes.

 Returns chronological timestamp of the event using the formula  timestamp = receivedAt - (sentAt - originalTimestamp).

GetConnectionString Returns Jobs DB connection configuration.

GetMandatoryJSONFieldNames returns all the json field names defined against the json tag for each field.

GetMD5Hash returns EncodeToString(md5 hash of the input string).

GetParsedTimestamp returns the parsed timestamp.

GetReservedFolderPaths returns all temporary folder paths.

GetTagName gets the tag name using a uuid and name.

IsValidUUID will check if provided string is a valid UUID */.

MapLookup returns the value of the key in the map, or nil if the key is not present.

MergeMaps merging with one level of nesting.

NestedMapLookup m: a map from strings to other maps or values, of arbitrary depth ks: successive keys to reach an internal or leaf node (variadic) If an internal node is reached, will return the internal map Returns: (Exactly one of these will be nil) rval: the target node (if found) err: an error created by fmt.Errorf.

NewAsyncInit returns a new AsyncInit object with the given expected initialization events count.

RemoveContents removes all the contents of the directory.

RemoveEmptyFolderStructureForFilePath recursively cleans up everything till it reaches the stage where the folders are not empty or parent.

RemoveFilePaths removes filePaths as well as cleans up the empty folder structure.

RetryWithNotify retries a function f with a timeout and a maximum number of attempts & calls notify on each failure.

RunWithTimeout runs provided function f until provided timeout d.

SanitizeJSON makes a json payload safe for writing into postgres.

SetAppNameInDBConnURL sets application name in db connection url if application name is already present in dns it will get override by the appName.

SleepCtx sleeps for the given duration or until the context is canceled.

TailTruncateStr returns the last `count` digits of a string.

UpdateJSONWithNewKeyVal enhances the json passed with key, val.

RFC3339Milli with milli sec precision.

AsyncInit is a helper object to wait for multiple asynchronous initialization events.

ErrorStoreT : DS to store the app errors.

ExponentialNumber is a simple exponentially increasing number.

RudderError : to store rudder error.

DefaultString is a utility type for providing default values using one-liners in otherwise multi-line scenarios.