Versions in this module Expand all Collapse all v0 v0.2.4 Apr 18, 2014 Changes in this version + const MAX_UDP_MESSAGE_SIZE + var BlockDefs = map[string]*blocks.BlockDef + var Blocks = map[string]func() blocks.BlockInterface + func NewCache() blocks.BlockInterface + func NewCount() blocks.BlockInterface + func NewDeDupe() blocks.BlockInterface + func NewFilter() blocks.BlockInterface + func NewFromEmail() blocks.BlockInterface + func NewFromFile() blocks.BlockInterface + func NewFromHTTPStream() blocks.BlockInterface + func NewFromNSQ() blocks.BlockInterface + func NewFromPost() blocks.BlockInterface + func NewFromSQS() blocks.BlockInterface + func NewFromUDP() blocks.BlockInterface + func NewFromWebsocket() blocks.BlockInterface + func NewGaussian() blocks.BlockInterface + func NewGetHTTP() blocks.BlockInterface + func NewHistogram() blocks.BlockInterface + func NewJoin() blocks.BlockInterface + func NewKullbackLeibler() blocks.BlockInterface + func NewLearn() blocks.BlockInterface + func NewLinearModel() blocks.BlockInterface + func NewListenerUDP(block blocks.BlockInterface, connectionString string, out chan []byte) (*listenerUDP, error) + func NewLogisticModel() blocks.BlockInterface + func NewMap() blocks.BlockInterface + func NewMask() blocks.BlockInterface + func NewMovingAverage() blocks.BlockInterface + func NewPack() blocks.BlockInterface + func NewParseXML() blocks.BlockInterface + func NewPoisson() blocks.BlockInterface + func NewPoissonSampler(λ float64) func() int + func NewQueue() blocks.BlockInterface + func NewSet() blocks.BlockInterface + func NewSkeleton() blocks.BlockInterface + func NewSync() blocks.BlockInterface + func NewTicker() blocks.BlockInterface + func NewTimeseries() blocks.BlockInterface + func NewToBeanstalkd() blocks.BlockInterface + func NewToElasticsearch() blocks.BlockInterface + func NewToEmail() blocks.BlockInterface + func NewToFile() blocks.BlockInterface + func NewToLog() blocks.BlockInterface + func NewToMongoDB() blocks.BlockInterface + func NewToNSQ() blocks.BlockInterface + func NewToNSQMulti() blocks.BlockInterface + func NewToggle() blocks.BlockInterface + func NewUnpack() blocks.BlockInterface + func NewZipf() blocks.BlockInterface + func Start() + type Cache struct + func (b *Cache) Run() + func (b *Cache) Setup() + type Count struct + func (b *Count) Run() + func (b *Count) Setup() + type DeDupe struct + func (b *DeDupe) Run() + func (b *DeDupe) Setup() + type Filter struct + func (b *Filter) Run() + func (b *Filter) Setup() + type FromEmail struct + func (e *FromEmail) Run() + func (e *FromEmail) Setup() + type FromFile struct + func (b *FromFile) Run() + func (b *FromFile) Setup() + type FromHTTPStream struct + func (b *FromHTTPStream) Run() + func (b *FromHTTPStream) Setup() + type FromNSQ struct + func (b *FromNSQ) Run() + func (b *FromNSQ) Setup() + type FromPost struct + func (b *FromPost) Run() + func (b *FromPost) Setup() + type FromSQS struct + func (b *FromSQS) Run() + func (b *FromSQS) Setup() + type FromUDP struct + func (u *FromUDP) Run() + func (u *FromUDP) Setup() + type FromWebsocket struct + func (b *FromWebsocket) Run() + func (b *FromWebsocket) Setup() + type Gaussian struct + func (b *Gaussian) Run() + func (b *Gaussian) Setup() + type GetHTTP struct + func (b *GetHTTP) Run() + func (b *GetHTTP) Setup() + type Histogram struct + func (b *Histogram) Run() + func (b *Histogram) Setup() + type Join struct + func (b *Join) Run() + func (b *Join) Setup() + type KullbackLeibler struct + func (b *KullbackLeibler) Run() + func (b *KullbackLeibler) Setup() + type Learn struct + func (b *Learn) Run() + func (b *Learn) Setup() + type LinearModel struct + func (b *LinearModel) Run() + func (b *LinearModel) Setup() + type LogisticModel struct + func (b *LogisticModel) Run() + func (b *LogisticModel) Setup() + type Map struct + func (b *Map) Run() + func (b *Map) Setup() + type Mask struct + func (b *Mask) Run() + func (b *Mask) Setup() + type MovingAverage struct + func (b *MovingAverage) Run() + func (b *MovingAverage) Setup() + type PQMessage struct + type Pack struct + func (b *Pack) Run() + func (b *Pack) Setup() + type ParseXML struct + func (b *ParseXML) Run() + func (b *ParseXML) Setup() + type Poisson struct + func (b *Poisson) Run() + func (b *Poisson) Setup() + type PriorityQueue []*PQMessage + func (pq *PriorityQueue) Peek() interface{} + func (pq *PriorityQueue) PeekAndShift(max time.Time, lag time.Duration) (interface{}, time.Duration) + func (pq *PriorityQueue) Pop() interface{} + func (pq *PriorityQueue) Push(x interface{}) + func (pq PriorityQueue) Len() int + func (pq PriorityQueue) Less(i, j int) bool + func (pq PriorityQueue) Swap(i, j int) + type Queue struct + func (b *Queue) Run() + func (b *Queue) Setup() + type Set struct + func (b *Set) Run() + func (b *Set) Setup() + type Skeleton struct + func (b *Skeleton) Run() + func (b *Skeleton) Setup() + type Sync struct + func (b *Sync) Run() + func (b *Sync) Setup() + type Ticker struct + func (b *Ticker) Run() + func (b *Ticker) Setup() + type Timeseries struct + func (b *Timeseries) Run() + func (b *Timeseries) Setup() + type ToBeanstalkd struct + func (b *ToBeanstalkd) Run() + func (b *ToBeanstalkd) Setup() + type ToElasticsearch struct + func (b *ToElasticsearch) Run() + func (b *ToElasticsearch) Setup() + type ToEmail struct + func (e *ToEmail) Run() + func (e *ToEmail) Send(msg interface{}) error + func (e *ToEmail) Setup() + type ToFile struct + func (b *ToFile) Run() + func (b *ToFile) Setup() + type ToLog struct + func (b *ToLog) Run() + func (b *ToLog) Setup() + type ToMongoDB struct + func (b *ToMongoDB) Run() + func (b *ToMongoDB) Setup() + type ToNSQ struct + func (b *ToNSQ) Run() + func (b *ToNSQ) Setup() + type ToNSQMulti struct + func (b *ToNSQMulti) Run() + func (b *ToNSQMulti) Setup() + type Toggle struct + func (b *Toggle) Run() + func (b *Toggle) Setup() + type Unpack struct + func (b *Unpack) Run() + func (b *Unpack) Setup() + type Zipf struct + func (b *Zipf) Run() + func (b *Zipf) Setup()