reporter

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

type Config struct {
	// Shared: labelling, metadata, caches, and metrics.
	ExternalLabels         []Label
	ReportInterval         time.Duration
	LabelTTL               time.Duration
	CacheSize              uint32
	NodeName               string
	AgentRevision          string
	RelabelConfigs         []*relabel.Config
	Registerer             prometheus.Registerer
	SamplesPerSecond       int64
	LocalMetadataOnly      bool
	Semconv                bool // Automatically enabled by NewOTLPProfiles.
	DisableCPULabel        bool
	DisableThreadIDLabel   bool
	DisableThreadCommLabel bool
	MergeGpuProfiles       bool

	// Symbol upload. Always aimed at a Parca-protocol DebuginfoService,
	// regardless of where profiles go.
	DebuginfoClient         debuginfogrpc.DebuginfoServiceClient
	DisableSymbolUpload     bool
	StripTextSection        bool
	SymbolUploadConcurrency int
	UploaderQueueSize       uint32
	CacheDir                string

	// Logs and traces the agent emits about itself. LogExporter and
	// TraceExporter win when set; otherwise both piggyback GRPCConn.
	GRPCConn      *grpc.ClientConn
	LogExporter   sdklog.Exporter
	TraceExporter sdktrace.SpanExporter

	// ExportSelfLogs builds the LoggerProvider that Logger() hands out. It is
	// separate from GRPCConn because a connection means profiles are being
	// exported, which says nothing about whether the agent's own logs should
	// be (a Parca server, for one, does not accept OTLP logs).
	ExportSelfLogs bool

	// oomprof, shared by the arrow and OTLP backends.
	EnableOOMProf       bool
	EnableOOMProfAllocs bool

	// ExportCallOptions are applied to every OTLP profiles export and carry
	// the transport compressor when one is configured. They are per-call
	// rather than dial options because the arrow paths share this connection
	// and already compress inside their own payload.
	ExportCallOptions []grpc.CallOption

	// Arrow-only.
	Mem                memory.Allocator
	ProfileStoreClient profilestoregrpc.ProfileStoreServiceClient
	UseV2Schema        bool
	OfflineMode        *OfflineModeConfig
}

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

type FunctionV2 struct {
	SystemName string
	Filename   string
	StartLine  uint64
}

type GrpcDebuginfoUploadServiceClient interface {
	Upload(ctx context.Context, opts ...grpc.CallOption) (debuginfogrpc.DebuginfoService_UploadClient, error)
}

type GrpcUploadClient struct {
	GrpcDebuginfoUploadServiceClient
}

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

type Label struct {
	Name  string
	Value string
}

type Labels []Label

type LocationsWriter struct {
	IsComplete         *array.BooleanBuilder
	LocationsList      *array.ListBuilder
	Locations          *array.StructBuilder
	Address            *array.Uint64Builder
	FrameType          *BinaryDictionaryRunEndBuilder
	MappingStart       *Uint64RunEndBuilder
	MappingLimit       *Uint64RunEndBuilder
	MappingOffset      *Uint64RunEndBuilder
	MappingFile        *BinaryDictionaryRunEndBuilder
	MappingBuildID     *BinaryDictionaryRunEndBuilder
	Lines              *array.ListBuilder
	Line               *array.StructBuilder
	LineNumber         *array.Int64Builder
	ColumnNumber       *array.Uint64Builder
	FunctionName       *array.BinaryDictionaryBuilder
	FunctionSystemName *array.BinaryDictionaryBuilder
	FunctionFilename   *BinaryDictionaryRunEndBuilder
	FunctionStartLine  *array.Int64Builder
}

type ParcaReporter interface {
	reporter.Reporter
	reporter.ExecutableReporter

	// ReportMetrics fans otel-side metric updates back into the agent's
	// prometheus registry.
	ReportMetrics(timestamp uint32, ids []uint32, values []int64)

	// ReportMemoryTraces emits one or more memory-attributed traces for a
	// single process snapshot. The samples slice carries the stacks plus
	// alloc/free counters; meta carries the per-process attribution
	// (PID, comm, executable path, build ID). Implementations should
	// hold their writer lock at most once per call.
	ReportMemoryTraces(samples []oomprof.Sample, meta oomprof.SampleMeta) error

	// Logger returns an OTel logs Logger bound to the given instrumentation
	// scope name. The OTLP server surfaces the scope as attributes_scope.name
	// so consumers can filter by producer.
	//
	// When the reporter was constructed without a gRPC conn (offline mode),
	// the returned Logger is a no-op.
	Logger(scope string) log.Logger

	// LoggerProvider returns the provider behind Logger, for bridges that
	// take a provider rather than a Logger (e.g. otelslog). It is a no-op
	// provider whenever Logger would return a no-op.
	LoggerProvider() log.LoggerProvider

	// Tracer returns an OTel Tracer bound to the given instrumentation scope
	// name. Used by producers that model interval-shaped events (probe fires,
	// etc.) as spans rather than logs; the OTLP server surfaces the scope as
	// the span's instrumentation-scope name so consumers can filter by
	// producer.
	//
	// When the reporter was constructed without a gRPC conn (offline mode),
	// the returned Tracer is a no-op.
	Tracer(scope string) trace.Tracer

	// SetProbes gives the probes service access to executable reporting.
	SetProbes(p ProbesHook)

	// ProcessLabels returns the resolver behind the reporter's per-process
	// labels, so other signals about a process can carry the same identity.
	ProcessLabels() *processlabels.Resolver
}

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

type ProbesHook interface {
	OnExecutable(filePath string, fileID libpf.FileID)
}

type SampleWriter struct {
	StacktraceID *BinaryDictionaryRunEndBuilder
	Value        *array.Int64Builder
	Producer     *BinaryDictionaryRunEndBuilder
	SampleType   *BinaryDictionaryRunEndBuilder
	SampleUnit   *BinaryDictionaryRunEndBuilder
	PeriodType   *BinaryDictionaryRunEndBuilder
	PeriodUnit   *BinaryDictionaryRunEndBuilder
	Temporality  *BinaryDictionaryRunEndBuilder
	Period       *Int64RunEndBuilder
	Duration     *Int64RunEndBuilder
	Timestamp    *Int64RunEndBuilder
	// contains filtered or unexported fields
}

type SampleWriterV2 struct {

	// Stacktrace with deduplication
	Stacktrace   *StacktraceDictBuilderV2
	StacktraceID *extensions.UUIDBuilder

	// Sample data fields (same as v1)
	Value       *array.Int64Builder
	Producer    *StringRunEndBuilder
	SampleType  *StringRunEndBuilder
	SampleUnit  *StringRunEndBuilder
	PeriodType  *StringRunEndBuilder
	PeriodUnit  *StringRunEndBuilder
	Temporality *StringRunEndBuilder
	Period      *Int64RunEndBuilder
	Duration    *Uint64RunEndBuilder
	Timestamp   *array.TimestampBuilder
	// contains filtered or unexported fields
}

type StacktraceDictBuilderV2 struct {

	// Track locations for deduplication: frame -> dictionary index
	LocationIndex map[libpf.Frame]uint32
	// contains filtered or unexported fields
}

type Stater interface {
	Stat() (os.FileInfo, error)
}

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

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