in action/log/logadapter/elasticsearch.go [177:195]
func ParseJobString(input string) (map[string]string, error) {
// Remove curly braces
input = strings.Trim(input, "{}")
// Split by ','
parts := strings.Split(input, ",")
kvMap := make(map[string]string)
for _, part := range parts {
// Split by '=' to get key-value pairs
kv := strings.Split(part, "=")
if len(kv) != 2 {
return nil, fmt.Errorf("invalid key=value pair: %s", part)
}
kvMap[strings.TrimSpace(kv[0])] = strings.TrimSpace(kv[1])
}
return kvMap, nil
}