unmarshaller

package
v0.0.0-...-8d187f3 Latest Latest
Warning

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

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

Documentation

Index

Constants

View Source 
const (
	EdgeCode    = flow_metrics.IPPath | flow_metrics.L3EpcIDPath
	MainAddCode = flow_metrics.RegionID | flow_metrics.HostID | flow_metrics.L3Device | flow_metrics.SubnetID | flow_metrics.PodNodeID | flow_metrics.AZID | flow_metrics.PodGroupID | flow_metrics.PodNSID | flow_metrics.PodID | flow_metrics.PodClusterID | flow_metrics.ServiceID | flow_metrics.Resource
	EdgeAddCode = flow_metrics.RegionIDPath | flow_metrics.HostIDPath | flow_metrics.L3DevicePath | flow_metrics.SubnetIDPath | flow_metrics.PodNodeIDPath | flow_metrics.AZIDPath | flow_metrics.PodGroupIDPath | flow_metrics.PodNSIDPath | flow_metrics.PodIDPath | flow_metrics.PodClusterIDPath | flow_metrics.ServiceIDPath | flow_metrics.ResourcePath
	PortAddCode = flow_metrics.IsKeyService

	SIGNAL_SOURCE_OTEL = 4
)
View Source 
const (
	QUEUE_BATCH_SIZE = 1024
	FLUSH_INTERVAL   = 5
	GET_MAX_SIZE     = 1024
	DOC_TIME_EXCEED  = 300
	HASH_SEED        = 17
)

Variables

View Source 
var APP_SERVICE_TAG_APPLICATION = strings.Split(flow_metrics.APPLICATION_1M.TableName(), ".")[0]

just write the app_service_tag of `1m` data, the app_service_tag of `1s`, `1h`... and other, can also use `1m` app_service_tag.

View Source 
var APP_SERVICE_TAG_APPLICATION_MAP = strings.Split(flow_metrics.APPLICATION_MAP_1M.TableName(), ".")[0]

Functions

func DecodeForQueueMonitor 

func DecodeForQueueMonitor(item interface{}) (interface{}, error)

func DocumentExpand 

func DocumentExpand(doc app.Document, platformData *grpc.PlatformInfoTable) error

func EncodeTo 

func EncodeTo(e app.Document, protocol config.ExportProtocol, utags *utag.UniversalTagsManager, cfg *config.ExporterCfg) (interface{}, error)

func EncodeToPrometheus 

func EncodeToPrometheus(e app.Document, utags *utag.UniversalTagsManager, cfg *config.ExporterCfg) (interface{}, error)

func QueryUniversalTags0 

func QueryUniversalTags0(e app.Document, utags *utag.UniversalTagsManager) *utag.UniversalTags

func QueryUniversalTags1 

func QueryUniversalTags1(e app.Document, utags *utag.UniversalTagsManager) *utag.UniversalTags

Types

type BatchDocument 

type BatchDocument []app.Document

func (BatchDocument) String 

func (bd BatchDocument) String() string

type Counter 

type Counter struct {
	DocCount        int64 `statsd:"doc-count"`
	ErrDocCount     int64 `statsd:"err-doc-count"`
	AverageDelay    int64 `statsd:"average-delay"`
	MaxDelay        int64 `statsd:"max-delay"`
	MinDelay        int64 `statsd:"min-delay"`
	ExpiredDocCount int64 `statsd:"expired-doc-count"`
	FutureDocCount  int64 `statsd:"future-doc-count"`
	DropDocCount    int64 `statsd:"drop-doc-count"`
	TotalTime       int64 `statsd:"total-time"`
	AvgTime         int64 `statsd:"avg-time"`

	FlowPortCount       int64 `statsd:"vtap-flow-port"`
	FlowPort1sCount     int64 `statsd:"vtap-flow-port-1s"`
	FlowEdgePortCount   int64 `statsd:"vtap-flow-edge-port"`
	FlowEdgePort1sCount int64 `statsd:"vtap-flow-edge-port-1s"`
	AclCount            int64 `statsd:"vtap-acl"`
	OtherCount          int64 `statsd:"other-db-count"`
}

type ExportDocumentApp 

type ExportDocumentApp app.DocumentApp

func (*ExportDocumentApp) AddReferenceCount 

func (e *ExportDocumentApp) AddReferenceCount()

func (*ExportDocumentApp) EncodeTo 

func (e *ExportDocumentApp) EncodeTo(protocol config.ExportProtocol, utags *utag.UniversalTagsManager, cfg *config.ExporterCfg) (interface{}, error)

func (*ExportDocumentApp) GetFieldValueByOffsetAndKind 

func (e *ExportDocumentApp) GetFieldValueByOffsetAndKind(offset uintptr, kind reflect.Kind, dataType utils.DataType) interface{}

func (*ExportDocumentApp) Meter 

func (e *ExportDocumentApp) Meter() flow_metrics.Meter

func (*ExportDocumentApp) Release 

func (e *ExportDocumentApp) Release()

func (*ExportDocumentApp) TimestampUs 

func (e *ExportDocumentApp) TimestampUs() int64

app document

type ExportDocumentFlow 

type ExportDocumentFlow app.DocumentFlow

func (*ExportDocumentFlow) AddReferenceCount 

func (e *ExportDocumentFlow) AddReferenceCount()

func (*ExportDocumentFlow) EncodeTo 

func (e *ExportDocumentFlow) EncodeTo(protocol config.ExportProtocol, utags *utag.UniversalTagsManager, cfg *config.ExporterCfg) (interface{}, error)

func (*ExportDocumentFlow) GetFieldValueByOffsetAndKind 

func (e *ExportDocumentFlow) GetFieldValueByOffsetAndKind(offset uintptr, kind reflect.Kind, dataType utils.DataType) interface{}

func (*ExportDocumentFlow) Meter 

func (e *ExportDocumentFlow) Meter() flow_metrics.Meter

func (*ExportDocumentFlow) Release 

func (e *ExportDocumentFlow) Release()

func (*ExportDocumentFlow) TimestampUs 

func (e *ExportDocumentFlow) TimestampUs() int64

flow document

type ExportDocumentUsage 

type ExportDocumentUsage app.DocumentUsage

func (*ExportDocumentUsage) AddReferenceCount 

func (e *ExportDocumentUsage) AddReferenceCount()

func (*ExportDocumentUsage) EncodeTo 

func (e *ExportDocumentUsage) EncodeTo(protocol config.ExportProtocol, utags *utag.UniversalTagsManager, cfg *config.ExporterCfg) (interface{}, error)

func (*ExportDocumentUsage) GetFieldValueByOffsetAndKind 

func (e *ExportDocumentUsage) GetFieldValueByOffsetAndKind(offset uintptr, kind reflect.Kind, dataType utils.DataType) interface{}

func (*ExportDocumentUsage) Meter 

func (e *ExportDocumentUsage) Meter() flow_metrics.Meter

func (*ExportDocumentUsage) Release 

func (e *ExportDocumentUsage) Release()

func (*ExportDocumentUsage) TimestampUs 

func (e *ExportDocumentUsage) TimestampUs() int64

usage document

type QueueCache 

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

type Unmarshaller 

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

func NewUnmarshaller 

func NewUnmarshaller(index int, platformData *grpc.PlatformInfoTable, disableSecondWrite bool, unmarshallQueue queue.QueueReader, dbwriter dbwriter.DbWriter, exporters *exporters.Exporters, appServiceTagWriter *flow_tag.AppServiceTagWriter) *Unmarshaller

func (*Unmarshaller) GetCounter 

func (u *Unmarshaller) GetCounter() interface{}

func (*Unmarshaller) QueueProcess 

func (u *Unmarshaller) QueueProcess()

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.