ingestion

Documentation

Index

• func IsIngestionError(err error) bool
• type Error
  • func (e Error) Error() string
  • func (e Error) Unwrap() error
• type Format
• type IngestInput
• type Ingester
• type Metadata
• type NoopIngester
  • func NewNoopIngester() *NoopIngester
  • func (*NoopIngester) Ingest(_ context.Context, _ *IngestInput) error
• type Parallelizer
  • func NewParallelizer(log *logrus.Logger, ingesters ...Ingester) *Parallelizer
  • func (p *Parallelizer) Ingest(ctx context.Context, in *IngestInput) error
• type RawProfile

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 NoopIngester

type NoopIngester struct{}

func NewNoopIngester

func NewNoopIngester() *NoopIngester

func (*NoopIngester) Ingest

func (*NoopIngester) Ingest(_ context.Context, _ *IngestInput) error

type Parallelizer

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

func NewParallelizer

func NewParallelizer(log *logrus.Logger, ingesters ...Ingester) *Parallelizer

func (*Parallelizer) Ingest

func (p *Parallelizer) Ingest(ctx context.Context, in *IngestInput) error

type RawProfile

type RawProfile interface {
	Parse(context.Context, storage.Putter, storage.MetricsExporter, Metadata) error
	Bytes() ([]byte, error)
	// ContentType denotes Bytes output type. Must be only called after Bytes.
	ContentType() string
}