application

package
v0.0.0-...-d0ab517 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jan 8, 2026 License: Apache-2.0 Imports: 116 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	MaxSpanLength         = 500
	MaxListSpansLimit     = 1000
	MaxTraceTreeLength    = 10000
	MaxOApiListSpansLimit = 200
	QueryLimitDefault     = 100
)

Variables

This section is empty.

Functions

func GetUserID 

func GetUserID(ctx context.Context, sessionReq *common.Session) (string, error)

func NewDatasetServiceAdapter 

func NewDatasetServiceAdapter(evalSetService evaluationsetservice.Client, datasetService datasetservice.Client) *service.DatasetServiceAdaptor

func NewIngestionCollectorFactory 

func NewIngestionCollectorFactory(mqFactory mq.IFactory, traceRepo repo2.ITraceRepo) service.IngestionCollectorFactory

func NewInitTaskProcessor 

func NewInitTaskProcessor(datasetServiceProvider *service.DatasetServiceAdaptor, evalService rpc.IEvaluatorRPCAdapter,
	evaluationService rpc.IEvaluationRPCAdapter, taskRepo repo4.ITaskRepo,
) *processor.TaskProcessor

func NewMetricsPlatformConfig 

func NewMetricsPlatformConfig() *entity.PlatformMetrics

func NewScheduledTask 

func NewScheduledTask(
	locker lock.ILocker, config3 config2.ITraceConfig,

	traceHubService tracehub.ITraceHubService,
	taskService service3.ITaskService,
	taskProcessor processor.TaskProcessor,
	taskRepo repo4.ITaskRepo,
) []scheduledtask.ScheduledTask

func NewTaskLocker 

func NewTaskLocker(cmdable redis.Cmdable) lock.ILocker

func NewTraceConfigLoader 

func NewTraceConfigLoader(confFactory conf.IConfigLoaderFactory) (conf.IConfigLoader, error)

func NewTraceProcessorBuilder 

func NewTraceProcessorBuilder(
	traceConfig config2.ITraceConfig,
	fileProvider rpc.IFileProvider,
	benefitSvc benefit.IBenefitService,
) service.TraceFilterProcessorBuilder

Types

type GetDisplayInfoRequest 

type GetDisplayInfoRequest struct {
	WorkspaceID  int64
	UserIDs      []string
	EvaluatorIDs []int64
	TagKeyIDs    []string
}

inner usage

type GetDisplayInfoResponse 

type GetDisplayInfoResponse struct {
	UserMap map[string]*commdo.UserInfo
	EvalMap map[int64]*rpc.Evaluator
	TagMap  map[int64]*rpc.TagInfo
}

type IAnnotationQueueConsumer 

type IAnnotationQueueConsumer interface {
	Send(context.Context, *entity.AnnotationEvent) error
}

type IMetricApplication 

type IMetricApplication interface {
	metric.MetricService
}

func InitMetricApplication 

func InitMetricApplication(ckDb ck.Provider, storageProvider storage2.IStorageProvider, configFactory conf.IConfigLoaderFactory, fileClient fileservice.Client, benefit2 benefit.IBenefitService, authClient authservice.Client, idGenerator idgen.IIDGenerator) (IMetricApplication, error)

func NewMetricApplication 

func NewMetricApplication(
	metricService service.IMetricsService,
	tenantProvider tenant.ITenantProvider,
	authSvc rpc.IAuthProvider,
) (IMetricApplication, error)

type IObservabilityOpenAPIApplication 

type IObservabilityOpenAPIApplication interface {
	openapi.OpenAPIService
	IAnnotationQueueConsumer
}

func InitOpenAPIApplication 

func InitOpenAPIApplication(mqFactory mq.IFactory, configFactory conf.IConfigLoaderFactory, fileClient fileservice.Client, ckDb ck.Provider, benefit2 benefit.IBenefitService, limiterFactory limiter.IRateLimiterFactory, authClient authservice.Client, meter metrics.Meter, db2 db.Provider, redis3 redis.Cmdable, idgen2 idgen.IIDGenerator, evalService evaluatorservice.Client, persistentCmdable redis.PersistentCmdable) (IObservabilityOpenAPIApplication, error)

func NewOpenAPIApplication 

func NewOpenAPIApplication(
	traceService service.ITraceService,
	auth rpc.IAuthProvider,
	benefit benefit.IBenefitService,
	tenant tenant.ITenantProvider,
	workspace workspace.IWorkSpaceProvider,
	rateLimiter limiter.IRateLimiterFactory,
	traceConfig config.ITraceConfig,
	metrics metrics.ITraceMetrics,
	collector collector.ICollectorProvider,
) (IObservabilityOpenAPIApplication, error)

type ITaskApplication 

type ITaskApplication interface {
	task.TaskService
	ITaskQueueConsumer
	RunTaskScheduleTask(ctx context.Context) error
}

func InitTaskApplication 

func InitTaskApplication(db2 db.Provider, idgen2 idgen.IIDGenerator, configFactory conf.IConfigLoaderFactory, benefit2 benefit.IBenefitService, ckDb ck.Provider, redis3 redis.Cmdable, mqFactory mq.IFactory, userClient userservice.Client, authClient authservice.Client, evalService evaluatorservice.Client, evalSetService evaluationsetservice.Client, exptService experimentservice.Client, datasetService datasetservice.Client, fileClient fileservice.Client, taskProcessor processor.TaskProcessor, aid int32, persistentCmdable redis.PersistentCmdable) (ITaskApplication, error)

func NewTaskApplication 

func NewTaskApplication(
	taskService service.ITaskService,
	authService rpc.IAuthProvider,
	evalService rpc.IEvaluatorRPCAdapter,
	evaluationService rpc.IEvaluationRPCAdapter,
	userService rpc.IUserProvider,
	tracehubSvc tracehub.ITraceHubService,
	taskProcessor processor.TaskProcessor,
	taskCallbackService service.ITaskCallbackService,
	scheduledTasks []scheduledtask.ScheduledTask,
	traceRepo tracerepo.ITraceRepo,
) (ITaskApplication, error)

type ITaskQueueConsumer 

type ITaskQueueConsumer interface {
	SpanTrigger(ctx context.Context, rawSpan *entity.RawSpan, Span *loop_span.Span) error
	AutoEvalCallback(ctx context.Context, event *entity.AutoEvalEvent) error
	AutoEvalCorrection(ctx context.Context, event *entity.CorrectionEvent) error
	BackFill(ctx context.Context, event *entity.BackFillEvent) error
}

type ITraceApplication 

type ITraceApplication interface {
	trace.TraceService
	GetDisplayInfo(context.Context, *GetDisplayInfoRequest) GetDisplayInfoResponse
}

func InitTraceApplication 

func InitTraceApplication(db2 db.Provider, ckDb ck.Provider, redis3 redis.Cmdable, persistentCmdable redis.PersistentCmdable, meter metrics.Meter, mqFactory mq.IFactory, configFactory conf.IConfigLoaderFactory, idgen2 idgen.IIDGenerator, fileClient fileservice.Client, benefit2 benefit.IBenefitService, authClient authservice.Client, userClient userservice.Client, evalService evaluatorservice.Client, evalSetService evaluationsetservice.Client, tagService tagservice.Client, datasetService datasetservice.Client) (ITraceApplication, error)

func NewTraceApplication 

func NewTraceApplication(
	traceService service.ITraceService,
	traceExportService service.ITraceExportService,
	viewRepo repo.IViewRepo,
	benefitService benefit.IBenefitService,
	tenant tenant.ITenantProvider,
	traceMetrics metrics.ITraceMetrics,
	traceConfig config.ITraceConfig,
	authService rpc.IAuthProvider,
	evalService rpc.IEvaluatorRPCAdapter,
	userService rpc.IUserProvider,
	tagService rpc.ITagRPCAdapter,
) (ITraceApplication, error)

type ITraceIngestionApplication 

type ITraceIngestionApplication interface {
	RunSync(context.Context) error
	RunAsync(context.Context)
}

func InitTraceIngestionApplication 

func InitTraceIngestionApplication(configFactory conf.IConfigLoaderFactory, storageProvider storage2.IStorageProvider, ckDb ck.Provider, db2 db.Provider, mqFactory mq.IFactory, persistentCmdable redis.PersistentCmdable, idGenerator idgen.IIDGenerator) (ITraceIngestionApplication, error)

func NewIngestionApplication 

func NewIngestionApplication(svc service.IngestionService) ITraceIngestionApplication

type IngestionApplicationImpl 

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

func (*IngestionApplicationImpl) RunAsync 

func (i *IngestionApplicationImpl) RunAsync(ctx context.Context)

func (*IngestionApplicationImpl) RunSync 

func (i *IngestionApplicationImpl) RunSync(ctx context.Context) error

type MetricApplication 

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

func (*MetricApplication) GetDrillDownValues 

func (m *MetricApplication) GetDrillDownValues(ctx context.Context, req *metric.GetDrillDownValuesRequest) (r *metric.GetDrillDownValuesResponse, err error)

func (*MetricApplication) GetMetrics 

func (m *MetricApplication) GetMetrics(ctx context.Context, req *metric.GetMetricsRequest) (r *metric.GetMetricsResponse, err error)

func (*MetricApplication) TraverseMetrics 

func (m *MetricApplication) TraverseMetrics(ctx context.Context, req *metric.TraverseMetricsRequest) (*metric.TraverseMetricsResponse, error)

type OpenAPIApplication 

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

func (*OpenAPIApplication) AllowByKey 

func (p *OpenAPIApplication) AllowByKey(ctx context.Context, key string) bool

func (*OpenAPIApplication) CreateAnnotation 

func (o *OpenAPIApplication) CreateAnnotation(ctx context.Context, req *openapi.CreateAnnotationRequest) (*openapi.CreateAnnotationResponse, error)

func (*OpenAPIApplication) DeleteAnnotation 

func (o *OpenAPIApplication) DeleteAnnotation(ctx context.Context, req *openapi.DeleteAnnotationRequest) (*openapi.DeleteAnnotationResponse, error)

func (*OpenAPIApplication) IngestTraces 

func (o *OpenAPIApplication) IngestTraces(ctx context.Context, req *openapi.IngestTracesRequest) (*openapi.IngestTracesResponse, error)

func (*OpenAPIApplication) ListPreSpanOApi 

func (o *OpenAPIApplication) ListPreSpanOApi(ctx context.Context, req *openapi.ListPreSpanOApiRequest) (*openapi.ListPreSpanOApiResponse, error)

func (*OpenAPIApplication) ListSpansOApi 

func (o *OpenAPIApplication) ListSpansOApi(ctx context.Context, req *openapi.ListSpansOApiRequest) (*openapi.ListSpansOApiResponse, error)

func (*OpenAPIApplication) ListTracesOApi 

func (o *OpenAPIApplication) ListTracesOApi(ctx context.Context, req *openapi.ListTracesOApiRequest) (*openapi.ListTracesOApiResponse, error)

func (*OpenAPIApplication) OtelIngestTraces 

func (o *OpenAPIApplication) OtelIngestTraces(ctx context.Context, req *openapi.OtelIngestTracesRequest) (*openapi.OtelIngestTracesResponse, error)

func (*OpenAPIApplication) SearchTraceOApi 

func (o *OpenAPIApplication) SearchTraceOApi(ctx context.Context, req *openapi.SearchTraceOApiRequest) (*openapi.SearchTraceOApiResponse, error)

func (*OpenAPIApplication) SearchTraceTreeOApi 

func (o *OpenAPIApplication) SearchTraceTreeOApi(ctx context.Context, req *openapi.SearchTraceTreeOApiRequest) (*openapi.SearchTraceTreeOApiResponse, error)

func (*OpenAPIApplication) Send 

func (o *OpenAPIApplication) Send(ctx context.Context, event *entity.AnnotationEvent) error

type TaskApplication 

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

func (*TaskApplication) AutoEvalCallback 

func (t *TaskApplication) AutoEvalCallback(ctx context.Context, event *entity.AutoEvalEvent) error

func (*TaskApplication) AutoEvalCorrection 

func (t *TaskApplication) AutoEvalCorrection(ctx context.Context, event *entity.CorrectionEvent) error

func (*TaskApplication) BackFill 

func (t *TaskApplication) BackFill(ctx context.Context, event *entity.BackFillEvent) error

func (*TaskApplication) CheckTaskName 

func (t *TaskApplication) CheckTaskName(ctx context.Context, req *task.CheckTaskNameRequest) (*task.CheckTaskNameResponse, error)

func (*TaskApplication) CreateTask 

func (t *TaskApplication) CreateTask(ctx context.Context, req *task.CreateTaskRequest) (*task.CreateTaskResponse, error)

func (*TaskApplication) GetTask 

func (t *TaskApplication) GetTask(ctx context.Context, req *task.GetTaskRequest) (*task.GetTaskResponse, error)

func (*TaskApplication) ListTasks 

func (t *TaskApplication) ListTasks(ctx context.Context, req *task.ListTasksRequest) (*task.ListTasksResponse, error)

func (*TaskApplication) RunTaskScheduleTask 

func (t *TaskApplication) RunTaskScheduleTask(ctx context.Context) error

func (*TaskApplication) SpanTrigger 

func (t *TaskApplication) SpanTrigger(ctx context.Context, rawSpan *entity.RawSpan, loopSpan *loop_span.Span) error

func (*TaskApplication) UpdateTask 

func (t *TaskApplication) UpdateTask(ctx context.Context, req *task.UpdateTaskRequest) (*task.UpdateTaskResponse, error)

type TraceApplication 

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

func (*TraceApplication) BatchGetTracesAdvanceInfo 

func (t *TraceApplication) BatchGetTracesAdvanceInfo(ctx context.Context, req *trace.BatchGetTracesAdvanceInfoRequest) (*trace.BatchGetTracesAdvanceInfoResponse, error)

func (*TraceApplication) ChangeEvaluatorScore 

func (t *TraceApplication) ChangeEvaluatorScore(ctx context.Context, req *trace.ChangeEvaluatorScoreRequest) (*trace.ChangeEvaluatorScoreResponse, error)

func (*TraceApplication) CreateManualAnnotation 

func (t *TraceApplication) CreateManualAnnotation(ctx context.Context, req *trace.CreateManualAnnotationRequest) (*trace.CreateManualAnnotationResponse, error)

func (*TraceApplication) CreateView 

func (t *TraceApplication) CreateView(ctx context.Context, req *trace.CreateViewRequest) (*trace.CreateViewResponse, error)

func (*TraceApplication) DeleteManualAnnotation 

func (t *TraceApplication) DeleteManualAnnotation(ctx context.Context, req *trace.DeleteManualAnnotationRequest) (*trace.DeleteManualAnnotationResponse, error)

func (*TraceApplication) DeleteView 

func (t *TraceApplication) DeleteView(ctx context.Context, req *trace.DeleteViewRequest) (*trace.DeleteViewResponse, error)

func (*TraceApplication) ExportTracesToDataset 

func (t *TraceApplication) ExportTracesToDataset(ctx context.Context, req *trace.ExportTracesToDatasetRequest) (
	r *trace.ExportTracesToDatasetResponse, err error,
)

func (*TraceApplication) ExtractSpanInfo 

func (t *TraceApplication) ExtractSpanInfo(ctx context.Context, req *trace.ExtractSpanInfoRequest) (*trace.ExtractSpanInfoResponse, error)

func (*TraceApplication) GetDisplayInfo 

func (t *TraceApplication) GetDisplayInfo(ctx context.Context, req *GetDisplayInfoRequest) GetDisplayInfoResponse

func (*TraceApplication) GetTrace 

func (t *TraceApplication) GetTrace(ctx context.Context, req *trace.GetTraceRequest) (*trace.GetTraceResponse, error)

func (*TraceApplication) GetTracesMetaInfo 

func (t *TraceApplication) GetTracesMetaInfo(ctx context.Context, req *trace.GetTracesMetaInfoRequest) (*trace.GetTracesMetaInfoResponse, error)

func (*TraceApplication) GetTrajectoryConfig 

func (t *TraceApplication) GetTrajectoryConfig(ctx context.Context, req *trace.GetTrajectoryConfigRequest) (r *trace.GetTrajectoryConfigResponse, err error)

func (*TraceApplication) IngestTracesInner 

func (t *TraceApplication) IngestTracesInner(ctx context.Context, req *trace.IngestTracesRequest) (r *trace.IngestTracesResponse, err error)

func (*TraceApplication) ListAnnotationEvaluators 

func (t *TraceApplication) ListAnnotationEvaluators(ctx context.Context, req *trace.ListAnnotationEvaluatorsRequest) (*trace.ListAnnotationEvaluatorsResponse, error)

func (*TraceApplication) ListAnnotations 

func (t *TraceApplication) ListAnnotations(ctx context.Context, req *trace.ListAnnotationsRequest) (*trace.ListAnnotationsResponse, error)

func (*TraceApplication) ListPreSpan 

func (t *TraceApplication) ListPreSpan(ctx context.Context, req *trace.ListPreSpanRequest) (r *trace.ListPreSpanResponse, err error)

func (*TraceApplication) ListSpans 

func (t *TraceApplication) ListSpans(ctx context.Context, req *trace.ListSpansRequest) (*trace.ListSpansResponse, error)

func (*TraceApplication) ListTrajectory 

func (t *TraceApplication) ListTrajectory(ctx context.Context, req *trace.ListTrajectoryRequest) (r *trace.ListTrajectoryResponse, err error)

func (*TraceApplication) ListViews 

func (t *TraceApplication) ListViews(ctx context.Context, req *trace.ListViewsRequest) (*trace.ListViewsResponse, error)

func (*TraceApplication) PreviewExportTracesToDataset 

func (t *TraceApplication) PreviewExportTracesToDataset(ctx context.Context, req *trace.PreviewExportTracesToDatasetRequest) (
	r *trace.PreviewExportTracesToDatasetResponse, err error,
)

func (*TraceApplication) SearchTraceTree 

func (t *TraceApplication) SearchTraceTree(ctx context.Context, req *trace.SearchTraceTreeRequest) (*trace.SearchTraceTreeResponse, error)

func (*TraceApplication) UpdateManualAnnotation 

func (t *TraceApplication) UpdateManualAnnotation(ctx context.Context, req *trace.UpdateManualAnnotationRequest) (*trace.UpdateManualAnnotationResponse, error)

func (*TraceApplication) UpdateView 

func (t *TraceApplication) UpdateView(ctx context.Context, req *trace.UpdateViewRequest) (*trace.UpdateViewResponse, error)

func (*TraceApplication) UpsertTrajectoryConfig 

func (t *TraceApplication) UpsertTrajectoryConfig(ctx context.Context, req *trace.UpsertTrajectoryConfigRequest) (r *trace.UpsertTrajectoryConfigResponse, err error)

Source Files

View all Source files

Directories

Path Synopsis
metric
task
trace
Package mocks is a generated GoMock package.
 Package mocks is a generated GoMock package.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.