jaeger

type IJaegerTraceRepository interface {
	Get(traceId trigger.TraceId) (*JaegerTraceDTO, error)
}

type JaegerConfig struct {
	BaseURL string `mapstructure:"base_url"` // "http://localhost:16686"
}

type JaegerProcess struct {
	ServiceName string      `json:"serviceName"`
	Tags        []JaegerTag `json:"tags"`
}

type JaegerReference struct {
	RefType string `json:"refType"`
	TraceId string `json:"traceID"`
	SpanId  string `json:"spanID"`
}

type JaegerSpanDTO struct {
	TraceId       string            `json:"traceID"`
	SpanId        string            `json:"spanID"`
	OperationName string            `json:"operationName"`
	References    []JaegerReference `json:"references"`
	StartTimeUs   int64             `json:"startTime"`
	DurationUs    int64             `json:"duration"`
	Tags          []JaegerTag       `json:"tags"`
	Logs          []any             `json:"logs"`
	ProcessID     string            `json:"processID"`
	Warnings      []string          `json:"warnings"`
}

type JaegerTag struct {
	Key   string `json:"key"`
	Type  string `json:"type"`
	Value any    `json:"value"`
}

type JaegerTraceAdapter struct {
	// contains filtered or unexported fields
}

type JaegerTraceDTO struct {
	TraceId   string                   `json:"traceID"`
	Spans     []JaegerSpanDTO          `json:"spans"`
	Processes map[string]JaegerProcess `json:"processes"`
	Warnings  []string                 `json:"warnings"`
}

type JaegerTraceRepository struct {
	BaseURL string
	Client  *http.Client
	// contains filtered or unexported fields
}

type JaegerTraceResponse struct {
	Data   []JaegerTraceDTO `json:"data"`
	Total  int              `json:"total"`
	Limit  int              `json:"limit"`
	Offset int              `json:"offset"`
	Errors any              `json:"errors"`
}