utils

Documentation

Index

• func BackupDirectory(sourceDir, targetDir, prefix string) error
• func ConfigValueToNumber(valueType string, value interface{}) (float64, error)
• func DownloadFileFromUrl(filepath string, url string) error
• func GenerateId(len int) string
• func GenerateRandomNumber() int32
• func IsNumber(valueType string) bool
• func RouteIncludesTopic(route, topic string) bool
• type LogEntry
  • func GetLogs(logFile string, filter *LogFilter, limitLines int) []LogEntry
• type LogFilter

Functions

func BackupDirectory

func BackupDirectory(sourceDir, targetDir, prefix string) error

func ConfigValueToNumber

func ConfigValueToNumber(valueType string, value interface{}) (float64, error)

func DownloadFileFromUrl

func DownloadFileFromUrl(filepath string, url string) error

func GenerateId

func GenerateId(len int) string

func GenerateRandomNumber

func GenerateRandomNumber() int32

func IsNumber

func IsNumber(valueType string) bool

func RouteIncludesTopic

func RouteIncludesTopic(route, topic string) bool

Types

type LogEntry

type LogEntry struct {
	Component string `json:"comp"`
	FlowId    string `json:"fid"`
	LogLevel  string `json:"level"`
	Msg       string `json:"msg"`
	Time      string `json:"time"`
}

{"comp":"flow","fid":"RMgV2a79wxQMQ2o","level":"info","msg":" Node is loaded and added.","time":"2018-12-24 16:03:29.178"}

func GetLogs

func GetLogs(logFile string, filter *LogFilter, limitLines int) []LogEntry

type LogFilter

type LogFilter struct {
	Component string
	FlowId    string
}