Documentation
¶
Index ¶
- Constants
- Variables
- func AddFileToZip(zipWriter *zip.Writer, filename string) 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() (string, error)
- func GetAnonymousID(event interface{}) (string, bool)
- func GetChronologicalTimeStamp(receivedAt, sentAt, originalTimestamp time.Time) time.Time
- func GetIPFromReq(req *http.Request) string
- func GetMD5Hash(input string) string
- func GetMacAddress() string
- func GetOutboundIP() (net.IP, error)
- func GetRudderEventMap(rudderEvent interface{}) (map[string]interface{}, bool)
- func GetRudderEventVal(key string, rudderEvent interface{}) (interface{}, bool)
- func IncrementMapByKey(m map[string]int, key string, increment int)
- func IsPostgresCompatible(connInfo string) bool
- func KeepProcessAlive()
- func MapStringKeys(input map[string]interface{}) []string
- func ParseRudderEventBatch(eventPayload json.RawMessage) ([]interface{}, bool)
- func PrintMemUsage()
- func ReadLines(path string) ([]string, error)
- func RecordAppError(err error)
- func RemoveFilePaths(filepaths ...string)
- func ReplaceDB(dbName, targetName string)
- func ReplaceMultiRegex(str string, expList map[string]string) (string, error)
- func SortedMapKeys(input interface{}) []string
- func SortedStructSliceValues(input interface{}, filedName string) []string
- func StringKeys(input interface{}) []string
- func TruncateStr(str string, limit int) string
- func UnZipSingleFile(outputfile string, filename string)
- func ZipFiles(filename string, files []string) error
- type ErrorStoreT
- type GZipWriter
- type PerfStats
- type RudderError
- type WaitGroup
Constants ¶
const (
// RFC3339Milli with milli sec precision
RFC3339Milli = "2006-01-02T15:04:05.000Z07:00"
)
Variables ¶
var AppStartTime int64
Functions ¶
func AddFileToZip ¶
AddFileToZip adds file to zip including size header stats
func AssertErrorIfDev ¶
func AssertErrorIfDev(err error)
func Contains ¶
func Contains(in interface{}, elem interface{}) bool
Contains returns true if an element is present in a iteratee. https://github.com/thoas/go-funk
func ContainsString ¶
func Copy ¶
func Copy(dst, src interface{})
Copy copies the exported fields from src to dest Used for copying the default transport
func CreateTMPDIR ¶
CreateTMPDIR creates tmp dir at path configured via RUDDER_TMPDIR env var
func GetAnonymousID ¶
GetAnonymousID return the UserID from the object
func GetChronologicalTimeStamp ¶
Returns chronological timestamp of the event using the formula timestamp = receivedAt - (sentAt - originalTimestamp)
func GetIPFromReq ¶
GetIPFromReq gets ip address from request
func GetMD5Hash ¶
GetMD5Hash returns EncodeToString(md5 hash of the input string)
func GetMacAddress ¶
func GetMacAddress() string
func GetOutboundIP ¶
GetOutboundIP returns preferred outbound ip of this machine https://stackoverflow.com/a/37382208
func GetRudderEventMap ¶
GetRudderEventMap returns the event structure from the client payload
func GetRudderEventVal ¶
GetRudderEventVal returns the value corresponding to the key in the message structure
func IncrementMapByKey ¶
IncrementMapByKey starts with 1 and increments the counter of a key
func IsPostgresCompatible ¶
IsPostgresCompatible checks the if the version of postgres is greater than minPostgresVersion
func KeepProcessAlive ¶
func KeepProcessAlive()
func MapStringKeys ¶
func ParseRudderEventBatch ¶
func ParseRudderEventBatch(eventPayload json.RawMessage) ([]interface{}, bool)
ParseRudderEventBatch looks for the batch structure inside event
func PrintMemUsage ¶
func PrintMemUsage()
PrintMemUsage outputs the current, total and OS memory being used. As well as the number of garage collection cycles completed.
func RecordAppError ¶
func RecordAppError(err error)
RecordAppError appends the error occured to error_store.json
func RemoveFilePaths ¶
func RemoveFilePaths(filepaths ...string)
func ReplaceDB ¶
func ReplaceDB(dbName, targetName string)
ReplaceDB : Rename the OLD DB and create a new one. Since we are not journaling, this should be idemponent
func ReplaceMultiRegex ¶
func SortedMapKeys ¶
func SortedMapKeys(input interface{}) []string
func SortedStructSliceValues ¶
func StringKeys ¶
func StringKeys(input interface{}) []string
func TruncateStr ¶
func UnZipSingleFile ¶
UnZipSingleFile unzips zip containing single file into ouputfile path passed
Types ¶
type ErrorStoreT ¶
type ErrorStoreT struct {
Errors []RudderError
}
ErrorStoreT : DS to store the app errors
type GZipWriter ¶
func CreateGZ ¶
func CreateGZ(s string) (w GZipWriter, err error)
func (GZipWriter) CloseGZ ¶
func (w GZipWriter) CloseGZ()
func (GZipWriter) Write ¶
func (w GZipWriter) Write(b []byte)
func (GZipWriter) WriteGZ ¶
func (w GZipWriter) WriteGZ(s string)
type PerfStats ¶
type PerfStats struct {
// contains filtered or unexported fields
}
PerfStats is the class for managing performance stats. Not multi-threaded safe now
func (*PerfStats) End ¶
End marks the end of one round of stat collection. events is number of events processed since start
type RudderError ¶
type RudderError struct {
StartTime int64
CrashTime int64
ReadableStartTime string
ReadableCrashTime string
Message string
StackTrace string
Code int
}
RudderError : to store rudder error
type WaitGroup ¶
type WaitGroup struct {
// contains filtered or unexported fields
}
func NewWaitGroup ¶
func NewWaitGroup() *WaitGroup
Source Files