Categorygithub.com/TencentBlueKing/bkmonitor-datalink/pkg/influxdb-proxybackendinfluxdb
package
3.9.1739+incompatible
Repository: https://github.com/tencentblueking/bkmonitor-datalink.git
Documentation: pkg.go.dev
Overview
Versions
1
Dependencies
23
Dependents
2
Files
2.5k SLOC

# Functions

DumpsBackendData : 负责将传入的内容写入到指定的string中并返回.
GetBrokerAddress 获取Broker地址.
KafkaStatusDown 将kafka状态改为down.
KafkaStatusUp 将kafka状态改为up.
LoadsBackendData :.
MakeKafkaConfig : 创建并返回一个kafka配置对象，直接读取配置文件的信息.
newBackendMetric :.
NewBuffer :.
NewBufferData :.
NewInfluxDBFrontend : client can only re-use but not share.

# Variables

NewBackend :.
stubbing :.
stubbing :.
NewHTTPClient :.
NewKafkaBackup :.
stubbing :.
stubbing :.
stubbing :.
stubbing :.
hash算法.
hash算法.

# Structs

Backend :.
Buffer 用于做缓存操作，集齐缓存数据后统一写入到influxdb中 为了换取开发的方便，所以在写入触发的时候，将会将所有的数据读取到buffer的缓存中，再逐一返回到外部.
BufferData :.
Data 备份数据结构.
KafkaConfig kafka配置项.
No description provided by the author
XDGSCRAMClient :.

# Interfaces

Broker :.
Client http.Client抽象接口.
StorageBackup :.

# Type aliases

CountAddFunc :.
CountIncFunc :.
DataHandler :.