ingestion

type Error struct{ Err error }

type Format string

type IngestInput struct {
	Format   Format
	Profile  RawProfile
	Metadata Metadata
}

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

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

type NoopIngester struct{}

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

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
}