servicegraphs

package
v1.5.0 Latest Latest
Warning

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

Go to latest
Published: Aug 17, 2022 License: AGPL-3.0 Imports: 20 Imported by: 0

Documentation

Index

Constants

View Source
const (
	Name = "service-graphs"
)

Variables

This section is empty.

Functions

func New

func New(cfg Config, tenant string, registry registry.Registry, logger log.Logger) gen.Processor

Types

type Config

type Config struct {
	// Wait is the value to wait for an edge to be completed
	Wait time.Duration `yaml:"wait"`
	// MaxItems is the amount of edges that will be stored in the storeMap
	MaxItems int `yaml:"max_items"`

	// Workers is the amount of workers that will be used to process the edges
	Workers int `yaml:"workers"`

	// Buckets for latency histogram in seconds.
	HistogramBuckets []float64 `yaml:"histogram_buckets"`

	// Additional dimensions (labels) to be added to the metric along with the default ones.
	// If client and server spans have the same attribute, behaviour is undetermined
	// (either value could get used)
	Dimensions []string `yaml:"dimensions"`
}

func (*Config) RegisterFlagsAndApplyDefaults

func (cfg *Config) RegisterFlagsAndApplyDefaults(prefix string, f *flag.FlagSet)

type Processor added in v1.5.0

type Processor struct {
	Cfg Config
	// contains filtered or unexported fields
}

func (*Processor) Name added in v1.5.0

func (p *Processor) Name() string

func (*Processor) PushSpans added in v1.5.0

func (p *Processor) PushSpans(ctx context.Context, req *tempopb.PushSpansRequest)

func (*Processor) Shutdown added in v1.5.0

func (p *Processor) Shutdown(_ context.Context)

Directories

Path Synopsis

Jump to

Keyboard shortcuts

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