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 APPLICATION + const APPLICATION_1M + const APPLICATION_1S + const APPLICATION_LAYER + const APPLICATION_MAP_1M + const APPLICATION_MAP_1S + const CAPTURE_INFO + const CATEGORY_K8S_LABEL + const CATEGORY_METRICS + const CATEGORY_TAG + const CUSTOM_TAG + const ConditionAnd + const ConditionOr + const DATA_LINK_LAYER + const DELAY + const DefaultExportOtherBatchSize + const DefaultExportOtlpBatchSize + const DefaultExportQueueCount + const DefaultExportQueueSize + const ERROR + const EVENT_INFO + const FLOW_INFO + const K8S_LABEL + const L3_THROUGHPUT + const L4_FLOW_LOG + const L4_THROUGHPUT + const L7_FLOW_LOG + const MAX_DATASOURCE_ID + const METRICS + const NATIVE_TAG + const NETWORK_1M + const NETWORK_1S + const NETWORK_LAYER + const NETWORK_MAP_1M + const NETWORK_MAP_1S + const PERF_EVENT + const SERVICE_INFO + const SecurityProtocol + const TAG + const TCP_ERROR + const TCP_SLOW + const THROUGHPUT + const TOPIC_PREFIX + const TRACING_INFO + const TRANSPORT_LAYER + const TUNNEL_INFO + const UNIVERSAL_TAG + const UNKNOWN_CATEGORY + var DefaultExportCategory = []string + func CategoryBitsToString(bits uint64) string + func FlowLogMessageToDataSourceID(messageType datatype.MessageType) uint32 + func GetK8sLabelConfigs(strs []string) []string + func StringToCategoryBit(str string) uint64 + func StringsToCategoryBits(strs []string) uint64 + func StringsToDataSourceBits(strs []string) uint32 + func TagStringToDataSourceBits(s string) uint32 + type AndConditionHandler struct + func (a *AndConditionHandler) Decision(val bool) (bool, bool) + func (a *AndConditionHandler) Init() + type ConditionHandler interface + Decision func(bool) (bool, bool) + Init func() + type Config struct + Base *config.Config + Exporters []ExporterCfg + func Load(base *config.Config, path string) *Config + func (c *Config) Validate() error + type DataSourceID uint32 + func ToDataSourceID(str string) (DataSourceID, error) + func (d DataSourceID) IsMap() bool + func (d DataSourceID) String() string + func (d DataSourceID) TopicString() string + type ExportProtocol uint8 + const MAX_PROTOCOL_ID + const PROTOCOL_KAFKA + const PROTOCOL_OTLP + const PROTOCOL_PROMETHEUS + func (p ExportProtocol) String() string + type ExporterCfg struct + BatchSize int + DataSourceBits uint32 + DataSources []string + Enabled bool + Endpoints []string + EnumTranslateToNameDisabled bool + ExportEmptyMetricsDisabled bool + ExportEmptyTag bool + ExportFieldCategoryBits uint64 + ExportFieldK8s []string + ExportFieldNames []string + ExportFieldStructTags [MAX_DATASOURCE_ID][]StructTags + ExportFields []string + ExportProtocol ExportProtocol + ExtraHeaders map[string]string + FlusTimeout int + Protocol string + QueueCount int + QueueSize int + RandomEndpoints []string + Sasl Sasl + TagFieltertStructTags [MAX_DATASOURCE_ID][]StructTags + TagFilterCondition TagFilterCondition + TagFilters []TagFilter + Topic string + UniversalTagTranslateToNameDisabled bool + func (cfg *ExporterCfg) Validate() error + type ExportersConfig struct + Exporters Config + type OperatorID uint8 + const EQ + const IN + const INVALID_OPERATOR_ID + const NEQ + const NOT_IN + const REGEXP_EQ + const REGEXP_NEQ + const WILDCARD_EQ + const WILDCARD_NEQ + func (o OperatorID) String() string + type OrConditionHandler struct + func (o *OrConditionHandler) Decision(val bool) (bool, bool) + func (o *OrConditionHandler) Init() + type Sasl struct + Enabled bool + Mechanism string + Password string + SecurityProtocol string + Username string + func (s *Sasl) Validate() error + type StructTags struct + Category string + CategoryBit uint64 + DataKind reflect.Kind + DataSourceID uint32 + DataType utils.DataType + DataTypeStr string + EnumFile string + EnumIntMap map[int]string + EnumStringMap map[string]string + FieldName string + IsExportedField bool + MapName string + Name string + Offset uintptr + Omitempty bool + SubCategoryBit uint64 + TagDataSourceBits uint32 + TagDataSourceStr string + TagFilters []TagFilter + ToStringFunc reflect.Value + ToStringFuncName string + UniversalTagMapID uint8 + type TagFilter struct + FieldFloat64s []float64 + FieldName string + FieldValues []string + Operator string + OperatorId OperatorID + RegexpComplied *regexp.Regexp + func (t *TagFilter) MatchFloatValue(value float64) bool + func (t *TagFilter) MatchStringValue(value string) bool + func (t *TagFilter) MatchValue(value interface{}) bool + func (t *TagFilter) Validate() + type TagFilterCondition struct + ConditionType string + func (t *TagFilterCondition) NewConditionHandler() ConditionHandler + func (t *TagFilterCondition) Validate()
Go to main page