Versions in this module Expand all Collapse all v1 v1.0.11 Feb 23, 2021 v1.0.10 Feb 23, 2021 v1.0.9 Feb 23, 2021 v1.0.8 Feb 23, 2021 v1.0.5 Feb 9, 2021 v0 v0.1.0 Feb 10, 2021 Changes in this version + const RFC3339Milli + var AppStartTime int64 + var DefaultConfigDBUtils = ConfigDBUtils + func AddFileToZip(zipWriter *zip.Writer, filename string) error + func AppendError(callingMethodName string, firstError *error, secondError *error) + func AssertErrorIfDev(err error) + func Contains(in interface{}, elem interface{}) bool + func ContainsString(slice []string, str string) bool + func Copy(dst, src interface{}) + func CreateTMPDIR(rudderTmpDir string) (string, error) + func GetChronologicalTimeStamp(receivedAt, sentAt, originalTimestamp time.Time) time.Time + func GetHash(s string) int + func GetIPFromReq(req *http.Request) string + func GetMD5Hash(input string) string + func GetMD5UUID(str string) (uuid.UUID, error) + func GetMacAddress() string + func GetMandatoryJSONFieldNames(st interface{}) []string + func GetObjectStorageConfig(provider string, objectStorageConfig interface{}, accessKeyID string, ...) map[string]interface + func GetOutboundIP() (net.IP, error) + func GetParsedTimestamp(input interface{}) (time.Time, bool) + func GetRudderEventVal(key string, rudderEvent types.SingularEventT) (interface{}, bool) + func GetRudderID(event types.SingularEventT) (string, bool) + func GetSpacesLocation(location string) (region string) + func GetTagName(id string, names ...string) string + func HasAWSKeysInConfig(config interface{}) bool + func IncrementMapByKey(m map[string]int, key string, increment int) + func IntArrayToString(a []int64, delim string) string + func IsValidUUID(uuid string) bool + func KeepProcessAlive() + func MakeJSONArray(bytesArray [][]byte) []byte + func MakeRetryablePostRequest(url string, endpoint string, data interface{}) (response []byte, statusCode int, err error) + func MapStringKeys(input map[string]interface{}) []string + func MinInt(a, b int) int + func ParseRudderEventBatch(eventPayload json.RawMessage) ([]types.SingularEventT, bool) + func PrintMemUsage() + func QuoteLiteral(literal string) string + func ReadLines(path string) ([]string, error) + func RecordAppError(err error, errorStorePath string) + func RemoveFilePaths(filepaths ...string) + func ReplaceDB(dbName, targetName string, configDBUtilsList ...interface{}) + func ReplaceMultiRegex(str string, expList map[string]string) (string, error) + func RunWithTimeout(f func(), onTimeout func(), d time.Duration) + func SingleQuoteLiteralJoin(slice []string) string + func SortedMapKeys(input interface{}) []string + func SortedStructSliceValues(input interface{}, filedName string) []string + func StringKeys(input interface{}) []string + func TailTruncateStr(str string, count int) string + func TruncateStr(str string, limit int) string + func UnZipSingleFile(outputfile string, filename string) + func ZipFiles(filename string, files []string) error + type ConfigDBUtils struct + Host string + Password string + Port int + Sslmode string + User string + type ErrorStoreT struct + Errors []RudderError + type GZipWriter struct + BufWriter *bufio.Writer + File *os.File + GzWriter *gzip.Writer + func CreateGZ(s string) (w GZipWriter, err error) + func (w GZipWriter) CloseGZ() error + func (w GZipWriter) Write(b []byte) + func (w GZipWriter) WriteGZ(s string) + type PerfStats struct + func (stats *PerfStats) End(events int) + func (stats *PerfStats) Print() + func (stats *PerfStats) Setup(comp string) + func (stats *PerfStats) Start() + func (stats *PerfStats) Status() map[string]interface{} + type RudderError struct + Code int + CrashTime int64 + Message string + ReadableCrashTime string + ReadableStartTime string + StackTrace string + StartTime int64 + type WaitGroup struct + func NewWaitGroup() *WaitGroup + func (wg *WaitGroup) Add(delta int) + func (wg *WaitGroup) Done() + func (wg *WaitGroup) Err(err error) + func (wg *WaitGroup) Wait() error + func (wg *WaitGroup) WaitForAll() []error
Go to main page