Code
Hub
Workspaces
Following
Trending
Connect
MCP
copy
Create free account
hub
/
github.com/cloudflare/go-stream
/ functions
Functions
520 in github.com/cloudflare/go-stream
⨍
Functions
520
◇
Types & classes
128
Method
Exit
()
stream/mapper/generator.go:27
Function
Fatalf
(format string, v ...interface{})
util/slog/slog.go:80
Method
FlushAll
(outch chan<- stream.Object)
cube/operator.go:29
Method
FlushAll
(out chan<- Object)
stream/interfaceBatcher.go:59
Method
FlushItems
()
cube/partitionedcube.go:172
Method
GetAggregates
()
cube/cube.go:86
Method
GetConstraint
(t *Table)
cube/pg/table.go:125
Method
GetCurrentEra
()
cluster/manager.go:20
Method
GetCurrentEra
()
cluster/manager.go:31
Method
GetCurrentEra
()
cluster/manager.go:65
Method
GetDimensions
()
cube/cube.go:82
Method
GetEra
(t time.Time)
cluster/manager.go:19
Method
GetEra
(t time.Time)
cluster/manager.go:27
Method
GetEra
(t time.Time)
cluster/manager.go:58
Method
GetInDepth
()
stream/chain.go:173
Method
GetInDepth
()
stream/util.go:24
Method
GetNode
(posit int)
cluster/era.go:45
Method
GetNodes
()
cluster/era.go:9
Method
GetNodes
()
cluster/era.go:24
Method
GetNodes
()
cluster/era.go:41
Method
GetTableName
(basename string)
cube/pg/table.go:121
Method
GetWorker
()
stream/mapper/generator.go:19
Method
GetWorker
()
stream/mapper/generator.go:37
Method
GetWorker
()
stream/mapper/generator.go:53
Method
GetWorker
()
stream/mapper/generator.go:65
Method
HasItems
()
cube/partitionedcube.go:187
Method
HasItems
()
cube/partitionedcube.go:216
Method
HasItems
()
cube/operator.go:33
Method
HasItems
()
stream/interfaceBatcher.go:63
Method
In
()
stream/chain.go:168
Method
In
()
stream/util.go:20
Function
Init
(logName string, logLevel string, logPrefix string, metrics *util.StreamingMetrics, metricsAddr string, logAd
util/slog/slog.go:45
Method
Insert
(dimensions Dimensions, aggregates Aggregates)
cube/partitionedcube.go:19
Method
Insert
(dimensions Dimensions, aggregates Aggregates)
cube/partitionedcube.go:103
Method
Insert
(dimensions Dimensions, aggregates Aggregates)
cube/partitionedcube.go:146
Method
Insert
(dimensions Dimensions, aggregates Aggregates)
cube/cube.go:58
Method
Ip
()
cluster/node.go:16
Method
Ip
()
cluster/node.go:34
Method
Ip
()
cluster/node.go:63
Method
IsOrdered
()
stream/mapper/orderpreserving.go:46
Method
IsOrdered
()
stream/mapper/operator.go:75
Method
IsParallel
()
stream/operator.go:32
Method
IsParallel
()
stream/mapper/operator.go:71
Function
JsonGeneralDecoder
* Example Decoder Usage intDecGenFn := func () interface{} { decoder := encoding.JsonGeneralDecoder() return func(in []byte, closenotifier chan<- bo
stream/encoding/json.go:24
Function
JsonGeneralEncoder
()
stream/encoding/json.go:34
Method
Len
()
transport/client.go:102
Method
Len
()
util/util.go:48
Method
Len
()
util/util.go:88
Method
Len
()
util/util.go:147
Method
MakeOrdered
()
stream/mapper/orderpreserving.go:50
Method
MakeOrdered
()
stream/mapper/operator.go:79
Method
Map
(input stream.Object, out Outputer)
stream/mapper/worker.go:40
Method
Map
(input stream.Object, out Outputer)
stream/mapper/worker.go:103
Method
Merge
(update *PartitionedCube)
cube/partitionedcube.go:38
Method
Merge
(with Aggregate)
cube/aggregate.go:13
Method
Merge
(with Aggregate)
cube/aggregate.go:28
Method
Name
()
cube/pg/table.go:34
Method
Name
()
cluster/node.go:15
Method
Name
()
cluster/node.go:30
Method
Name
()
cluster/node.go:59
Function
NewBaseInOutOp
(slack int)
stream/util.go:58
Function
NewDistributor
(mapp func(Object) DistribKey, creator func(DistribKey) DistributorChildOp)
stream/distributor.go:25
Function
NewDropOp
()
stream/util/util.go:10
Function
NewDynamicBBManager
(bbHosts []string)
cluster/manager.go:123
Function
NewFanoutOp
()
stream/fanout.go:22
Function
NewHllAggregate
(val string)
cube/aggregate.go:33
Function
NewHllAggregateFromBytes
(val []byte)
cube/aggregate.go:42
Function
NewHllDimension
(i *hll.Hll)
cube/dimension.go:45
Function
NewIOReaderSource
(reader io.ReadCloser)
stream/source/reader.go:80
Function
NewIOReaderSourceLengthDelim
(reader io.ReadCloser)
stream/source/reader.go:85
Function
NewInChainWrapper
(c Chain)
stream/chain.go:164
Function
NewInterfaceBatchOp
(pn ProcessedNotifier)
stream/interfaceBatcher.go:76
Function
NewInterfaceBuffer
(size int)
util/util.go:65
Function
NewInterfaceReaderSource
(reader InterfaceReader)
stream/source/interfacereader.go:35
Function
NewInterfaceTimingOp
* func NewInterfaceTimingOp() (oper stream.Operator, count *uint32, duration *time.Duration) { var counter = new(uint32) var dur time.Duration var
stream/timing/timing.go:65
Function
NewInterfaceWriterSink
(writer InterfaceWriter)
stream/sink/interfacewriter.go:35
Function
NewJsonDecodeRop
(gen interface{})
stream/encoding/json.go:41
Function
NewJsonEncodeRop
()
stream/encoding/json.go:45
Function
NewMakeInterfaceOp
()
stream/util/util.go:17
Function
NewMakeProtobufMessageOp
()
stream/encoding/protobuf.go:53
Function
NewMemoryBuffer
(size int)
util/util.go:13
Function
NewMultiPartWriterSink
(writer io.Writer)
stream/sink/writer.go:124
Function
NewNonBlockingProcessedNotifier
(slack int)
stream/ProcessedNotifier.go:18
Function
NewOp
(proc interface{}, tn string)
stream/mapper/operator.go:7
Function
NewOpExitor
(callback interface{}, exitCallback func(), tn string)
stream/mapper/operator.go:15
Function
NewOpFactory
(proc interface{}, tn string)
stream/mapper/operator.go:23
Function
NewOpWorkerCloserFactory
(proc interface{}, tn string)
stream/mapper/operator.go:31
Function
NewOpWorkerFinalItemsFactory
(proc interface{}, tn string)
stream/mapper/operator.go:39
Function
NewOrderedOp
(proc interface{}, tn string)
stream/mapper/orderpreserving.go:9
Function
NewPgBatchOperator
(parse func(stream.Object) (Dimensions, Aggregates), downstreamProcessed stream.ProcessedNotifier)
cube/operator.go:37
Function
NewProcessedNotifier
()
stream/ProcessedNotifier.go:14
Function
NewProtobufDecodeOp
(gen interface{})
stream/encoding/protobuf.go:33
Function
NewProtobufEncodeOp
()
stream/encoding/protobuf.go:37
Function
NewSequentialBufferChanImpl
(maxItems int)
util/util.go:116
Function
NewSimpleEra
()
cluster/era.go:16
Function
NewSimpleNode
(name string, ip string, port string)
cluster/node.go:26
Function
NewSnappyDecodeOp
()
stream/compress/snappy.go:24
Function
NewSnappyEncodeOp
()
stream/compress/snappy.go:10
Function
NewStaticManager
(e Era)
cluster/manager.go:35
Function
NewStreamingMetrics
(mReg metrics.Registry)
util/util.go:198
← previous
next →
301–400 of 520, ranked by callers