unmarshaller

Documentation

Index

• Constants
• func DecodeForQueueMonitor(item interface{}) (interface{}, error)
• func DocumentExpand(doc *app.Document, platformData *grpc.PlatformInfoTable) error
• type BatchDocument
  • func (bd BatchDocument) String() string
• type Counter
• type QueueCache
• type Unmarshaller
  • func NewUnmarshaller(index int, platformData *grpc.PlatformInfoTable, disableSecondWrite bool, ...) *Unmarshaller
  • func (u *Unmarshaller) GetCounter() interface{}
  • func (u *Unmarshaller) QueueProcess()

Constants

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

	SIGNAL_SOURCE_OTEL = 4
)

const (
	QUEUE_BATCH_SIZE = 1024
	FLUSH_INTERVAL   = 5
	GET_MAX_SIZE     = 1024
	DOC_TIME_EXCEED  = 300
	HASH_SEED        = 17
)

Functions

func DecodeForQueueMonitor

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

func DocumentExpand

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

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 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, dbwriters []dbwriter.DbWriter) *Unmarshaller

func (*Unmarshaller) GetCounter

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

func (*Unmarshaller) QueueProcess

func (u *Unmarshaller) QueueProcess()