streaming

Documentation

Index

• Constants
• Variables
• func UnmarshalVTLabel(dAtA []byte) (uint64, error)
• type Labels
  • func CutLabel(a arenahelper.ArenaWrapper, labels Labels, i int) Labels
  • func (l Labels) Hash() uint64
  • func (l Labels) Len() int
  • func (l Labels) Less(i, j int) bool
  • func (l Labels) Swap(i, j int)
• type LabelsCache
  • func (c *LabelsCache) Get(sampleTypeIndex int, h uint64) (*tree.Tree, bool)
  • func (c *LabelsCache) GetOrCreateTree(sampleTypeIndex int, l Labels) *tree.Tree
  • func (c *LabelsCache) Remove(sampleTypeIndex int, h uint64)
  • func (c *LabelsCache) Reset()
• type ParseWriteBatchInput
• type ParserConfig
• type StackFormatter
  • func StackFrameFormatterForSpyName(spyName string) StackFormatter
• type VTStreamingParser
  • func NewStreamingParser(config ParserConfig) *VTStreamingParser
  • func VTStreamingParserFromPool(config ParserConfig) *VTStreamingParser
  • func (p *VTStreamingParser) FreeArena()
  • func (p *VTStreamingParser) ParsePprof(ctx context.Context, startTime, endTime time.Time, bs []byte, ...) (err error)
  • func (p *VTStreamingParser) ParseWithWriteBatch(input ParseWriteBatchInput) (err error)
  • func (p *VTStreamingParser) Reset(config ParserConfig)
  • func (p *VTStreamingParser) ResetCache()
  • func (p *VTStreamingParser) ResolveLabels(l Labels) map[string]string
  • func (p *VTStreamingParser) ReturnToPool()
  • func (p *VTStreamingParser) UnmarshalVTProfile(dAtA []byte, opFlag uint64) error

Constants

const (
	// StackFrameFormatterGo use only function name
	StackFrameFormatterGo = 0
	// StackFrameFormatterRuby use function name, line number, function name
	StackFrameFormatterRuby = 1
)

Variables

var (
	ErrInvalidLength        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflow          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroup = fmt.Errorf("proto: unexpected end of group")
	ErrUnknownField         = fmt.Errorf("proto: unknown field")
)

var PPROFBufPool = bytebufferpool.Pool{}

Functions

func UnmarshalVTLabel

func UnmarshalVTLabel(dAtA []byte) (uint64, error)

revive:disable-next-line:cognitive-complexity,cyclomatic necessary complexity

Types

type Labels

type Labels []uint64

func CutLabel

func CutLabel(a arenahelper.ArenaWrapper, labels Labels, i int) Labels

CutLabel creates a copy of labels without label i.

func (Labels) Hash

func (l Labels) Hash() uint64

func (Labels) Len

func (l Labels) Len() int

func (Labels) Less

func (l Labels) Less(i, j int) bool

func (Labels) Swap

func (l Labels) Swap(i, j int)

type LabelsCache

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

func (*LabelsCache) Get

func (c *LabelsCache) Get(sampleTypeIndex int, h uint64) (*tree.Tree, bool)

func (*LabelsCache) GetOrCreateTree

func (c *LabelsCache) GetOrCreateTree(sampleTypeIndex int, l Labels) *tree.Tree

func (*LabelsCache) Remove

func (c *LabelsCache) Remove(sampleTypeIndex int, h uint64)

func (*LabelsCache) Reset

func (c *LabelsCache) Reset()

type ParseWriteBatchInput

type ParseWriteBatchInput struct {
	Context            context.Context
	StartTime, EndTime time.Time
	Profile, Previous  []byte
	WriteBatchFactory  stackbuilder.WriteBatchFactory
}

type ParserConfig

type ParserConfig struct {
	Putter        storage.Putter
	SpyName       string
	Labels        map[string]string
	SampleTypes   map[string]*tree.SampleTypeConfig
	Formatter     StackFormatter
	ArenasEnabled bool
}

type StackFormatter

type StackFormatter int

func StackFrameFormatterForSpyName

func StackFrameFormatterForSpyName(spyName string) StackFormatter

type VTStreamingParser

type VTStreamingParser struct {
	Formatter     StackFormatter
	ArenasEnabled bool
	// contains filtered or unexported fields
}

func NewStreamingParser

func NewStreamingParser(config ParserConfig) *VTStreamingParser

func VTStreamingParserFromPool

func VTStreamingParserFromPool(config ParserConfig) *VTStreamingParser

func (*VTStreamingParser) FreeArena

func (p *VTStreamingParser) FreeArena()

func (*VTStreamingParser) ParsePprof

func (p *VTStreamingParser) ParsePprof(ctx context.Context, startTime, endTime time.Time, bs []byte, cumulativeOnly bool) (err error)

func (*VTStreamingParser) ParseWithWriteBatch

func (p *VTStreamingParser) ParseWithWriteBatch(input ParseWriteBatchInput) (err error)

func (*VTStreamingParser) Reset

func (p *VTStreamingParser) Reset(config ParserConfig)

func (*VTStreamingParser) ResetCache

func (p *VTStreamingParser) ResetCache()

func (*VTStreamingParser) ResolveLabels

func (p *VTStreamingParser) ResolveLabels(l Labels) map[string]string

func (*VTStreamingParser) ReturnToPool

func (p *VTStreamingParser) ReturnToPool()

func (*VTStreamingParser) UnmarshalVTProfile

func (p *VTStreamingParser) UnmarshalVTProfile(dAtA []byte, opFlag uint64) error

revive:disable-next-line:cognitive-complexity,cyclomatic necessary complexity