trace

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

type CSVRequests []*CSVRequest

type CsvFields interface {
	bp.HasName
	GetRow() *export.Row
	CsvFields(row *export.Row) []string
}

type IBuffer2SqlItem interface {
	bp.HasName
	Size() int64
	Free()
}

type IDGenerator interface {
	NewIDs() (TraceID, SpanID)
	NewSpanID() SpanID
}

type MOErrorHolder struct {
	Error     error     `json:"error"`
	Timestamp time.Time `json:"timestamp"`
}

type MONodeResource struct {
	NodeUuid string `json:"node_uuid"`
	NodeType string `json:"node_type"`
}

type MOSpan struct {
	SpanConfig
	Name      bytes.Buffer `json:"name"`
	StartTime time.Time    `json:"start_time"`
	EndTime   time.Time    `jons:"end_time"`
	Duration  uint64       `json:"duration"`
	// contains filtered or unexported fields
}

type MOTracer struct {
	TracerConfig
	// contains filtered or unexported fields
}

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

type MOZapLog struct {
	Level       zapcore.Level `json:"Level"`
	SpanContext *SpanContext  `json:"span"`
	Timestamp   time.Time     `json:"timestamp"`
	LoggerName  string
	Caller      string `json:"caller"` // like "util/trace/trace.go:666"
	Message     string `json:"message"`
	Extra       string `json:"extra"` // like json text
	Stack       string `json:"stack"`
}

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

type SerializeExecPlanFunc func(plan any, uuid2 uuid.UUID) (jsonByte []byte, rows int64, bytes int64)

type Span interface {
	// End completes the Span. The Span is considered complete and ready to be
	// delivered through the rest of the telemetry pipeline after this method
	// is called. Therefore, updates to the Span are not allowed after this
	// method has been called.
	End(options ...SpanEndOption)

	// SpanContext returns the SpanContext of the Span. The returned SpanContext
	// is usable even after the End method has been called for the Span.
	SpanContext() SpanContext

	ParentSpanContext() SpanContext
}

type SpanConfig struct {
	SpanContext

	// NewRoot identifies a Span as the root Span for a new trace. This is
	// commonly used when an existing trace crosses trust boundaries and the
	// remote parent span context should be ignored for security.
	NewRoot bool `json:"NewRoot"` // WithNewRoot
	// contains filtered or unexported fields
}

type SpanContext struct {
	TraceID TraceID `json:"trace_id"`
	SpanID  SpanID  `json:"span_id"`
	// Kind default SpanKindInternal
	Kind SpanKind `json:"span_kind"`
}

type SpanEndOption interface {
	// contains filtered or unexported methods
}

type SpanID [8]byte

type SpanKind int

type SpanOption interface {
	SpanStartOption
	SpanEndOption
}

type SpanProcessor interface {
	OnStart(ctx context.Context, s Span)
	OnEnd(s Span)
	Shutdown(ctx context.Context) error
}

type SpanStartOption interface {
	// contains filtered or unexported methods
}

type StatementInfo struct {
	StatementID          [16]byte  `json:"statement_id"`
	TransactionID        [16]byte  `json:"transaction_id"`
	SessionID            [16]byte  `jons:"session_id"`
	Account              string    `json:"account"`
	User                 string    `json:"user"`
	Host                 string    `json:"host"`
	Database             string    `json:"database"`
	Statement            string    `json:"statement"`
	StatementFingerprint string    `json:"statement_fingerprint"`
	StatementTag         string    `json:"statement_tag"`
	RequestAt            time.Time `json:"request_at"` // see WithRequestAt

	// after
	Status     StatementInfoStatus `json:"status"`
	Error      error               `json:"error"`
	ResponseAt time.Time           `json:"response_at"`
	Duration   time.Duration       `json:"duration"` // unit: ns
	ExecPlan   any                 `json:"exec_plan"`
	// RowsRead, BytesScan generated from ExecPlan
	RowsRead  int64 `json:"rows_read"`  // see ExecPlan2Json
	BytesScan int64 `json:"bytes_scan"` // see ExecPlan2Json
	// SerializeExecPlan
	SerializeExecPlan SerializeExecPlanFunc // see SetExecPlan, ExecPlan2Json
	// contains filtered or unexported fields
}

type StatementInfoStatus int

type StatementOption interface {
	Apply(*StatementInfo)
}

type StatementOptionFunc func(*StatementInfo)

type TraceFlags byte //nolint:revive // revive complains about stutter of `trace.TraceFlags`.

type TraceID [16]byte

type Tracer interface {
	// Start creates a span and a context.Context containing the newly-created span.
	Start(ctx context.Context, spanName string, opts ...SpanOption) (context.Context, Span)
	// Debug creates a span only with DebugMode
	Debug(ctx context.Context, spanName string, opts ...SpanOption) (context.Context, Span)
}

type TracerConfig struct {
	Name string
}

type TracerOption interface {
	// contains filtered or unexported methods
}

type TracerProvider interface {
	Tracer(instrumentationName string, opts ...TracerOption) Tracer
}

type TracerProviderOption interface {
	// contains filtered or unexported methods
}