Function ParseJSONLogs

tests/utils/logs/logs.go:37–63

ParseJSONLogs returns the pod's logs of a given pod name, in the form of a list of JSON entries

(
	ctx context.Context,
	kubeInterface kubernetes.Interface,
	namespace string, podName string,
)

// ParseJSONLogs returns the pod's logs of a given pod name,
// in the form of a list of JSON entries
func ParseJSONLogs(
	ctx context.Context,
	kubeInterface kubernetes.Interface,
	namespace string, podName string,
) ([]map[string]interface{}, error) {
	// Gather pod logs
	podLogs, err := pods.Logs(ctx, kubeInterface, namespace, podName)
	if err != nil {
		return nil, err
	}

	// In pod logs, each row is stored as JSON object. Split the JSON objects into JSON array
	logEntries := strings.Split(podLogs, "\n")
	parsedLogEntries := make([]map[string]interface{}, len(logEntries))
	for i, entry := range logEntries {
		if entry == "" {
			continue
		}
		parsedEntry := make(map[string]interface{})
		err := json.Unmarshal([]byte(entry), &parsedEntry)
		if err != nil {
			return nil, err
		}
		parsedLogEntries[i] = parsedEntry
	}
	return parsedLogEntries, nil
}

// HasLogger verifies if a given value exists inside a list of JSON entries
func HasLogger(logEntries []map[string]interface{}, logger string) bool {