MCPcopy Create free account

hub / github.com/cloudflare/go-stream / types & classes

Types & classes128 in github.com/cloudflare/go-stream

↓ 2 callersTypeAliasHllError
* --> Need to figure out how to fix memory leak now. Basic type is multiset_t Need to support these operations * Make new empty hll X hll_emp
cube/pg/hll/hll.go:51
↓ 1 callersTypeAliasCountAggregate
cube/aggregate.go:11
↓ 1 callersTypeAliasIntDimension
cube/dimension.go:25
↓ 1 callersTypeAliasStringDimension
cube/dimension.go:33
↓ 1 callersTypeAliasTimeDimension
cube/dimension.go:10
↓ 1 callersTypeAliasZmqCommand
transport/common.go:11
InterfaceAggregate
cube/aggregate.go:7
InterfaceAggregateColumn
cube/pg/table.go:21
InterfaceAggregates
cube/cube.go:10
StructBBHost
cluster/manager.go:46
StructBBResult
cluster/manager.go:54
StructBaseIn
stream/util.go:16
StructBaseInOutOp
stream/util.go:52
StructBaseOut
stream/util.go:36
InterfaceBatchContainer
stream/batcher.go:9
StructBatcherOperator
stream/batcher.go:16
StructByteReader
Misc /////////////////////////////////////////////// stolen from bytes.Reader. Slightly changed to allow us to reuse gob.Decoder on same object
stream/encoding/gob.go:91
StructCallbackGenerator
stream/mapper/generator.go:13
StructCallbackWorker
stream/mapper/worker.go:15
InterfaceChain
stream/chain.go:8
StructClient
transport/client.go:20
InterfaceCloser
stream/mapper/operator.go:47
InterfaceColumn
cube/pg/table.go:14
StructCountCol
cube/pg/table.go:76
StructCube
cube/cube.go:27
InterfaceCubeDescriber
cube/cube.go:22
InterfaceCuber
cube/cube.go:16
StructDefaultCol
cube/pg/table.go:26
InterfaceDimension
cube/dimension.go:8
InterfaceDimensions
cube/cube.go:9
InterfaceDistribKey
stream/distributor.go:14
StructDistributeOperator
stream/distributor.go:16
InterfaceDistributorChildOp
stream/distributor.go:9
StructDynamicBBManager
cluster/manager.go:39
StructEfficientWorker
* avoids Value.Call on fast path */
stream/mapper/worker.go:80
InterfaceEra
cluster/era.go:8
StructExecutor
cube/pg/executor.go:12
InterfaceExitor
stream/mapper/operator.go:55
StructFanoutOperator
stream/fanout.go:14
InterfaceGenerator
import "encoding/json"
stream/mapper/generator.go:9
InterfaceGoServiceNode
cluster/node.go:14
StructHardStopChannelCloser
stream/util.go:3
StructHll
Hll is the basic type for the Hll library. Holds an unexported instance of the database, for interactions.
cube/pg/hll/hll.go:59
StructHllAggregate
@TODO -- expand this to work with HLLs
cube/aggregate.go:24
StructHllCol
HLL code
cube/pg/table.go:86
StructHllDimension
cube/dimension.go:41
StructIONextReader
note that IONextReader will always close the underlying reader when exiting. It must do that to exit the ReadNext blocking call
stream/source/reader.go:24
InterfaceIn
stream/operator.go:42
InterfaceInChain
stream/chain.go:155
InterfaceInOutOperator
stream/operator.go:48
StructIntCol
cube/pg/table.go:46
StructInterfaceBuffer
util/util.go:60
StructInterfaceContainer
stream/interfaceBatcher.go:39
InterfaceInterfaceReader
stream/source/interfacereader.go:5
StructInterfaceReaderSource
stream/source/interfacereader.go:9
InterfaceInterfaceWriter
stream/sink/interfacewriter.go:5
StructInterfaceWriterSink
stream/sink/interfacewriter.go:9
InterfaceManager
* There should be a separate manager for each service */
cluster/manager.go:18
StructMemoryBuffer
util/util.go:8
StructMetricsGroup
util/util.go:170
StructMultiPartWriterSink
stream/sink/writer.go:116
InterfaceNextReader
stream/source/reader.go:14
StructNextReaderSource
stream/source/reader.go:73
InterfaceNode
cluster/node.go:10
InterfaceObject
stream/operator.go:12
StructOp
stream/mapper/operator.go:59
InterfaceOperator
* soft stops are created by closing the input channel */
stream/operator.go:15
StructOrderPreservingOp
stream/mapper/orderpreserving.go:38
StructOrderPreservingOutputer
stream/mapper/orderpreserving.go:22
StructOrderedChain
stream/chain.go:127
InterfaceOut
stream/operator.go:37
InterfaceOutputer
stream/mapper/output.go:5
InterfaceParallelizableOperator
stream/operator.go:30
InterfacePartition
cube/partitionedcube.go:8
InterfacePartition
cube/pg/table.go:112
InterfacePartitionVisitor
cube/partitionedcube.go:57
StructPartitionedCube
cube/partitionedcube.go:10
StructPrintSink
stream/sink/print/print.go:10
InterfaceProcessedNotifier
stream/ProcessedNotifier.go:3
InterfaceRepartitionableCube
cube/partitionedcube.go:61
StructRepartitionedCube
cube/partitionedcube.go:67
StructRunner
stream/runner.go:9
StructRunningCount
stream/interfaceBatcher.go:3
InterfaceSequentialBuffer
util/util.go:101
StructSequentialBufferChanImpl
util/util.go:110
StructServer
transport/server.go:14
StructSimpleChain
* A SimpleChain implements the operator interface too! */
stream/chain.go:25
StructSimpleEra
cluster/era.go:12
StructSimpleNode
cluster/node.go:20
StructSimpleOutputer
stream/mapper/output.go:9
StructSimpleProcessedNotifier
stream/ProcessedNotifier.go:9
InterfaceSinker
stream/sink/sink.go:7
InterfaceSourcer
stream/source/source.go:5
StructStaticManager
cluster/manager.go:23
InterfaceStopper
stream/mapper/operator.go:51
StructStreamingMetrics
util/util.go:176
StructStringCol
cube/pg/table.go:55
StructTable
* type Col struct { name string typ string } func (c *Col) Name() string { return c.name } func (c *Col) Type() string { return c.typ } func C
cube/pg/table.go:149
StructTestCubeAggregates
cube/testcube.go:8
StructTestCubeAggregates
cube/pg/table_test.go:44
next →1–100 of 128, ranked by callers