flow_tag

type AppServiceCounter struct {
	CacheExpiredCount int64 `statsd:"cache-expired-count"`
	CacheAddCount     int64 `statsd:"cache-add-count"`
	CacheHitCount     int64 `statsd:"cache-hit-count"`
	CacheCount        int64 `statsd:"cache-count"`
}

type AppServiceTag struct {
	Time        uint32 // s
	Table       string
	AppService  string
	AppInstance string
	TeamID      uint16
	OrgId       uint16
}

type AppServiceTagWriter struct {
	Cache             *lru.Cache[AppServiceTag, uint32]
	CacheFlushTimeout uint32
	CacheKeyBuf       AppServiceTag

	utils.Closable
	// contains filtered or unexported fields
}

type Counter struct {
	NewFieldCount        int64 `statsd:"new-field-count"`
	NewFieldValueCount   int64 `statsd:"new-field-value-count"`
	FieldCacheCount      int64 `statsd:"field-cache-count"`
	FieldValueCacheCount int64 `statsd:"field-value-cache-count"`
}

type FieldType uint8

type FieldValueType uint8

type FlowTag struct {
	pool.ReferenceCount
	TagType

	Timestamp uint32 // s
	FlowTagInfo
}

type FlowTagCache struct {
	Id                          int
	FieldCache, FieldValueCache *lru.Cache[FlowTagInfo, uint32]
	CacheFlushTimeout           uint32

	// only for prometheus
	PrometheusFieldCache, PrometheusFieldValueCache *lru128.U128LRU

	// temporary buffers for generating new flow_tags
	FlowTagInfoBuffer FlowTagInfo
	Fields            []interface{}
	FieldValues       []interface{}
}

type FlowTagInfo struct {
	Table          string // Represents virtual_table_name in ext_metrics
	FieldName      string
	FieldValue     string
	FieldValueType FieldValueType
	VtapId         uint16

	// IDs only for prometheus
	TableId      uint32
	FieldNameId  uint32
	FieldValueId uint32

	VpcId     int32 // XXX: can use int16
	PodNsId   uint16
	FieldType FieldType

	// Not stored, only determines which database to store in.
	// When Orgid is 0 or 1, it is stored in database 'flow_tag', otherwise stored in '<OrgId>_flow_tag'.
	OrgId  uint16
	TeamID uint16
}

type FlowTagWriter struct {
	Cache *FlowTagCache

	utils.Closable
	// contains filtered or unexported fields
}

type TagType uint8