decoder

package
v0.0.0-...-b8a1a0e Latest Latest
Warning

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

Go to latest
Published: Jan 31, 2024 License: Apache-2.0 Imports: 29 Imported by: 0

Documentation

Index

Constants

View Source
const (
	BUFFER_SIZE = 1024

	UNICODE_NULL = "\x00"
)

Variables

This section is empty.

Functions

This section is empty.

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"`
}

type Decoder

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

func NewDecoder

func NewDecoder(index int, msgType datatype.MessageType, compressionAlgo string,
	platformData *grpc.PlatformInfoTable,
	inQueue queue.QueueReader,
	profileWriter *dbwriter.ProfileWriter) *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

Jump to

Keyboard shortcuts

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