in log_config.go [431:460]
func AddNecessaryInputConfigField(inputConfigDetail map[string]interface{}) {
if _, ok := inputConfigDetail["localStorage"]; !ok {
inputConfigDetail["localStorage"] = true
}
if _, ok := inputConfigDetail["enableTag"]; !ok {
inputConfigDetail["enableTag"] = true
}
if _, ok := inputConfigDetail["maxSendRate"]; !ok {
inputConfigDetail["maxSendRate"] = -1
}
if _, ok := inputConfigDetail["mergeType"]; !ok {
inputConfigDetail["mergeType"] = MergeTypeTopic
}
if logTypeInterface, ok := inputConfigDetail["logType"]; ok {
if logType, ok := logTypeInterface.(string); ok {
AddNecessaryLocalFileInputConfigField(inputConfigDetail)
switch logType {
case LogFileTypeApsaraLog:
AddNecessaryApsaraLogInputConfigField(inputConfigDetail)
case LogFileTypeRegexLog:
AddNecessaryRegexLogInputConfigField(inputConfigDetail)
case LogFileTypeJSONLog:
AddNecessaryJSONLogInputConfigField(inputConfigDetail)
case LogFileTypeDelimiterLog:
AddNecessaryDelimiterLogInputConfigField(inputConfigDetail)
}
}
}
}