memdb

Documentation

Index

• Constants
• func WriteProfiles(metrics *HeadMetrics, profiles []v1.InMemoryProfile) ([]byte, error)
• type FlushedHead
• type Head
  • func NewHead(metrics *HeadMetrics) *Head
  • func (h *Head) Flush(ctx context.Context) (res *FlushedHead, err error)
  • func (h *Head) Ingest(p *profilev1.Profile, id uuid.UUID, externalLabels []*typesv1.LabelPair)
• type HeadMetrics
  • func NewHeadMetricsWithPrefix(reg prometheus.Registerer, prefix string) *HeadMetrics

Constants

const (
	SegmentsParquetWriteBufferSize = 8 * 0x1000
)

Functions

func WriteProfiles

func WriteProfiles(metrics *HeadMetrics, profiles []v1.InMemoryProfile) ([]byte, error)

Types

type FlushedHead

type FlushedHead struct {
	Index    []byte
	Profiles []byte
	Symbols  []byte
	Meta     struct {
		ProfileTypeNames []string
		MinTimeNanos     int64
		MaxTimeNanos     int64
		NumSamples       uint64
		NumProfiles      uint64
		NumSeries        uint64
	}
}

type Head

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

func NewHead

func NewHead(metrics *HeadMetrics) *Head

func (*Head) Flush

func (h *Head) Flush(ctx context.Context) (res *FlushedHead, err error)

func (*Head) Ingest

func (h *Head) Ingest(p *profilev1.Profile, id uuid.UUID, externalLabels []*typesv1.LabelPair)

type HeadMetrics

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

todo remove unused

func NewHeadMetricsWithPrefix

func NewHeadMetricsWithPrefix(reg prometheus.Registerer, prefix string) *HeadMetrics