MCPcopy Create free account

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

Functions520 in github.com/cloudflare/go-stream

⨍ Functions 520◇ Types & classes 128
↓ 2 callersFunctionNewSimpleChain
()
stream/chain.go:39
↓ 2 callersMethodNotificationChannel
()
stream/ProcessedNotifier.go:4
↓ 2 callersMethodPrimaryKeyJoinConstraintsSql
(intoTableName string, updateTableName string)
cube/pg/table.go:286
↓ 2 callersMethodPrimaryKeySql
()
cube/pg/table.go:173
↓ 2 callersMethodPrint
()
cube/pg/hll/hll.go:82
↓ 2 callersMethodPrintFormat
()
cube/pg/table.go:17
↓ 2 callersMethodPrintInterface
(in interface{})
cube/pg/table.go:18
↓ 2 callersMethodRegister
(op string)
util/util.go:194
↓ 2 callersMethodRun
()
stream/sink/writer.go:129
↓ 2 callersMethodString
()
stream/mapper/operator.go:88
↓ 2 callersMethodTime
()
cube/partitionedcube.go:119
↓ 2 callersMethodTimeIndex
()
cube/cube.go:13
↓ 2 callersMethodTypeName
()
cube/pg/table.go:16
↓ 2 callersMethodUnion
(hllRhs *Hll)
cube/pg/hll/hll.go:95
↓ 2 callersMethodVisit
(func(Dimensions, Aggregates))
cube/cube.go:18
↓ 2 callersFunctionVisitAggregates
(wrapper reflect.Value, visitor func(fieldValue reflect.Value, fieldDescription reflect.StructField))
cube/pg/cube.go:23
↓ 2 callersMethodVisitPartitions
(visitor func(Partition, Cuber))
cube/partitionedcube.go:58
↓ 2 callersFunctionVisitWrapper
(wrapper reflect.Value, visitor func(fieldValue reflect.Value, fieldDescription reflect.StructField))
cube/pg/cube.go:9
↓ 2 callersMethodWorkerClose
(worker Worker, outputer Outputer)
stream/mapper/operator.go:103
↓ 2 callersMethodWorkerStop
(worker Worker)
stream/mapper/operator.go:92
↓ 2 callersFunctionbitstream_pack
cube/pg/hll/hll.c:297
↓ 2 callersFunctionbitstream_unpack
cube/pg/hll/hll.c:183
↓ 2 callersFunctiondecodeInt
(val []byte)
transport/common.go:74
↓ 2 callersFunctionfmix
cube/pg/hll/MurmurHash3.h:36
↓ 2 callersFunctiongetConnParams
()
cube/pg/table_test.go:14
↓ 2 callersFunctiongetDb
()
cube/pg/table_test.go:19
↓ 2 callersFunctiongetPartition
(p cube.Partition)
cube/pg/executor.go:67
↓ 2 callersMethodgetPartitionedCube
(outerpart Partition)
cube/partitionedcube.go:78
↓ 2 callersFunctiongetblock
cube/pg/hll/MurmurHash3.h:31
↓ 2 callersFunctioninteger_log2
cube/pg/hll/hll.c:120
↓ 2 callersFunctionparseMsg
(msg []byte)
transport/common.go:47
↓ 2 callersMethodpullLatestEra
()
cluster/manager.go:69
↓ 2 callersFunctionsendData
(sndCh chan<- stream.Object, data []byte, seq int)
transport/common.go:21
↓ 2 callersFunctionsendMsg
(sndCh chan<- stream.Object, command ZmqCommand, seq int, payload []byte)
transport/common.go:35
↓ 2 callersMethodsendSlice
(slice *reflect.Value, out Outputer)
stream/mapper/worker.go:22
↓ 2 callersFunctionsender
(c chan int, n int)
stream/operator_test.go:8
↓ 2 callersFunctiontimePartitioner
(td time.Duration)
cube/partitionedcube.go:133
↓ 2 callersMethodwriteValue
(msg []byte, writer io.Writer)
stream/sink/writer.go:13
↓ 1 callersMethodAck
(seq int)
util/util.go:104
↓ 1 callersMethodAdd
(object Object)
stream/batcher.go:13
↓ 1 callersMethodAdd
(n Node)
cluster/era.go:37
↓ 1 callersMethodAddAgg
(c AggregateColumn)
cube/pg/table.go:165
↓ 1 callersFunctionAddAggregates
(table *Table, rAggs reflect.Value)
cube/pg/cube.go:45
↓ 1 callersMethodAddDim
(c Column)
cube/pg/table.go:161
↓ 1 callersFunctionAddDimensions
(table *Table, rDims reflect.Value)
cube/pg/cube.go:27
↓ 1 callersMethodAddPartition
(p Partition, upc Cuber)
cube/partitionedcube.go:30
↓ 1 callersMethodBlocking
()
stream/ProcessedNotifier.go:6
↓ 1 callersMethodCanAdd
()
util/util.go:102
↓ 1 callersMethodCombiner
()
stream/mapper/orderpreserving.go:87
↓ 1 callersMethodCopyDataFull
(c cube.Cuber)
cube/pg/table.go:378
↓ 1 callersMethodCopyTableSql
(p Partition)
cube/pg/table.go:266
↓ 1 callersMethodCreateBaseTable
()
cube/pg/executor.go:43
↓ 1 callersMethodCreateForeignTableSql
(serverName string)
cube/pg/table.go:204
↓ 1 callersMethodCreateForeignTableViewSql
(serverNames []string, selfServerName string)
cube/pg/table.go:214
↓ 1 callersMethodCreatePartitionTableSql
*func (t *Table) GetPartitionTableName(start time.Time) string { return fmt.Sprintf("%s_%d", t.BaseTableName(), start.Unix()) }*/
cube/pg/table.go:249
↓ 1 callersMethodCreateTableNameSql
(temp bool, name string)
cube/pg/table.go:195
↓ 1 callersMethodCreateTemporaryCopyTableSql
(p Partition)
cube/pg/table.go:257
↓ 1 callersFunctionDefaultZmqSource
()
stream/source/zmq/zmq.go:19
↓ 1 callersMethodDropForeignTableSql
(serverName string)
cube/pg/table.go:209
↓ 1 callersMethodDropForeignTableViewSql
()
cube/pg/table.go:229
↓ 1 callersMethodDropPartition
(p cube.Partition)
cube/pg/executor.go:77
↓ 1 callersMethodDropPartitionTableSql
(p Partition)
cube/pg/table.go:274
↓ 1 callersMethodDuration
()
cube/partitionedcube.go:123
↓ 1 callersMethodErrorChannel
()
stream/runner.go:24
↓ 1 callersMethodExecErr
(sql string, args ...interface{})
cube/pg/executor.go:21
↓ 1 callersMethodExit
()
stream/mapper/operator.go:132
↓ 1 callersMethodFlush
(outch chan<- stream.Object)
cube/operator.go:16
↓ 1 callersMethodFlush
(out chan<- Object)
stream/interfaceBatcher.go:48
↓ 1 callersMethodFlush
(chan<- Object)
stream/batcher.go:10
↓ 1 callersMethodFlushAll
(chan<- Object)
stream/batcher.go:11
↓ 1 callersMethodGetAggregates
()
cube/cube.go:24
↓ 1 callersMethodGetAverage
()
stream/interfaceBatcher.go:11
↓ 1 callersMethodGetAverageMin
(min int)
stream/interfaceBatcher.go:23
↓ 1 callersMethodGetConstraint
(t *Table)
cube/pg/table.go:114
↓ 1 callersMethodGetDimensions
()
cube/cube.go:23
↓ 1 callersMethodGetOnePkColSql
(intoTableName string)
cube/pg/table.go:302
↓ 1 callersFunctionGobGeneralDecoder
* Example Decoder Usage intDecGenFn := func () interface{} { decoder := encoding.GobGeneralDecoder() return func(in []byte, closenotifier chan<- boo
stream/encoding/gob.go:25
↓ 1 callersMethodInitiateWorkerChannels
(numWorkers int)
stream/mapper/orderpreserving.go:100
↓ 1 callersMethodLastFlush
()
stream/batcher.go:58
↓ 1 callersMethodListColumnsSql
()
cube/pg/table.go:316
↓ 1 callersMethodMakeOrdered
()
stream/operator.go:34
↓ 1 callersMethodMerge
(with Aggregate)
cube/aggregate.go:8
↓ 1 callersMethodMergeCopySql
(p Partition)
cube/pg/table.go:306
↓ 1 callersFunctionNew
(log2m int, regwidth int, expthresh int64, sparseon int)
cube/pg/hll/hll.go:63
↓ 1 callersFunctionNewBatchOperator
(name string, container BatchContainer, processedDownstream ProcessedNotifier)
stream/batcher.go:31
↓ 1 callersFunctionNewChain
()
stream/chain.go:35
↓ 1 callersFunctionNewClient
(addr string, hwm int)
transport/client.go:36
↓ 1 callersFunctionNewGobDecodeRop
(gen interface{})
stream/encoding/gob.go:42
↓ 1 callersFunctionNewGobEncodeRop
()
stream/encoding/gob.go:48
↓ 1 callersFunctionNewIOReaderWrapper
(r io.ReadCloser)
stream/source/reader.go:65
↓ 1 callersFunctionNewIOReaderWrapperLengthDelim
(r io.ReadCloser)
stream/source/reader.go:69
↓ 1 callersFunctionNewInterfaceContainer
()
stream/interfaceBatcher.go:44
↓ 1 callersFunctionNewNextReaderSourceMax
(reader NextReader, max uint32)
stream/source/reader.go:94
↓ 1 callersFunctionNewOrderPreservingOutputer
(out chan<- stream.Object, num chan<- int)
stream/mapper/orderpreserving.go:34
↓ 1 callersFunctionNewOrderedChain
()
stream/chain.go:131
↓ 1 callersFunctionNewPrintSink
(logger *log.Logger)
stream/sink/print/print.go:20
↓ 1 callersFunctionNewRepartitionedCube
(innerpartitioner func(d Dimensions) Partition, outerpartitioner func(inner Partition) (outer Partition))
cube/partitionedcube.go:73
↓ 1 callersFunctionNewRunningCount
(sz int)
stream/interfaceBatcher.go:7
↓ 1 callersFunctionNewServer
(addr string, highWaterMark int)
transport/server.go:26
↓ 1 callersFunctionNewSimpleOutputer
(ch chan<- stream.Object)
stream/mapper/output.go:17
← previousnext →101–200 of 520, ranked by callers