Code
Hub
Workspaces
Following
Trending
Connect
MCP
copy
Create free account
hub
/
github.com/chengshiwen/influxdb-cluster
/ functions
Functions
12,982 in github.com/chengshiwen/influxdb-cluster
⨍
Functions
12,982
◇
Types & classes
2,137
↓ 2,304 callers
Method
Errorf
(format string, args ...interface{})
pkg/testing/assert/assertions.go:10
↓ 1,558 callers
Function
ParseTags
ParseTags returns an instance of Tags for a comma-delimited list of key/values.
query/point_test.go:180
↓ 692 callers
Function
NewValue
NewValue returns a new Value with the underlying type dependent on value.
tsdb/engine/tsm1/encoding.go:116
↓ 688 callers
Method
String
String returns a string representation of the point. If there is a timestamp associated with the point then it will be specified with the default prec
models/points.go:123
↓ 490 callers
Method
New
New creates a new zap.Logger from config settings.
logger/logger.go:25
↓ 355 callers
Method
Run
(s *stressClient.StressTest)
stress/v2/statement/statement.go:13
↓ 341 callers
Method
Join
(addr string, v interface{})
cmd/influxd-ctl/common/http.go:87
↓ 334 callers
Method
UnixNano
UnixNano returns the timestamp of the value in nanoseconds since unix epoch.
tsdb/engine/tsm1/encoding.go:99
↓ 263 callers
Method
Close
Close releases any resources allocated by the ResultSet.
storage/reads/store.go:24
↓ 254 callers
Method
Equal
Equal compares if the Tags are equal to each other.
query/point.go:94
↓ 244 callers
Method
Close
()
tsdb/index.go:33
↓ 242 callers
Method
Merge
Merge merges another sketch into this one.
pkg/estimator/sketch.go:14
↓ 240 callers
Function
NewTags
NewTags returns a new Tags from a map.
models/points.go:1960
↓ 231 callers
Method
Len
Len returns the current number of idle connections of the pool.
coordinator/pool.go:32
↓ 230 callers
Method
UnixNano
UnixNano returns the timestamp of the point as nanoseconds since Unix epoch.
models/points.go:112
↓ 227 callers
Method
Add
Add adds a single value to the sketch.
pkg/estimator/sketch.go:8
↓ 227 callers
Method
Error
Error returns the first error from any statement. Returns nil if no errors occurred on any statements.
services/httpd/handler.go:2141
↓ 227 callers
Method
ID
()
services/meta/data.go:2098
↓ 224 callers
Method
Unmarshal
([]byte)
cmd/influx_tools/internal/format/binary/writer_test.go:106
↓ 201 callers
Method
Value
Value returns the underlying value.
tsdb/engine/tsm1/encoding.go:102
↓ 198 callers
Method
Error
()
tsdb/engine/tsm1/compact.go:1242
↓ 198 callers
Method
Open
()
tsdb/index.go:32
↓ 184 callers
Function
mustParseTime
mustParseTime parses an IS0-8601 string. Panic on error.
query/iterator_test.go:1988
↓ 178 callers
Method
Close
Close closes the underlying resources that the cursor is using.
query/cursor.go:88
↓ 173 callers
Method
Write
Write takes a BatchPoints object and writes all Points to InfluxDB.
client/v2/client.go:80
↓ 170 callers
Method
Add
Add records a new block entry for a key in the index.
tsdb/engine/tsm1/writer.go:156
↓ 169 callers
Method
Error
()
coordinator/meta_executor.go:65
↓ 168 callers
Method
String
String returns the string representation of the value and its timestamp.
tsdb/engine/tsm1/encoding.go:108
↓ 167 callers
Method
Next
Next returns true if there are any values remaining in the iterator.
tsdb/engine/tsm1/compact.go:1224
↓ 159 callers
Method
Diff
Diff removes from s any elements also present in other.
tsdb/series_set.go:200
↓ 157 callers
Method
Subset
Subset returns a new tags object with a subset of the keys.
query/point.go:141
↓ 155 callers
Method
Get
Get returns a new connection from the pool. Closing the connections puts it back to the Pool. Closing it when the pool is destroyed or full will be co
coordinator/pool.go:25
↓ 154 callers
Method
Next
()
query/iterator.gen.go:27
↓ 153 callers
Method
Close
Close closes the index and releases any resources.
tsdb/engine/tsm1/reader.go:126
↓ 146 callers
Method
Error
()
services/meta/client.go:1440
↓ 142 callers
Method
Write
Write writes a new block for key containing and values. Writes append blocks in the order that the Write function is called. The caller is responsib
tsdb/engine/tsm1/writer.go:129
↓ 139 callers
Method
Encode
(dst []byte)
tsdb/engine/tsm1/wal.go:588
↓ 139 callers
Method
Name
()
tsdb/engine/tsm1/writer.go:250
↓ 139 callers
Method
Stats
Stats returns the IteratorStats from the underlying iterators.
query/cursor.go:79
↓ 137 callers
Method
read
(key []byte, timestamp int64)
tsdb/engine/tsm1/reader.gen.go:96
↓ 135 callers
Method
Split
Split will attempt to return multiple points with the same timestamp whose string representations are no longer than size. Points with a single field
models/points.go:141
↓ 127 callers
Method
unread
unread sets v to the buffer. It is read on the next call to Next().
query/iterator.gen.go:107
↓ 122 callers
Method
Marshal
()
cmd/influx_tools/internal/format/binary/binary.pb.go:522
↓ 121 callers
Method
httpError
httpError writes an error to the client in a standard format.
services/meta/handler.go:1621
↓ 118 callers
Method
Clone
Clone returns a deep copy of the sketch.
pkg/estimator/sketch.go:20
↓ 110 callers
Method
Next
Next advances the ResultSet to the next cursor. It returns false when there are no more cursors.
storage/reads/store.go:15
↓ 104 callers
Function
NewSeriesIDSet
NewSeriesIDSet returns a new instance of SeriesIDSet.
tsdb/series_set.go:18
↓ 103 callers
Method
Close
Close closes the pool and all its connections. After Close() the pool is no longer usable.
coordinator/pool.go:29
↓ 101 callers
Function
MustTempDir
()
tsdb/engine/tsm1/file_store_test.go:2966
↓ 101 callers
Method
Wait
Wait blocks until the guard has been marked Done.
tsdb/guard.go:58
↓ 96 callers
Method
Close
()
tsdb/index/tsi1/file_set.go:439
↓ 96 callers
Method
Window
Window returns the time window [start,end) that t falls within.
query/iterator.go:800
↓ 94 callers
Method
Name
Name return the measurement name for the point.
models/points.go:79
↓ 93 callers
Method
Parse
()
pkg/tlsconfig/tls_config.go:25
↓ 92 callers
Method
Done
Done signals to anyone waiting on the guard that they can proceed.
tsdb/guard.go:67
↓ 91 callers
Method
Bytes
()
tsdb/engine/tsm1/timestamp.go:55
↓ 91 callers
Method
Read
Read returns all the values in the block where time t resides.
tsdb/engine/tsm1/file_store.go:45
↓ 90 callers
Method
Flush
Flushes flushes all pending changes to the underlying file resources.
tsdb/engine/tsm1/writer.go:142
↓ 90 callers
Method
Next
()
tsdb/index/tsi1/tsi1.go:151
↓ 89 callers
Method
Marshal
()
services/storage/source.pb.go:89
↓ 89 callers
Method
ReadAll
ReadAll reads all points from all iterators.
query/iterator_test.go:1316
↓ 86 callers
Method
Add
(key []byte)
cmd/influx_inspect/report/report.go:243
↓ 83 callers
Method
Contains
Contains return true if the given key exists in the index.
tsdb/engine/tsm1/reader.go:69
↓ 83 callers
Function
ParsePointsString
ParsePointsString is identical to ParsePoints but accepts a string.
models/points.go:283
↓ 83 callers
Function
test
(t *testing.T, line string, point TestPoint)
models/points_test.go:364
↓ 80 callers
Method
Next
()
tsdb/index.go:106
↓ 80 callers
Function
RegisteredIndexes
RegisteredIndexes returns the slice of currently registered indexes.
tsdb/index.go:3122
↓ 80 callers
Method
markRead
(min, max int64)
tsdb/engine/tsm1/compact.go:1325
↓ 79 callers
Method
Stat
Stat returns size and last modification time of the file.
tsdb/index/tsi1/log_file.go:238
↓ 77 callers
Method
IsZero
IsZero returns true if the interval has no duration.
query/iterator.go:1159
↓ 77 callers
Method
Strings
(j int)
storage/reads/flux_table.go:170
↓ 76 callers
Method
httpError
httpError writes an error to the client in a standard format.
services/httpd/handler.go:1744
↓ 75 callers
Method
Emit
()
query/functions.gen.go:40
↓ 75 callers
Method
Size
Size returns the number of bytes necessary to represent the value and its timestamp.
tsdb/engine/tsm1/encoding.go:105
↓ 75 callers
Method
Size
()
storage/reads/datatypes/predicate.pb.go:189
↓ 74 callers
Method
Read
Read returns the next value from the decoder.
tsdb/engine/tsm1/int.go:224
↓ 72 callers
Method
Error
Error returns a descriptive error of the values dropped.
prometheus/converters.go:42
↓ 72 callers
Method
Set
Set sets the internal state for a Pnt.
stress/basic.go:145
↓ 71 callers
Method
ServeHTTP
ServeHTTP responds to HTTP request to the handler.
services/httpd/handler.go:453
↓ 70 callers
Method
Decode
(ctx context.Context)
flux/stdlib/influxdata/influxdb/buckets.go:37
↓ 69 callers
Method
Error
Error returns any asynchronous error that may have occurred while executing the query.
query/executor.go:445
↓ 69 callers
Function
MustNewPoint
MustNewPoint returns a new point with the given measurement name, tags, fields and timestamp. If an unsupported field value (NaN) is passed, this fun
models/points.go:1463
↓ 69 callers
Method
Read
Read returns the next timestamp from the decoder.
tsdb/engine/tsm1/timestamp.go:269
↓ 68 callers
Method
Compare
(other *SeriesCursorRow)
tsdb/series_cursor.go:39
↓ 67 callers
Method
Error
Error satisfies the error interface.
cmd/influx_tools/internal/errlist/errlist.go:34
↓ 66 callers
Method
GetCounter
GetCounter returns the counter identified by the id that was returned by MustRegisterCounter for the same group. Using an id from a different group wi
pkg/metrics/group.go:17
↓ 65 callers
Function
ParseTags
(buf []byte)
models/points.go:316
↓ 64 callers
Method
Replace
Replace replaces oldFiles with newFiles.
tsdb/engine/tsm1/file_store.go:749
↓ 63 callers
Method
WriteHeader
(code int)
services/meta/gzip.go:43
↓ 62 callers
Method
Reverse
Reverse reverses the order of series keys and filters in the TagSet.
query/result.go:40
↓ 61 callers
Method
GetDimensions
GetDimensions retrieves the dimensions for this query.
query/iterator.go:918
↓ 61 callers
Method
Remove
()
tsdb/engine/tsm1/writer.go:150
↓ 61 callers
Method
Set
(s string)
cmd/influx/cli/cli.go:1200
↓ 61 callers
Method
Size
Size returns the total number of alive connections of the pool.
coordinator/pool.go:35
↓ 60 callers
Method
Close
()
cmd/influxd/run/server.go:726
↓ 60 callers
Method
Release
()
tsdb/index/tsi1/file_set.go:470
↓ 59 callers
Method
Done
()
storage/reads/flux_table.go:92
↓ 59 callers
Method
Next
()
cmd/influx_tools/internal/storage/series_cursor.go:16
↓ 58 callers
Method
SetBytes
SetBytes initializes the decoder with b. Must call before calling Next().
tsdb/engine/tsm1/float.go:158
↓ 55 callers
Method
Error
Error returns the string representation of the error, to satisfy the error interface.
tsdb/shard.go:106
next →
1–100 of 12,982, ranked by callers