Code
Hub
Workspaces
Following
Trending
Connect
MCP
copy
Create free account
hub
/
github.com/cloudflare/go-stream
/ types & classes
Types & classes
128 in github.com/cloudflare/go-stream
⨍
Functions
520
◇
Types & classes
128
↓ 2 callers
TypeAlias
HllError
* --> 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 callers
TypeAlias
CountAggregate
cube/aggregate.go:11
↓ 1 callers
TypeAlias
IntDimension
cube/dimension.go:25
↓ 1 callers
TypeAlias
StringDimension
cube/dimension.go:33
↓ 1 callers
TypeAlias
TimeDimension
cube/dimension.go:10
↓ 1 callers
TypeAlias
ZmqCommand
transport/common.go:11
Interface
Aggregate
cube/aggregate.go:7
Interface
AggregateColumn
cube/pg/table.go:21
Interface
Aggregates
cube/cube.go:10
Struct
BBHost
cluster/manager.go:46
Struct
BBResult
cluster/manager.go:54
Struct
BaseIn
stream/util.go:16
Struct
BaseInOutOp
stream/util.go:52
Struct
BaseOut
stream/util.go:36
Interface
BatchContainer
stream/batcher.go:9
Struct
BatcherOperator
stream/batcher.go:16
Struct
ByteReader
Misc /////////////////////////////////////////////// stolen from bytes.Reader. Slightly changed to allow us to reuse gob.Decoder on same object
stream/encoding/gob.go:91
Struct
CallbackGenerator
stream/mapper/generator.go:13
Struct
CallbackWorker
stream/mapper/worker.go:15
Interface
Chain
stream/chain.go:8
Struct
Client
transport/client.go:20
Interface
Closer
stream/mapper/operator.go:47
Interface
Column
cube/pg/table.go:14
Struct
CountCol
cube/pg/table.go:76
Struct
Cube
cube/cube.go:27
Interface
CubeDescriber
cube/cube.go:22
Interface
Cuber
cube/cube.go:16
Struct
DefaultCol
cube/pg/table.go:26
Interface
Dimension
cube/dimension.go:8
Interface
Dimensions
cube/cube.go:9
Interface
DistribKey
stream/distributor.go:14
Struct
DistributeOperator
stream/distributor.go:16
Interface
DistributorChildOp
stream/distributor.go:9
Struct
DynamicBBManager
cluster/manager.go:39
Struct
EfficientWorker
* avoids Value.Call on fast path */
stream/mapper/worker.go:80
Interface
Era
cluster/era.go:8
Struct
Executor
cube/pg/executor.go:12
Interface
Exitor
stream/mapper/operator.go:55
Struct
FanoutOperator
stream/fanout.go:14
Interface
Generator
import "encoding/json"
stream/mapper/generator.go:9
Interface
GoServiceNode
cluster/node.go:14
Struct
HardStopChannelCloser
stream/util.go:3
Struct
Hll
Hll is the basic type for the Hll library. Holds an unexported instance of the database, for interactions.
cube/pg/hll/hll.go:59
Struct
HllAggregate
@TODO -- expand this to work with HLLs
cube/aggregate.go:24
Struct
HllCol
HLL code
cube/pg/table.go:86
Struct
HllDimension
cube/dimension.go:41
Struct
IONextReader
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
Interface
In
stream/operator.go:42
Interface
InChain
stream/chain.go:155
Interface
InOutOperator
stream/operator.go:48
Struct
IntCol
cube/pg/table.go:46
Struct
InterfaceBuffer
util/util.go:60
Struct
InterfaceContainer
stream/interfaceBatcher.go:39
Interface
InterfaceReader
stream/source/interfacereader.go:5
Struct
InterfaceReaderSource
stream/source/interfacereader.go:9
Interface
InterfaceWriter
stream/sink/interfacewriter.go:5
Struct
InterfaceWriterSink
stream/sink/interfacewriter.go:9
Interface
Manager
* There should be a separate manager for each service */
cluster/manager.go:18
Struct
MemoryBuffer
util/util.go:8
Struct
MetricsGroup
util/util.go:170
Struct
MultiPartWriterSink
stream/sink/writer.go:116
Interface
NextReader
stream/source/reader.go:14
Struct
NextReaderSource
stream/source/reader.go:73
Interface
Node
cluster/node.go:10
Interface
Object
stream/operator.go:12
Struct
Op
stream/mapper/operator.go:59
Interface
Operator
* soft stops are created by closing the input channel */
stream/operator.go:15
Struct
OrderPreservingOp
stream/mapper/orderpreserving.go:38
Struct
OrderPreservingOutputer
stream/mapper/orderpreserving.go:22
Struct
OrderedChain
stream/chain.go:127
Interface
Out
stream/operator.go:37
Interface
Outputer
stream/mapper/output.go:5
Interface
ParallelizableOperator
stream/operator.go:30
Interface
Partition
cube/partitionedcube.go:8
Interface
Partition
cube/pg/table.go:112
Interface
PartitionVisitor
cube/partitionedcube.go:57
Struct
PartitionedCube
cube/partitionedcube.go:10
Struct
PrintSink
stream/sink/print/print.go:10
Interface
ProcessedNotifier
stream/ProcessedNotifier.go:3
Interface
RepartitionableCube
cube/partitionedcube.go:61
Struct
RepartitionedCube
cube/partitionedcube.go:67
Struct
Runner
stream/runner.go:9
Struct
RunningCount
stream/interfaceBatcher.go:3
Interface
SequentialBuffer
util/util.go:101
Struct
SequentialBufferChanImpl
util/util.go:110
Struct
Server
transport/server.go:14
Struct
SimpleChain
* A SimpleChain implements the operator interface too! */
stream/chain.go:25
Struct
SimpleEra
cluster/era.go:12
Struct
SimpleNode
cluster/node.go:20
Struct
SimpleOutputer
stream/mapper/output.go:9
Struct
SimpleProcessedNotifier
stream/ProcessedNotifier.go:9
Interface
Sinker
stream/sink/sink.go:7
Interface
Sourcer
stream/source/source.go:5
Struct
StaticManager
cluster/manager.go:23
Interface
Stopper
stream/mapper/operator.go:51
Struct
StreamingMetrics
util/util.go:176
Struct
StringCol
cube/pg/table.go:55
Struct
Table
* 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
Struct
TestCubeAggregates
cube/testcube.go:8
Struct
TestCubeAggregates
cube/pg/table_test.go:44
next →
1–100 of 128, ranked by callers