openobserve

type IOpenObserveTraceRepository interface {
	Get(traceId trigger.TraceId) (*OpenObserveTraceResponse, error)
}

type OpenObserveConfig struct {
	BaseURL    string `mapstructure:"base_url"`    // "http://localhost:5080"
	OrgName    string `mapstructure:"org_name"`    // "default"
	StreamName string `mapstructure:"stream_name"` // "default"
	Username   string `mapstructure:"username"`    // "admin@example.com"
	Password   string `mapstructure:"password"`    // "admin"
}

type OpenObserveSpanDTO struct {
	SpanId        string
	ParentId      string
	ServiceName   string
	OperationName *string
	SpanKind      *string
	SpanStatus    *string
	StartTimeNs   int64
	EndTimeNs     int64
	DurationNs    int64
	Attributes    map[string]any
}

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

type OpenObserveTraceRepository struct {
	BaseURL      string
	Organization string
	StreamName   string
	Username     string
	Password     string
	Client       *http.Client

	Timeout    time.Duration
	RetryDelay time.Duration
	LastSpan   *span.ExpectedSpan
	// contains filtered or unexported fields
}

type OpenObserveTraceResponse struct {
	TraceId     trigger.TraceId
	StartTimeNs int64
	EndTimeNs   int64
	DurationNs  int64
	SpanCount   int
	ErrorCount  int
	Spans       []*OpenObserveSpanDTO
}