factory.go

package service

import (
	"strings"

	"github.com/clickvisual/clickvisual/api/internal/pkg/model/view"
)

func arrFilter(source, target []string) []string {
	res := make([]string, 0)
	filter := make(map[string]interface{})
	for _, v := range source {
		filter[v] = struct{}{}
	}
	for _, v := range target {
		filter[v] = struct{}{}
	}
	for k := range filter {
		res = append(res, k)
	}
	return res
}

func databaseCutting(input []string) (output []string) {
	output = make([]string, 0)
	for _, row := range input {
		rowArr := strings.Split(row, ".")
		if len(rowArr) != 2 {
			continue
		}
		output = append(output, rowArr[1])
	}
	return
}

var templateTableAnalysisField = map[string][]view.IndexItem{
	"app_stdout": {
		{
			Field: "application",
			Typ:   0,
		},
		{
			Field: "category",
			Typ:   0,
		},
		{
			Field: "level",
			Typ:   1,
		},
		{
			Field: "env",
			Typ:   0,
		},
		{
			Field: "lv",
			Typ:   0,
		},
		{
			Field: "method",
			Typ:   0,
		},
		{
			Field: "msg",
			Typ:   0,
		},
		{
			Field: "status",
			Typ:   1,
		},
		{
			Field: "step",
			Typ:   0,
		},
	},
	"ego_stdout": {
		{
			Field: "addr",
			Typ:   0,
		},
		{
			Field: "code",
			Typ:   1,
		},
		{
			Field: "comp",
			Typ:   0,
		},
		{
			Field: "compName",
			Typ:   0,
		},
		{
			Field: "cost",
			Typ:   2,
		},
		{
			Field: "event",
			Typ:   0,
		},
		{
			Field: "ip",
			Typ:   0,
		},
		{
			Field: "lv",
			Typ:   0,
		},
		{
			Field: "method",
			Typ:   0,
		},
		{
			Field: "msg",
			Typ:   0,
		},
		{
			Field: "name",
			Typ:   0,
		},
		{
			Field: "peerIp",
			Typ:   0,
		},
		{
			Field: "peerName",
			Typ:   0,
		},
		{
			Field: "tid",
			Typ:   0,
		},
		{
			Field: "ts",
			Typ:   2,
		},
		{
			Field: "type",
			Typ:   0,
		},
		{
			Field: "ucode",
			Typ:   1,
		},
	},
	"ingress_stdout": {
		{
			Field: "body_bytes_sent",
			Typ:   1,
		},
		{
			Field: "host",
			Typ:   0,
		},
		{
			Field: "proxy_upstream_name",
			Typ:   0,
		},
		{
			Field: "request_length",
			Typ:   1,
		},
		{
			Field: "request_time",
			Typ:   2,
		},
		{
			Field: "status",
			Typ:   1,
		},
		{
			Field: "upstream_response_time",
			Typ:   2,
		},
		{
			Field: "upstream_status",
			Typ:   1,
		},
		{
			Field: "url",
			Typ:   0,
		},
		{
			Field: "x_forward_for",
			Typ:   0,
		},
	},
	"ingress_stderr": {},
}