target

package
v0.9.0-rc.1 Latest Latest
Warning

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

Go to latest
Published: Jul 18, 2022 License: Apache-2.0 Imports: 16 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Group

type Group struct {
	// Targets is a list of targets identified by a label set. Each target is
	// uniquely identifiable in the group by its address label.
	Targets []model.LabelSet
	// Labels is a set of labels that is common across all targets in the group.
	Labels model.LabelSet

	// Source is an identifier that describes a group of targets.
	Source string
}

Group is a set of targets with a common label set(production , test, staging etc.).

func (Group) String

func (tg Group) String() string

type Manager

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

func NewManager

func NewManager(
	logger log.Logger,
	reg prometheus.Registerer,
	writeClient profilestorepb.ProfileStoreServiceClient,
	debugInfoClient debuginfo.Client,
	profilingDuration time.Duration,
	externalLabels model.LabelSet,
	samplingRatio float64,
) *Manager

func (*Manager) ActiveProfilers

func (m *Manager) ActiveProfilers() map[string][]Profiler

func (*Manager) Run

func (m *Manager) Run(ctx context.Context, update <-chan map[string][]*Group) error

type Profiler

type Profiler interface {
	Labels() model.LabelSet
	LastSuccessfulProfileStartedAt() time.Time
	NextProfileStartedAt() time.Time
	LastError() error
	Stop()
}

type ProfilerPool

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

func NewProfilerPool

func NewProfilerPool(
	logger log.Logger,
	reg prometheus.Registerer,
	ksymCache *ksym.Cache,
	objCache objectfile.Cache,
	writeClient profilestorepb.ProfileStoreServiceClient,
	debugInfoClient debuginfo.Client,
	profilingDuration time.Duration,
	externalLabels model.LabelSet,
	samplingRatio float64,
) *ProfilerPool

func (*ProfilerPool) Profilers

func (pp *ProfilerPool) Profilers() []Profiler

func (*ProfilerPool) Sync

func (pp *ProfilerPool) Sync(ctx context.Context, tg []*Group)

type Target

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

Jump to

Keyboard shortcuts

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