MCPcopy Create free account

hub / github.com/cloudflare/go-stream / functions

Functions520 in github.com/cloudflare/go-stream

⨍ Functions 520◇ Types & classes 128
↓ 50 callersFunctionereport
Generic error reporter. Prints the message and then dies.
cube/pg/hll/hll.c:72
↓ 48 callersMethodAdd
(o Operator)
stream/chain.go:12
↓ 21 callersMethodOut
(int)
stream/mapper/output.go:6
↓ 19 callersMethodWait
()
stream/chain.go:21
↓ 17 callersMethodStop
()
stream/chain.go:11
↓ 15 callersMethodSetIn
(c chan Object)
stream/operator.go:44
↓ 15 callersMethodUnix
()
cube/dimension.go:17
↓ 14 callersMethodError
()
cube/pg/hll/hll.go:53
↓ 13 callersMethodIn
()
stream/operator.go:43
↓ 12 callersMethodBaseTableName
()
cube/pg/table.go:233
↓ 12 callersMethodClose
(out Outputer)
stream/mapper/operator.go:48
↓ 12 callersMethodName
()
cube/pg/table.go:15
↓ 11 callersMethodExec
(sql string, args ...interface{})
cube/pg/executor.go:35
↓ 10 callersMethodRun
()
stream/chain.go:10
↓ 10 callersMethodSetOut
(c chan Object)
stream/operator.go:39
↓ 9 callersMethodDelete
()
cube/pg/hll/hll.go:78
↓ 8 callersMethodLen
Unacked() [][]byte //guaranteed only on first call
util/util.go:106
↓ 8 callersMethodWrite
(i interface{})
stream/sink/interfacewriter.go:6
↓ 7 callersMethodHasItems
()
stream/batcher.go:12
↓ 7 callersMethodInit
()
stream/mapper/operator.go:66
↓ 7 callersFunctionNewDefault
()
cube/pg/hll/hll.go:73
↓ 7 callersFunctionStartOp
(wg *sync.WaitGroup, op stream.Operator)
transport/reliable_test.go:111
↓ 6 callersMethodData
()
cube/cube.go:72
↓ 6 callersFunctionDefaultServer
()
transport/server.go:22
↓ 6 callersMethodGet
(i int)
util/util.go:97
↓ 6 callersMethodGetCardinality
()
cube/pg/hll/hll.go:157
↓ 6 callersMethodInsert
(dimensions Dimensions, aggregates Aggregates)
cube/cube.go:17
↓ 6 callersFunctionInsertTestCube
(c *cube.Cube, d1 time.Time, d2 int, A1 int, A2 int)
cube/pg/table_test.go:53
↓ 6 callersMethodOperators
()
stream/chain.go:9
↓ 6 callersMethodOut
()
stream/operator.go:38
↓ 6 callersFunctioncompressed_add
cube/pg/hll/hll.c:444
↓ 5 callersMethodAdd4Bytes
(value []byte)
cube/pg/hll/hll.go:129
↓ 5 callersFunctionDefaultClient
(ip string)
transport/client.go:32
↓ 5 callersMethodExit
()
stream/mapper/operator.go:56
↓ 5 callersMethodGetTableName
(basename string)
cube/pg/table.go:113
↓ 5 callersMethodHardStop
()
stream/runner.go:67
↓ 5 callersFunctionLogf
(level logger.Level, format string, v ...interface{})
util/slog/slog.go:74
↓ 5 callersFunctionMakeTable
* func AddDimensions(table *Table, rDims reflect.Value) { for i := 0; i < rDims.NumField(); i++ { if rDims.Field(i).Kind() == reflect.Struct && rDi
cube/pg/cube.go:73
↓ 5 callersFunctionMurmurHash3_x64_128
cube/pg/hll/MurmurHash3.h:49
↓ 5 callersMethodName
()
cluster/node.go:11
↓ 5 callersFunctionNewDefaultCol
(name string)
cube/pg/table.go:30
↓ 5 callersMethodStop
()
stream/source/reader.go:19
↓ 5 callersFunctionfatal
fatal: outputs a fatal startup error to STDERR, logs it to the logger if available and terminates the program
util/slog/slog.go:29
↓ 5 callersFunctionpack_header
cube/pg/hll/hll.c:1031
↓ 5 callersFunctionunpack_header
cube/pg/hll/hll.c:809
↓ 4 callersMethodError
(op *string)
util/util.go:186
↓ 4 callersFunctionInsertTestCube
(c *Cube, d1 int, d2 int, A1 int, A2 int)
cube/testcube.go:17
↓ 4 callersFunctionNewBaseIn
(slack int)
stream/util.go:32
↓ 4 callersFunctionNewHardStopChannelCloser
()
stream/util.go:12
↓ 4 callersFunctionNewTestCube
()
cube/pg/table_test.go:49
↓ 4 callersMethodRead
(b []byte)
stream/encoding/gob.go:96
↓ 4 callersMethodStart
async functions
stream/chain.go:20
↓ 4 callersMethodUpsertCube
(p cube.Partition, c cube.Cuber)
cube/pg/executor.go:81
↓ 4 callersFunctionencodeInt
(val int)
transport/common.go:62
↓ 4 callersFunctionnumfilled
cube/pg/hll/hll.c:510
↓ 3 callersMethodAddInt32
(value int32)
cube/pg/hll/hll.go:111
↓ 3 callersMethodCloseNotifier
()
stream/runner.go:28
↓ 3 callersMethodDownstreamWillCallback
()
stream/batcher.go:47
↓ 3 callersMethodForeignTableName
(serverName string)
cube/pg/table.go:237
↓ 3 callersMethodForeignTablesViewName
()
cube/pg/table.go:241
↓ 3 callersMethodGetTemporaryCopyTableName
(p Partition)
cube/pg/table.go:253
↓ 3 callersMethodGetWorker
()
stream/mapper/generator.go:10
↓ 3 callersMethodIsRunning
()
transport/client.go:98
↓ 3 callersFunctionNewRunner
()
stream/runner.go:16
↓ 3 callersFunctionNewTimePartitionedCube
(td time.Duration)
cube/partitionedcube.go:140
↓ 3 callersMethodNotify
(count uint)
stream/ProcessedNotifier.go:5
↓ 3 callersMethodSerialize
()
cube/pg/hll/hll.go:88
↓ 3 callersFunctionVisitDimensions
(wrapper reflect.Value, visitor func(fieldValue reflect.Value, fieldDescription reflect.StructField))
cube/pg/cube.go:19
↓ 3 callersMethodWaitGroup
()
stream/runner.go:20
↓ 3 callersFunctioncheckTable
(table *Table, a1Value int, a2Value int, start time.Time, t *testing.T)
cube/pg/table_test.go:96
↓ 3 callersFunctioncompressed_explicit_union
cube/pg/hll/hll.c:470
↓ 3 callersFunctionexplicit_to_compressed
cube/pg/hll/hll.c:478
↓ 3 callersFunctionexpthresh_value
If expthresh == -1 (auto select expthresh) determine the expthresh to use from nbits and nregs.
cube/pg/hll/hll.c:155
↓ 3 callersFunctionmultiset_copy_size
cube/pg/hll/hll.c:1153
↓ 3 callersMethodresetAckTimer
()
transport/client.go:109
↓ 3 callersFunctionsendAck
(sndCh chan<- stream.Object, seq int)
transport/common.go:25
↓ 2 callersMethodAdd8Bytes
(value []byte)
cube/pg/hll/hll.go:143
↓ 2 callersMethodAddInt64
(value int64)
cube/pg/hll/hll.go:120
↓ 2 callersMethodAddPartition
(Partition, Cuber)
cube/partitionedcube.go:64
↓ 2 callersMethodAsyncRun
(op Operator)
stream/runner.go:36
↓ 2 callersMethodAsyncRunAll
()
stream/runner.go:61
↓ 2 callersMethodColumnDefinitionsSql
()
cube/pg/table.go:181
↓ 2 callersMethodCopyDataLine
(dims cube.Dimensions, aggs cube.Aggregates)
cube/pg/table.go:346
↓ 2 callersMethodCreateTableSql
(temp bool)
cube/pg/table.go:192
↓ 2 callersMethodDownstreamCanAcceptFlush
INVARIANT CAN FLUSH OR WAITING: DownstreamCanAcceptFlush || DownstreamWillCallback
stream/batcher.go:43
↓ 2 callersMethodDropTableSql
()
cube/pg/table.go:270
↓ 2 callersMethodEvent
(op *string)
util/util.go:182
↓ 2 callersMethodFlush
()
stream/batcher.go:51
↓ 2 callersMethodGetInDepth
()
stream/operator.go:45
↓ 2 callersMethodIsOrdered
()
stream/operator.go:33
↓ 2 callersMethodMap
(input stream.Object, out Outputer)
stream/mapper/worker.go:11
↓ 2 callersFunctionName
(op Operator)
stream/operator.go:54
↓ 2 callersFunctionNewBaseOut
(slack int)
stream/util.go:48
↓ 2 callersFunctionNewCountAggregate
(n int)
cube/aggregate.go:18
↓ 2 callersFunctionNewCube
(dimensions Dimensions, aggregates Aggregates)
cube/cube.go:51
↓ 2 callersFunctionNewExecutor
(t *Table, c driver.Conn)
cube/pg/executor.go:17
↓ 2 callersFunctionNewIntDimension
(i int)
cube/dimension.go:27
↓ 2 callersFunctionNewNextReaderSource
(reader NextReader)
stream/source/reader.go:90
↓ 2 callersFunctionNewOrderedOpWrapper
(op *Op)
stream/mapper/orderpreserving.go:16
↓ 2 callersFunctionNewPartitionedCube
(partitioner func(Dimensions) Partition)
cube/partitionedcube.go:15
next →1–100 of 520, ranked by callers