MCPcopy Create free account

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

Functions520 in github.com/cloudflare/go-stream

⨍ Functions 520◇ Types & classes 128
↓ 1 callersFunctionNewTable
(name string)
cube/pg/table.go:157
↓ 1 callersFunctionNewTestCube
()
cube/testcube.go:13
↓ 1 callersFunctionNewTimeRepartitionedCube
(originaltd time.Duration, newtd time.Duration)
cube/partitionedcube.go:200
↓ 1 callersFunctionNewUnixgramSource
(sockPath string)
stream/source/unixgram/unixgram.go:27
↓ 1 callersFunctionNewWeightedEra
()
cluster/era.go:33
↓ 1 callersFunctionNewWeightedNode
(name string, ip string, port string, disk float32, load float32)
cluster/node.go:49
↓ 1 callersFunctionNewZmqSink
(addr string, highWaterMark int)
stream/sink/zmq/zmq.go:23
↓ 1 callersFunctionNewZmqSource
(addr string, highWaterMark int)
stream/source/zmq/zmq.go:23
↓ 1 callersMethodNormalizeAndPopulateMap
()
cluster/era.go:52
↓ 1 callersMethodPrimaryKeyListSql
(intoTableName string)
cube/pg/table.go:294
↓ 1 callersMethodReConnect
()
transport/client.go:62
↓ 1 callersMethodReadNext
ReadNext should/can block until Stop Called
stream/source/reader.go:17
↓ 1 callersMethodReadNext
()
stream/source/interfacereader.go:6
↓ 1 callersMethodReset
()
util/util.go:107
↓ 1 callersMethodRun
()
transport/client.go:70
↓ 1 callersMethodScan
(pos int)
util/util.go:44
↓ 1 callersMethodSetTimeCol
(c Column)
cube/pg/table.go:169
↓ 1 callersMethodSoftStop
()
stream/chain.go:81
↓ 1 callersMethodStart
()
stream/chain.go:76
↓ 1 callersMethodStop
* A stop is a hard stop as per the Operator interface */
stream/chain.go:92
↓ 1 callersMethodStop
()
stream/mapper/operator.go:52
↓ 1 callersMethodUpdate
(op *string, v int)
util/util.go:190
↓ 1 callersMethodUpdateAggregateSql
(intoTableName string, updateTableName string)
cube/pg/table.go:278
↓ 1 callersMethodUpdateSql
(intoTableName string, updateTableName string)
cube/pg/table.go:23
↓ 1 callersMethodUpsertCubes
(p cube.Partition, c []cube.Cuber)
cube/pg/executor.go:85
↓ 1 callersMethodValidate
(inCh chan stream.Object, typeName string)
stream/mapper/worker.go:12
↓ 1 callersMethodVisitPartitions
(visitor func(Partition, Cuber))
cube/partitionedcube.go:51
↓ 1 callersMethodWait
()
stream/chain.go:101
↓ 1 callersFunctioncheck_modifiers
cube/pg/hll/hll.c:1366
↓ 1 callersFunctioncompressed_pack
cube/pg/hll/hll.c:327
↓ 1 callersFunctioncompressed_unpack
cube/pg/hll/hll.c:213
↓ 1 callersMethodconnect
()
transport/client.go:116
↓ 1 callersFunctioncopy_metadata
cube/pg/hll/hll.c:434
↓ 1 callersMethodcreateBranch
(key DistribKey)
stream/distributor.go:29
↓ 1 callersMethoddecodeNginxLog
NOTE: nginx escapes chars in 0x7F-0x1F range into \xXX format for access logs. Try and de-code only these chars
stream/source/unixgram/unixgram.go:35
↓ 1 callersFunctiondecode_expthresh
The expthresh is represented in a encoded format in the type modifier to save metadata bits. This routine is used when the expthresh comes from a typ
cube/pg/hll/hll.c:107
↓ 1 callersFunctionelement_compare
cube/pg/hll/hll.c:498
↓ 1 callersFunctionencode_expthresh
This routine is used to encode an expthresh value to be stored in the typmod metadata or a hll header.
cube/pg/hll/hll.c:139
↓ 1 callersFunctionexit
exit: outputs a startup message to STDERR, logs it to the logger if available and terminates the program with code
util/slog/slog.go:35
↓ 1 callersFunctionexplicit_union
cube/pg/hll/hll.c:745
↓ 1 callersFunctionexplicit_validate
cube/pg/hll/hll.c:640
↓ 1 callersFunctiongamma_register_count_squared
Helper function
cube/pg/hll/hll.c:1526
↓ 1 callersMethodgenCopyDataLineFormatString
()
cube/pg/table.go:328
↓ 1 callersFunctiongetAggregatePgTypeVisit
(fieldValue reflect.Value, fieldDescription reflect.StructField)
cube/pg/cube.go:112
↓ 1 callersMethodgetCopyDataLineFormatString
()
cube/pg/table.go:339
↓ 1 callersFunctiongetDimensionPgTypeVisit
(fieldValue reflect.Value, fieldDescription reflect.StructField)
cube/pg/cube.go:84
↓ 1 callersFunctiongetNewConn
()
cube/pg/table_test.go:27
↓ 1 callersMethodhandleConnection
(conn net.Conn)
transport/server.go:121
↓ 1 callersFunctionhardCloseListener
(hcn chan bool, sfc chan bool, listener net.Listener)
transport/server.go:37
↓ 1 callersFunctionhll_empty4
Create an empty multiset with parameters. @TODO -- malloc's a pointer but doesn't free it. Must remember to free when done.
cube/pg/hll/hll.c:1388
↓ 1 callersMethodkeepErasCurrent
()
cluster/manager.go:112
↓ 1 callersFunctionmultiset_pack
cube/pg/hll/hll.c:1049
↓ 1 callersFunctionmultiset_tostring
cube/pg/hll/hll.c:522
↓ 1 callersFunctionproc
(i int)
stream/operator_test.go:14
↓ 1 callersMethodprocessAck
(seq int)
transport/client.go:49
↓ 1 callersMethodrunWorker
(worker Worker, workerid int)
stream/mapper/orderpreserving.go:54
↓ 1 callersMethodrunWorker
(worker Worker, outCh chan stream.Object)
stream/mapper/operator.go:114
↓ 1 callersFunctionsendClose
(sndCh chan<- stream.Object, seq int)
transport/common.go:30
↓ 1 callersFunctionsendMsgNoBlock
(sndCh chan<- stream.Object, command ZmqCommand, seq int, payload []byte)
transport/common.go:39
↓ 1 callersFunctionsizeInt
()
transport/common.go:82
↓ 1 callersFunctionsoftCloserRunner
(sfc chan bool, wg *sync.WaitGroup)
transport/server.go:48
↓ 1 callersFunctionsparse_pack
cube/pg/hll/hll.c:364
↓ 1 callersFunctionsparse_unpack
cube/pg/hll/hll.c:250
↓ 1 callersFunctionstatsSender
(metricsAddr *string, processName *string)
util/slog/slog.go:90
↓ 1 callersFunctionvalidateAggregates
(agg Aggregates)
cube/cube.go:42
↓ 1 callersFunctionvalidateDimensions
(dim Dimensions)
cube/cube.go:33
MethodAck
(seq int)
util/util.go:133
MethodAdd
(p PartitionVisitor)
cube/partitionedcube.go:87
MethodAdd
(obj stream.Object)
cube/operator.go:24
MethodAdd
(value string)
cube/pg/hll/hll.go:100
MethodAdd
(newOp fanoutChildOp)
stream/fanout.go:26
MethodAdd
(o Operator)
stream/chain.go:56
MethodAdd
(o Operator)
stream/chain.go:135
MethodAdd
(op Operator)
stream/runner.go:57
MethodAdd
(i int)
stream/interfaceBatcher.go:31
MethodAdd
(obj Object)
stream/interfaceBatcher.go:67
MethodAdd
(payload []byte)
util/util.go:103
MethodAdd
(payload []byte)
util/util.go:125
MethodAdd
(n Node)
cluster/era.go:20
FunctionBenchmarkDirectSend
(b *testing.B)
stream/operator_test.go:18
FunctionBenchmarkHashBytes
(b *testing.B)
cube/pg/hll/hll_test.go:123
FunctionBenchmarkReflectSend
(b *testing.B)
stream/operator_test.go:27
MethodBlocking
()
stream/ProcessedNotifier.go:38
MethodByteSize
()
util/util.go:52
MethodCanAdd
()
util/util.go:121
MethodClear
()
util/util.go:36
MethodClear
()
util/util.go:92
MethodClose
(out Outputer)
stream/mapper/worker.go:30
MethodClose
()
stream/mapper/worker.go:92
MethodCreateForeignTable
(serverName string)
cube/pg/executor.go:51
MethodCreateForeignTableView
(serverNames []string, selfServerName string)
cube/pg/executor.go:59
FunctionDefaultPrintSink
()
stream/sink/print/print.go:16
FunctionDefaultUnixgramSource
()
stream/source/unixgram/unixgram.go:23
FunctionDefaultZmqSink
()
stream/sink/zmq/zmq.go:19
MethodDropAllTables
()
cube/pg/executor.go:47
MethodDropForeignTable
(serverName string)
cube/pg/executor.go:55
MethodDropForeignTableView
()
cube/pg/executor.go:63
FunctionExampleCreate2
()
cube/pg/table_test.go:59
FunctionExampleDrop
()
cube/pg/table_test.go:69
FunctionExampleInsertLine
()
cube/pg/table_test.go:79
← previousnext →201–300 of 520, ranked by callers