Versions in this module Expand all Collapse all v1 v1.6.65 Sep 23, 2024 v1.6.64 Sep 13, 2024 v1.6.4 Sep 13, 2024 Changes in this version + const DefaultExchangeTimeout + const DefaultInfluxDBTimeout + const DefaultQueryTimeout + const GROUP_ID_MAP_ROLE_BOTH + const GROUP_ID_MAP_ROLE_CLIENT + const GROUP_ID_MAP_ROLE_SERVER + const OPT_STATUS_FAILED + const OPT_STATUS_OK + const OPT_STATUS_PARTIAL_DATA + var AggOpMap = map[string]AggOp + var AggOpMapRev map[AggOp]string + var PeriAggFieldSize = map[PeriAggOp]int + var PeriAggOpMap = map[string]PeriAggOp + var PeriAggOpMapRev map[PeriAggOp]string + var SUPPORTED_ID_MAP = []struct{ ... } + var TagCodeMap = map[TagName]struct + type AdaptiveGroupBy struct + AlterTags []TagName + Tags []TagName + TieredTags [][]TagName + type AggOp uint8 + const AGG_OP_AVG + const AGG_OP_AVG_DIV_SUM + const AGG_OP_AVG_SUM + const AGG_OP_DISTINCT + const AGG_OP_HISTOGRAM + const AGG_OP_HISTOGRAM_DIV_SUM + const AGG_OP_HISTOGRAM_SUM + const AGG_OP_LAST_SUM + const AGG_OP_MAX + const AGG_OP_MAX_DIV_SUM + const AGG_OP_MAX_SUM + const AGG_OP_MIN + const AGG_OP_MIN_DIV_SUM + const AGG_OP_MIN_SUM + const AGG_OP_PERCENTILE + const AGG_OP_PERCENTILE_DIV_SUM + const AGG_OP_PERCENTILE_SUM + const AGG_OP_STDDEV + const AGG_OP_STDDEV_DIV_SUM + const AGG_OP_STDDEV_SUM + const AGG_OP_SUM + func (o *AggOp) UnmarshalJSON(b []byte) error + func (o AggOp) MarshalJSON() ([]byte, error) + func (o AggOp) String() string + type Aggregation struct + DistinctExclude [][]string + Field string + Fields []string + IsTimeField bool + Op AggOp + Parameters []string + ResultFieldName string + func (a *Aggregation) Validate() error + type Duration time.Duration + func (d *Duration) UnmarshalJSON(b []byte) error + func (d Duration) MarshalJSON() ([]byte, error) + func (d Duration) String() string + type GroupByTime struct + Granularity Duration + GranularityInSeconds int32 + Offset Duration + OffsetInSeconds int32 + Step Duration + StepInSeconds int32 + WindowSize Duration + WindowSizeInSeconds int32 + func (t *GroupByTime) AlignTimestamp(ts uint32) uint32 + func (t *GroupByTime) GetEffectiveTimestampRange(ts uint32) (uint32, uint32) + type GroupIDMap struct + CIDRs []string + GroupID uint16 + IPRanges []string + L3EpcID int32 + PodGroupID uint16 + Protocol uint16 + Role string + ServerPorts string + ServiceID uint32 + type KeyValuePair struct + Key string + Value string + type MeterRange struct + Field string + Max uint64 + Min uint64 + type ModuleTime struct + Module string + Time string + type NewTagFilter struct + ExcludeSet []int32 + In []int32 + NotIn []int32 + type OptStatus string + type PeerStats struct + Finished bool + Peer string + Received uint64 + type PeriAggOp uint8 + const PERI_AGG_OP_DEDUP_ADD + const PERI_AGG_OP_DIV + const PERI_AGG_OP_RELATIVE_SUB + const PERI_AGG_OP_SUB + const PERI_AGG_OP_SUM + func (o *PeriAggOp) UnmarshalJSON(b []byte) error + func (o PeriAggOp) MarshalJSON() ([]byte, error) + func (o PeriAggOp) String() string + type PeriAggregation struct + Fields []string + Op PeriAggOp + ResultFieldName string + type PointGroup struct + Fields [][]interface{} + Tags []string + type Query struct + CustomTagMap []KeyValuePair + GroupByTags []AdaptiveGroupBy + GroupIDMap []GroupIDMap + IPMaskLen int + IPMaskLen0 int + IPMaskLen1 int + NewTagFilters []NewTagFilter + SQL string + TagIDMap []TagIDMap + type QueryData struct + AdaptiveGroupByTags []AdaptiveGroupBy + Aggregation []Aggregation + CustomTagMap []KeyValuePair + DBPort uint16 + ExchangeTimeout Duration + GroupByTags []TagName + GroupIDMap []GroupIDMap + IPMaskLen int + IPMaskLen0 int + IPMaskLen1 int + InfluxDBTimeout Duration + NewTagFilters []NewTagFilter + PostAggregation []PeriAggregation + PreAggregation []PeriAggregation + Queries []Query + QueryID uint32 + QueryTimeout Duration + Reciters []string + ReduceReciters []string + SQL string + SpanContext string + TagIDMap []TagIDMap + ThisReciter int + func (q *QueryData) FromBytes(b []byte) error + func (q *QueryData) ToBytes() ([]byte, error) + type QueryResult struct + Description string + ModuleTime []ModuleTime + PeerStats []PeerStats + QueryHits uint64 + QueryID uint32 + func QueryResultFromBytes(b []byte) (*QueryResult, error) + func (q *QueryResult) FromBytes(b []byte) error + func (q *QueryResult) ToBytes() ([]byte, error) + type QueryStats struct + Exchange QueryStatsItem + GlobalReducer []QueryStatsItem + InfluxDB QueryStatsItem + Mapper []QueryStatsItem + Reducer []QueryStatsItem + Sorter QueryStatsItem + Total QueryStatsItem + func (s *QueryStats) String() string + type QueryStatsItem struct + EndTime time.Duration + Processed uint64 + StartTime time.Duration + func (it *QueryStatsItem) Elapsed() time.Duration + func (it *QueryStatsItem) String() string + type QueryStatsItems []QueryStatsItem + func (it QueryStatsItems) Elapsed() time.Duration + func (it QueryStatsItems) String() string + type ResultData struct + Data []PointGroup + FieldColumns []string + TagColumns []string + type Sort struct + Field string + Limit uint + Order SortOrder + type SortOrder string + const SORT_ORDER_ASC + const SORT_ORDER_DESC + type TagIDMap struct + Default int32 + Fields []TagName + RawDefault string + RawRules []TagIDMapRawRule + ResultFieldName string + Rules []TagIDMapRule + func (m *TagIDMap) ParseRawRules() error + type TagIDMapRawRule struct + From [][]string + To string + type TagIDMapRule struct + From [][]int32 + To int32 + type TagName string + const TAG_ACL_GID + const TAG_AZ_ID + const TAG_AZ_ID_0 + const TAG_AZ_ID_1 + const TAG_DIRECTION + const TAG_GROUP_ID + const TAG_GROUP_ID_0 + const TAG_GROUP_ID_1 + const TAG_HOST_ID + const TAG_HOST_ID_0 + const TAG_HOST_ID_1 + const TAG_IP + const TAG_IP_0 + const TAG_IP_1 + const TAG_IP_VERSION + const TAG_L2_DEVICE_ID + const TAG_L2_DEVICE_ID_0 + const TAG_L2_DEVICE_ID_1 + const TAG_L2_DEVICE_TYPE + const TAG_L2_DEVICE_TYPE_0 + const TAG_L2_DEVICE_TYPE_1 + const TAG_L2_EPC_ID + const TAG_L2_EPC_ID_0 + const TAG_L2_EPC_ID_1 + const TAG_L3_DEVICE_ID + const TAG_L3_DEVICE_ID_0 + const TAG_L3_DEVICE_ID_1 + const TAG_L3_DEVICE_TYPE + const TAG_L3_DEVICE_TYPE_0 + const TAG_L3_DEVICE_TYPE_1 + const TAG_L3_EPC_ID + const TAG_L3_EPC_ID_0 + const TAG_L3_EPC_ID_1 + const TAG_POD_CLUSTER_ID + const TAG_POD_CLUSTER_ID_0 + const TAG_POD_CLUSTER_ID_1 + const TAG_POD_GROUP_ID + const TAG_POD_GROUP_ID_0 + const TAG_POD_GROUP_ID_1 + const TAG_POD_ID + const TAG_POD_ID_0 + const TAG_POD_ID_1 + const TAG_POD_NODE_ID + const TAG_POD_NODE_ID_0 + const TAG_POD_NODE_ID_1 + const TAG_POD_NS_ID + const TAG_POD_NS_ID_0 + const TAG_POD_NS_ID_1 + const TAG_PROTOCOL + const TAG_REGION_ID + const TAG_REGION_ID_0 + const TAG_REGION_ID_1 + const TAG_SERVER_PORT + const TAG_SUBNET_ID + const TAG_SUBNET_ID_0 + const TAG_SUBNET_ID_1 + const TAG_TAG_TYPE + const TAG_TAG_VALUE + const TAG_TAP_PORT + const TAG_TAP_SIDE + const TAG_TAP_TYPE + const TAG_TIMESTAMP + const TAG_VTAP_ID + type TimeUnit string + const TIME_UNIT_MILLISECOND + const TIME_UNIT_SECOND
Go to main page