handler

func AddTrace ¶

func AddTrace(pipeSearchResponseOuter *pipesearch.PipeSearchResponseOuter, traces *[]*structs.Trace, traceId string, traceStartTime uint64,
	traceEndTime uint64, serviceName string, operationName string)

func DependencyGraphThread ¶

func DependencyGraphThread()

func ExtractTraceID ¶

func ExtractTraceID(searchText string) (bool, string)

Check if searchText only contains traceId as query condition

func GetTotalUniqueTraceIds ¶

func GetTotalUniqueTraceIds(pipeSearchResponseOuter *pipesearch.PipeSearchResponseOuter) int

func GetUniqueTraceIds ¶

func GetUniqueTraceIds(pipeSearchResponseOuter *pipesearch.PipeSearchResponseOuter, startEpoch uint64, endEpoch uint64, page int) []string

func MakeTracesDependancyGraph ¶

func MakeTracesDependancyGraph(startEpoch int64, endEpoch int64) map[string]map[string]int

func MonitorSpansHealth ¶

func MonitorSpansHealth()

Monitor spans health in the last 5 mins

func ParseAndValidateRequestBody ¶

func ParseAndValidateRequestBody(ctx *fasthttp.RequestCtx) (*structs.SearchRequestBody, map[string]interface{}, error)

func ProcessAggregatedDependencyGraphs ¶

func ProcessAggregatedDependencyGraphs(ctx *fasthttp.RequestCtx, myid uint64)

ProcessAggregatedDependencyGraphs handles the /dependencies endpoint. It aggregates already computed dependency graphs based on the provided start and end epochs.

func ProcessGanttChartRequest ¶

func ProcessGanttChartRequest(ctx *fasthttp.RequestCtx, myid uint64)

func ProcessGeneratedDepGraph ¶

func ProcessGeneratedDepGraph(ctx *fasthttp.RequestCtx, myid uint64)

ProcessGeneratedDepGraph handles the /generate-dep-graph endpoint. It generates a new dependency graph based on the provided start and end epochs and displays it without storing.

func ProcessRedTracesIngest ¶

func ProcessRedTracesIngest()

func ProcessSearchTracesRequest ¶

func ProcessSearchTracesRequest(ctx *fasthttp.RequestCtx, myid uint64)

func ProcessTotalTracesRequest ¶

func ProcessTotalTracesRequest(ctx *fasthttp.RequestCtx, myid uint64)