decoder

Documentation

Index

• Constants
• type Counter
• type Decoder
  • func NewDecoder(index int, msgType datatype.MessageType, compressionAlgo string, ...) *Decoder
  • func (d *Decoder) GetCounter() interface{}
  • func (d *Decoder) Run()
• type Parser
  • func (p *Parser) Evaluate(i *storage.PutInput) (storage.SampleObserver, bool)
  • func (s Parser) Observe(k []byte, v int)
  • func (p *Parser) Put(ctx context.Context, i *storage.PutInput) error

Constants

const (
	BUFFER_SIZE = 1024

	UNICODE_NULL = "\x00"
)

const (
	// the maximum duration of off-cpu profile is 1h + <1s
	MAX_OFF_CPU_PROFILE_SPLIT_COUNT = 4000
	DEFAULT_COMPRESSION_ALGO        = "zstd"
)

Types

type Counter

type Counter struct {
	RawCount           int64 `statsd:"raw-count"`
	JavaProfileCount   int64 `statsd:"java-profile-count"`
	GolangProfileCount int64 `statsd:"golang-profile-count"`
	EBPFProfileCount   int64 `statsd:"ebpf-profile-count"`

	UncompressSize int64 `statsd:"uncompress-size"`
	CompressedSize int64 `statsd:"compressed-size"`

	TotalTime int64 `statsd:"total-time"`
	AvgTime   int64 `statsd:"avg-time"`

	OffCpuSplitCount     int64 `statsd:"off-cpu-split-count"`
	OffCpuSplitIntoCount int64 `statsd:"off-cpu-split-into-count"`
	OffCputNotSplitCount int64 `statsd:"off-cput-not-split-count"`
}

type Decoder

type Decoder struct {
	utils.Closable
	// contains filtered or unexported fields
}

func NewDecoder

func NewDecoder(index int, msgType datatype.MessageType, compressionAlgo string,
	offCpuSplittingGranularity int,
	platformData *grpc.PlatformInfoTable,
	inQueue queue.QueueReader,
	profileWriter *dbwriter.ProfileWriter,
	appServiceTagWriter *flow_tag.AppServiceTagWriter) *Decoder

func (*Decoder) GetCounter

func (d *Decoder) GetCounter() interface{}

func (*Decoder) Run

func (d *Decoder) Run()

type Parser

type Parser struct {
	IP net.IP

	*Counter
	// contains filtered or unexported fields
}

func (*Parser) Evaluate

func (p *Parser) Evaluate(i *storage.PutInput) (storage.SampleObserver, bool)

implement storage.MetricsExporter triggered by input.Profile.Parse

func (Parser) Observe

func (s Parser) Observe(k []byte, v int)

func (*Parser) Put

func (p *Parser) Put(ctx context.Context, i *storage.PutInput) error

implement storage.Putter triggered by input.Profile.Parse