Versions in this module Expand all Collapse all v4 v4.0.4 Aug 4, 2021 v4.0.3 Jun 27, 2021 v4.0.2 Jun 1, 2021 v4.0.1 Apr 19, 2021 v4.0.0 Apr 15, 2021 Changes in this version + const COMMON_MODULE + const COUNTER + const DERIVE + const GAUGE + const GRAPH + const MachineDep + const MachineIndep + const SPLIT + const SUBTRACT + func DictedTagstring(s string) map[string]string + func GetCounter(metric, tag string, tagMap map[string]string) (counter string, err error) + func HasReservedWords(str string) bool + func NidToEndpoint(nid string) string + func PKWhitEndpointAndTags(endpoint, metric, tags string) string + func PKWithCounter(endpoint, counter string) string + func PKWithTags(metric, tags string) string + func SortedTags(tags map[string]string) string + func SplitTagsString(s string) (tags map[string]string, err error) + type AggrCalc struct + Category int + Comment string + Created time.Time + Creator string + Expression string + GlobalOperator string + GroupBy []string + GroupByString string + Id int64 + LastUpdated time.Time + LastUpdator string + NewMetric string + NewStep int + Nid int64 + Quota int + RPN string + RawMetrics []*RawMetric + RawMetricsString string + Status int + type AggrCalcStra struct + GlobalOperator string + GroupKey string + InnerOperator string + Lateness int + NID string + RPN string + RawStep int + ResultStep int + SID int64 + VarID string + VarNum int + type AggrList struct + Data []*CentralAggrV2Point + type AggrOut struct + Data struct{ ... } + Index string + Operate int + Type string + type AggrTagsFilter struct + Opt string + TagK string + TagV []string + type AssignTask struct + Action string + Clock int64 + Id int64 + type Auth struct + AuthProtocol string + Community Secret + ContextName string + Password Secret + PrivPassword Secret + PrivProtocol string + SecurityLevel string + Username string + type BuiltinMetric struct + Metric string + Tags string + func (bm *BuiltinMetric) String() string + type BuiltinMetricRequest struct + Checksum string + IP string + Ty int + type BuiltinMetricResponse struct + Checksum string + ErrCode int + Metrics []*BuiltinMetric + Timestamp int64 + func (br *BuiltinMetricResponse) String() string + type BuiltinMetricSlice []*BuiltinMetric + func (bm BuiltinMetricSlice) Len() int + func (bm BuiltinMetricSlice) Less(i, j int) bool + func (bm BuiltinMetricSlice) Swap(i, j int) + type CentralAggrV2Point struct + Hash uint64 + Strategys []*AggrCalcStra + Timestamp int64 + Value float64 + type CludeRecv struct + End int64 + EndExclusive time.Time + Endpoints []string + Exclude []*TagPair + Include []*TagPair + Metric string + Nids []string + Start int64 + StartInclusive time.Time + func (p *CludeRecv) Validate() (err error) + type EndpointMetricRecv struct + End int64 + EndExclusive time.Time + Endpoints []string + Metrics []string + Nids []string + Start int64 + StartInclusive time.Time + func (p *EndpointMetricRecv) Validate() (err error) + type EndpointsRecv struct + End int64 + EndExclusive time.Time + Endpoints []string + Nids []string + Start int64 + StartInclusive time.Time + func (p *EndpointsRecv) Validate() (err error) + type Event struct + CurNid string + Detail string + Endpoint string + Etime int64 + EventType string + Hashid uint64 + History []History + ID string + Info string + Partition string + Sid int64 + Value string + type File struct + Body []byte + Filename string + Key interface{} + type History struct + Granularity int + Key string + Metric string + Points []*HistoryData + Tags map[string]string + type HistoryData struct + Extra string + Timestamp int64 + Value JsonFloat + func RRDData2HistoryData(datas []*RRDData) []*HistoryData + type IPAndSnmp struct + Auth string + IP string + LastUpdated time.Time + Metric Metric + Module string + Port int + Region string + Step int + Timeout int + Version string + type IPAndSnmpRpcResp struct + Data []*IPAndSnmp + Msg string + type IfTags struct + IfIndex string + IfName string + type Index struct + FixedSize int + Implied bool + Labelname string + Type string + type IndexByFullTagsRecv struct + End int64 + EndExclusive time.Time + Endpoints []string + Metric string + Nids []string + Start int64 + StartInclusive time.Time + Tagkv []TagPair + func (p *IndexByFullTagsRecv) Validate() (err error) + type IndexByFullTagsResp struct + Count int + DsType string + Endpoints []string + Metric string + Nids []string + Step int + Tags []string + type IndexModel struct + DsType string + Endpoint string + Metric string + Nid string + Step int + Tags map[string]string + Timestamp int64 + type IndexResp struct + Invalid int + Latency int64 + Msg string + Total int + type IndexTagkvResp struct + Endpoints []string + Metric string + Nids []string + Tagkv []*TagPair + type InfluxdbItem struct + Fields map[string]interface{} + Measurement string + Tags map[string]string + Timestamp int64 + type JsonFloat float64 + func (v JsonFloat) MarshalJSON() ([]byte, error) + type JudgeItem struct + DsType string + Endpoint string + Extra string + Metric string + Nid string + Sid int64 + Step int + Tags string + TagsMap map[string]string + Timestamp int64 + Value float64 + func (j *JudgeItem) MD5() string + func (j *JudgeItem) PrimaryKey() string + type Lookup struct + Labelname string + Labels []string + Oid string + Type string + type Message struct + Content string + Subject string + Tos []string + type Metric struct + EnumValues map[int]string + Help string + Indexes []*Index + Lookups []*Lookup + Name string + Oid string + RegexpExtracts map[string][]RegexpExtract + Type string + type MetricResp struct + Metrics []string + type MetricValue struct + CounterType string + Endpoint string + Extra string + Metric string + Nid string + Step int64 + Tags string + TagsMap map[string]string + Timestamp int64 + Value float64 + ValueUntyped interface{} + func (m *MetricValue) CheckValidity(now int64) (err error) + func (m *MetricValue) PK() string + type Notify struct + Content string + Subject string + Tos []string + type NullRpcRequest struct + type OpenTsdbItem struct + Metric string + Tags map[string]string + Timestamp int64 + Value float64 + func (t *OpenTsdbItem) OpenTsdbString() (s string) + func (t *OpenTsdbItem) String() string + type QueryData struct + ConsolFunc string + Counters []string + DsType string + End int64 + Endpoints []string + Nids []string + Start int64 + Step int + func (req *QueryData) Key() string + type QueryDataForUI struct + AggrFunc string + Comparisons []int64 + ConsolFunc string + DsType string + End int64 + Endpoints []string + GroupKey []string + Metric string + Nids []string + Start int64 + Step int + Tags []string + type QueryDataForUIResp struct + Comparison int64 + Counter string + DsType string + End int64 + Endpoint string + Nid string + Start int64 + Step int + Values []*RRDData + type QueryDataResp struct + Data []*TsdbQueryResponse + Msg string + type RRDData struct + Timestamp int64 + Value JsonFloat + func HistoryData2RRDData(datas []*HistoryData) []*RRDData + func NewRRDData(ts int64, val float64) *RRDData + func (rrd *RRDData) String() string + type RRDFile struct + Filename string + Key interface{} + type RRDFileQuery struct + Files []RRDFile + type RRDFileResp struct + Files []File + Msg string + type RRDValues []*RRDData + func (r RRDValues) Len() int + func (r RRDValues) Less(i, j int) bool + func (r RRDValues) Swap(i, j int) + type RawMetric struct + Endpoints []string + ExclNid []int64 + Filters []*AggrTagsFilter + Name string + Nid int64 + Nids []string + Opt string + VarID string + type RawMetricAggrCalc struct + GlobalOperator string + GroupBy []string + InnerOperator string + Lateness int + NewMetric string + NewStep int + Nid int64 + RPN string + Sid int64 + SourceMetric string + SourceNid int64 + TagFilters []*AggrTagsFilter + VarID string + VarNum int + type Regexp struct + type RegexpExtract struct + Regex Regexp + Value string + type ReportRequest struct + Ident string + ReportTasks []ReportTask + type ReportResponse struct + AssignTasks []AssignTask + Message string + type ReportTask struct + Clock int64 + Id int64 + Status string + Stderr string + Stdout string + type Secret string + type SimpleRpcResponse struct + Code int + type TagPair struct + Key string + Values []string + type TaskMetaResponse struct + Account string + Args string + Message string + Script string + type TransferResp struct + Invalid int + Latency int64 + Msg string + Total int + func (t *TransferResp) String() string + type TsdbItem struct + DsType string + Endpoint string + From int + Heartbeat int + Max string + Metric string + Min string + Nid string + Step int + Tags string + TagsMap map[string]string + Timestamp int64 + Value float64 + func (t *TsdbItem) MD5() string + func (t *TsdbItem) PrimaryKey() string + func (t *TsdbItem) String() string + func (t *TsdbItem) UUID() string + type TsdbQueryParam struct + ConsolFunc string + Counter string + DsType string + End int64 + Endpoint string + Nid string + Start int64 + Step int + func (g *TsdbQueryParam) PK() string + type TsdbQueryResponse struct + Counter string + DsType string + End int64 + Endpoint string + Nid string + Start int64 + Step int + Values []*RRDData + func (resp *TsdbQueryResponse) Key() string + type XcludeResp struct + DsType string + Endpoint string + Metric string + Nid string + Step int + Tags []string