func ParseJobString()

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
}