decoder

package

v1.6.65 Latest Latest Go to latest Published: Sep 23, 2024 License: Apache-2.0 Imports: 29 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/deepflowio/deepflow

Links

Open Source Insights

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

Constants ¶

View Source

const (
	BUFFER_SIZE = 1024

	UNICODE_NULL = "\x00"
)

View Source

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

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

	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

Source Files ¶

View all Source files

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