ingestion

package
v1.7.0 Latest Latest
Warning

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

Go to latest
Published: Jul 31, 2024 License: AGPL-3.0 Imports: 7 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func IsIngestionError

func IsIngestionError(err error) bool

Types

type Error

type Error struct{ Err error }

func (Error) Error

func (e Error) Error() string

func (Error) Unwrap

func (e Error) Unwrap() error

type Format

type Format string
const (
	FormatPprof      Format = "pprof"
	FormatJFR        Format = "jfr"
	FormatTrie       Format = "trie"
	FormatTree       Format = "tree"
	FormatLines      Format = "lines"
	FormatGroups     Format = "groups"
	FormatSpeedscope Format = "speedscope"
)

type IngestInput

type IngestInput struct {
	Format   Format
	Profile  RawProfile
	Metadata Metadata
}

type Ingester

type Ingester interface {
	Ingest(context.Context, *IngestInput) error
}

type Metadata

type Metadata struct {
	StartTime       time.Time
	EndTime         time.Time
	Key             *segment.Key
	SpyName         string
	SampleRate      uint32
	Units           metadata.Units
	AggregationType metadata.AggregationType
}

type ParseableToPprof added in v1.1.0

type ParseableToPprof interface {
	ParseToPprof(context.Context, Metadata) (*distributormodel.PushRequest, error)
}

type RawProfile

type RawProfile interface {
	Parse(context.Context, storage.Putter, storage.MetricsExporter, Metadata) error
}

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL