profiler

Documentation

Index

• func IsEnabled(ctx context.Context) bool
• func LogProcessor(profiles []*TagsProfile) error
• func NewProfiler(processor Processor, interval, window time.Duration) *profiler
• func Tag(ctx context.Context)
• func Untag(ctx context.Context)
• type Processor
• type Profiler
• type TagsProfile

Functions

func IsEnabled

func IsEnabled(ctx context.Context) bool

IsEnabled returns true if profiler is enabled This func is short enough can be inlined, and likely it returns false

func LogProcessor

func LogProcessor(profiles []*TagsProfile) error

func NewProfiler

func NewProfiler(processor Processor, interval, window time.Duration) *profiler

func Tag

func Tag(ctx context.Context)

Tag current goroutine with tagged ctx it's used for reuse goroutine scenario

func Untag

func Untag(ctx context.Context)

Untag current goroutine with tagged ctx it's used for reuse goroutine scenario

Types

type Processor

type Processor func(profiles []*TagsProfile) error

type Profiler

type Profiler interface {
	Run(ctx context.Context) (err error)
	Stop()
	Pause()
	Resume()
	Prepare(ctx context.Context) context.Context
	Tag(ctx context.Context, tags ...string) context.Context
	Untag(ctx context.Context)
	Lookup(ctx context.Context, key string) (string, bool)
}

type TagsProfile

type TagsProfile struct {
	Key     string   // eg: a=1,b=2
	Tags    []string // eg: ["a", "1", "b", "2"]
	Value   int64    // pprof cpu times
	Percent float64  // <= 1.0
}

TagsProfile is the stats result group by tag key