MCPcopy Create free account

hub / github.com/chengshiwen/influxdb-cluster / functions

Functions12,982 in github.com/chengshiwen/influxdb-cluster

↓ 2,304 callersMethodErrorf
(format string, args ...interface{})
pkg/testing/assert/assertions.go:10
↓ 1,558 callersFunctionParseTags
ParseTags returns an instance of Tags for a comma-delimited list of key/values.
query/point_test.go:180
↓ 692 callersFunctionNewValue
NewValue returns a new Value with the underlying type dependent on value.
tsdb/engine/tsm1/encoding.go:116
↓ 688 callersMethodString
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 callersMethodNew
New creates a new zap.Logger from config settings.
logger/logger.go:25
↓ 355 callersMethodRun
(s *stressClient.StressTest)
stress/v2/statement/statement.go:13
↓ 341 callersMethodJoin
(addr string, v interface{})
cmd/influxd-ctl/common/http.go:87
↓ 334 callersMethodUnixNano
UnixNano returns the timestamp of the value in nanoseconds since unix epoch.
tsdb/engine/tsm1/encoding.go:99
↓ 263 callersMethodClose
Close releases any resources allocated by the ResultSet.
storage/reads/store.go:24
↓ 254 callersMethodEqual
Equal compares if the Tags are equal to each other.
query/point.go:94
↓ 244 callersMethodClose
()
tsdb/index.go:33
↓ 242 callersMethodMerge
Merge merges another sketch into this one.
pkg/estimator/sketch.go:14
↓ 240 callersFunctionNewTags
NewTags returns a new Tags from a map.
models/points.go:1960
↓ 231 callersMethodLen
Len returns the current number of idle connections of the pool.
coordinator/pool.go:32
↓ 230 callersMethodUnixNano
UnixNano returns the timestamp of the point as nanoseconds since Unix epoch.
models/points.go:112
↓ 227 callersMethodAdd
Add adds a single value to the sketch.
pkg/estimator/sketch.go:8
↓ 227 callersMethodError
Error returns the first error from any statement. Returns nil if no errors occurred on any statements.
services/httpd/handler.go:2141
↓ 227 callersMethodID
()
services/meta/data.go:2098
↓ 224 callersMethodUnmarshal
([]byte)
cmd/influx_tools/internal/format/binary/writer_test.go:106
↓ 201 callersMethodValue
Value returns the underlying value.
tsdb/engine/tsm1/encoding.go:102
↓ 198 callersMethodError
()
tsdb/engine/tsm1/compact.go:1242
↓ 198 callersMethodOpen
()
tsdb/index.go:32
↓ 184 callersFunctionmustParseTime
mustParseTime parses an IS0-8601 string. Panic on error.
query/iterator_test.go:1988
↓ 178 callersMethodClose
Close closes the underlying resources that the cursor is using.
query/cursor.go:88
↓ 173 callersMethodWrite
Write takes a BatchPoints object and writes all Points to InfluxDB.
client/v2/client.go:80
↓ 170 callersMethodAdd
Add records a new block entry for a key in the index.
tsdb/engine/tsm1/writer.go:156
↓ 169 callersMethodError
()
coordinator/meta_executor.go:65
↓ 168 callersMethodString
String returns the string representation of the value and its timestamp.
tsdb/engine/tsm1/encoding.go:108
↓ 167 callersMethodNext
Next returns true if there are any values remaining in the iterator.
tsdb/engine/tsm1/compact.go:1224
↓ 159 callersMethodDiff
Diff removes from s any elements also present in other.
tsdb/series_set.go:200
↓ 157 callersMethodSubset
Subset returns a new tags object with a subset of the keys.
query/point.go:141
↓ 155 callersMethodGet
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 callersMethodNext
()
query/iterator.gen.go:27
↓ 153 callersMethodClose
Close closes the index and releases any resources.
tsdb/engine/tsm1/reader.go:126
↓ 146 callersMethodError
()
services/meta/client.go:1440
↓ 142 callersMethodWrite
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 callersMethodEncode
(dst []byte)
tsdb/engine/tsm1/wal.go:588
↓ 139 callersMethodName
()
tsdb/engine/tsm1/writer.go:250
↓ 139 callersMethodStats
Stats returns the IteratorStats from the underlying iterators.
query/cursor.go:79
↓ 137 callersMethodread
(key []byte, timestamp int64)
tsdb/engine/tsm1/reader.gen.go:96
↓ 135 callersMethodSplit
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 callersMethodunread
unread sets v to the buffer. It is read on the next call to Next().
query/iterator.gen.go:107
↓ 122 callersMethodMarshal
()
cmd/influx_tools/internal/format/binary/binary.pb.go:522
↓ 121 callersMethodhttpError
httpError writes an error to the client in a standard format.
services/meta/handler.go:1621
↓ 118 callersMethodClone
Clone returns a deep copy of the sketch.
pkg/estimator/sketch.go:20
↓ 110 callersMethodNext
Next advances the ResultSet to the next cursor. It returns false when there are no more cursors.
storage/reads/store.go:15
↓ 104 callersFunctionNewSeriesIDSet
NewSeriesIDSet returns a new instance of SeriesIDSet.
tsdb/series_set.go:18
↓ 103 callersMethodClose
Close closes the pool and all its connections. After Close() the pool is no longer usable.
coordinator/pool.go:29
↓ 101 callersFunctionMustTempDir
()
tsdb/engine/tsm1/file_store_test.go:2966
↓ 101 callersMethodWait
Wait blocks until the guard has been marked Done.
tsdb/guard.go:58
↓ 96 callersMethodClose
()
tsdb/index/tsi1/file_set.go:439
↓ 96 callersMethodWindow
Window returns the time window [start,end) that t falls within.
query/iterator.go:800
↓ 94 callersMethodName
Name return the measurement name for the point.
models/points.go:79
↓ 93 callersMethodParse
()
pkg/tlsconfig/tls_config.go:25
↓ 92 callersMethodDone
Done signals to anyone waiting on the guard that they can proceed.
tsdb/guard.go:67
↓ 91 callersMethodBytes
()
tsdb/engine/tsm1/timestamp.go:55
↓ 91 callersMethodRead
Read returns all the values in the block where time t resides.
tsdb/engine/tsm1/file_store.go:45
↓ 90 callersMethodFlush
Flushes flushes all pending changes to the underlying file resources.
tsdb/engine/tsm1/writer.go:142
↓ 90 callersMethodNext
()
tsdb/index/tsi1/tsi1.go:151
↓ 89 callersMethodMarshal
()
services/storage/source.pb.go:89
↓ 89 callersMethodReadAll
ReadAll reads all points from all iterators.
query/iterator_test.go:1316
↓ 86 callersMethodAdd
(key []byte)
cmd/influx_inspect/report/report.go:243
↓ 83 callersMethodContains
Contains return true if the given key exists in the index.
tsdb/engine/tsm1/reader.go:69
↓ 83 callersFunctionParsePointsString
ParsePointsString is identical to ParsePoints but accepts a string.
models/points.go:283
↓ 83 callersFunctiontest
(t *testing.T, line string, point TestPoint)
models/points_test.go:364
↓ 80 callersMethodNext
()
tsdb/index.go:106
↓ 80 callersFunctionRegisteredIndexes
RegisteredIndexes returns the slice of currently registered indexes.
tsdb/index.go:3122
↓ 80 callersMethodmarkRead
(min, max int64)
tsdb/engine/tsm1/compact.go:1325
↓ 79 callersMethodStat
Stat returns size and last modification time of the file.
tsdb/index/tsi1/log_file.go:238
↓ 77 callersMethodIsZero
IsZero returns true if the interval has no duration.
query/iterator.go:1159
↓ 77 callersMethodStrings
(j int)
storage/reads/flux_table.go:170
↓ 76 callersMethodhttpError
httpError writes an error to the client in a standard format.
services/httpd/handler.go:1744
↓ 75 callersMethodEmit
()
query/functions.gen.go:40
↓ 75 callersMethodSize
Size returns the number of bytes necessary to represent the value and its timestamp.
tsdb/engine/tsm1/encoding.go:105
↓ 75 callersMethodSize
()
storage/reads/datatypes/predicate.pb.go:189
↓ 74 callersMethodRead
Read returns the next value from the decoder.
tsdb/engine/tsm1/int.go:224
↓ 72 callersMethodError
Error returns a descriptive error of the values dropped.
prometheus/converters.go:42
↓ 72 callersMethodSet
Set sets the internal state for a Pnt.
stress/basic.go:145
↓ 71 callersMethodServeHTTP
ServeHTTP responds to HTTP request to the handler.
services/httpd/handler.go:453
↓ 70 callersMethodDecode
(ctx context.Context)
flux/stdlib/influxdata/influxdb/buckets.go:37
↓ 69 callersMethodError
Error returns any asynchronous error that may have occurred while executing the query.
query/executor.go:445
↓ 69 callersFunctionMustNewPoint
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 callersMethodRead
Read returns the next timestamp from the decoder.
tsdb/engine/tsm1/timestamp.go:269
↓ 68 callersMethodCompare
(other *SeriesCursorRow)
tsdb/series_cursor.go:39
↓ 67 callersMethodError
Error satisfies the error interface.
cmd/influx_tools/internal/errlist/errlist.go:34
↓ 66 callersMethodGetCounter
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 callersFunctionParseTags
(buf []byte)
models/points.go:316
↓ 64 callersMethodReplace
Replace replaces oldFiles with newFiles.
tsdb/engine/tsm1/file_store.go:749
↓ 63 callersMethodWriteHeader
(code int)
services/meta/gzip.go:43
↓ 62 callersMethodReverse
Reverse reverses the order of series keys and filters in the TagSet.
query/result.go:40
↓ 61 callersMethodGetDimensions
GetDimensions retrieves the dimensions for this query.
query/iterator.go:918
↓ 61 callersMethodRemove
()
tsdb/engine/tsm1/writer.go:150
↓ 61 callersMethodSet
(s string)
cmd/influx/cli/cli.go:1200
↓ 61 callersMethodSize
Size returns the total number of alive connections of the pool.
coordinator/pool.go:35
↓ 60 callersMethodClose
()
cmd/influxd/run/server.go:726
↓ 60 callersMethodRelease
()
tsdb/index/tsi1/file_set.go:470
↓ 59 callersMethodDone
()
storage/reads/flux_table.go:92
↓ 59 callersMethodNext
()
cmd/influx_tools/internal/storage/series_cursor.go:16
↓ 58 callersMethodSetBytes
SetBytes initializes the decoder with b. Must call before calling Next().
tsdb/engine/tsm1/float.go:158
↓ 55 callersMethodError
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