pyroscope

Documentation

Index

• Constants
• Variables
• type Appendable
• type AppendableFunc
  • func (f AppendableFunc) Append(ctx context.Context, labels labels.Labels, samples []*RawSample) error
  • func (f AppendableFunc) AppendIngest(_ context.Context, _ *IncomingProfile) error
  • func (f AppendableFunc) Appender() Appender
• type AppendableIngestFunc
  • func (f AppendableIngestFunc) Append(_ context.Context, _ labels.Labels, _ []*RawSample) error
  • func (f AppendableIngestFunc) AppendIngest(ctx context.Context, p *IncomingProfile) error
  • func (f AppendableIngestFunc) Appender() Appender
• type Appender
• type Fanout
  • func NewFanout(children []Appendable, componentID string, register prometheus.Registerer) *Fanout
  • func (f *Fanout) Appender() Appender
  • func (f *Fanout) Children() []Appendable
  • func (f *Fanout) UpdateChildren(children []Appendable)
• type IncomingProfile
• type RawSample

Constants

const (
	LabelNameDelta   = "__delta__"
	LabelName        = "__name__"
	LabelServiceName = "service_name"
)

Variables

var NoopAppendable = AppendableFunc(func(_ context.Context, _ labels.Labels, _ []*RawSample) error { return nil })

Types

type Appendable

type Appendable interface {
	Appender() Appender
}

type AppendableFunc

type AppendableFunc func(ctx context.Context, labels labels.Labels, samples []*RawSample) error

func (AppendableFunc) Append

func (f AppendableFunc) Append(ctx context.Context, labels labels.Labels, samples []*RawSample) error

func (AppendableFunc) AppendIngest

func (f AppendableFunc) AppendIngest(_ context.Context, _ *IncomingProfile) error

func (AppendableFunc) Appender

func (f AppendableFunc) Appender() Appender

type AppendableIngestFunc

type AppendableIngestFunc func(ctx context.Context, profile *IncomingProfile) error

For testing AppendIngest operations

func (AppendableIngestFunc) Append

func (f AppendableIngestFunc) Append(_ context.Context, _ labels.Labels, _ []*RawSample) error

func (AppendableIngestFunc) AppendIngest

func (f AppendableIngestFunc) AppendIngest(ctx context.Context, p *IncomingProfile) error

func (AppendableIngestFunc) Appender

func (f AppendableIngestFunc) Appender() Appender

type Appender

type Appender interface {
	Append(ctx context.Context, labels labels.Labels, samples []*RawSample) error
	AppendIngest(ctx context.Context, profile *IncomingProfile) error
}

type Fanout

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

Fanout supports the default Alloy style of appendables since it can go to multiple outputs. It also allows the intercepting of appends.

func NewFanout

func NewFanout(children []Appendable, componentID string, register prometheus.Registerer) *Fanout

NewFanout creates a fanout appendable.

func (*Fanout) Appender

func (f *Fanout) Appender() Appender

Appender satisfies the Appendable interface.

func (*Fanout) Children

func (f *Fanout) Children() []Appendable

Children returns the children of the fanout.

func (*Fanout) UpdateChildren

func (f *Fanout) UpdateChildren(children []Appendable)

UpdateChildren allows changing of the children of the fanout.

type IncomingProfile

type IncomingProfile struct {
	RawBody []byte
	Headers http.Header
	URL     *url.URL
	Labels  labels.Labels
}

type RawSample

type RawSample struct {
	// raw_profile is the set of bytes of the pprof profile
	RawProfile []byte
}