geetplaban

type AckValue struct {
	// contains filtered or unexported fields
}

type Acker interface {
	AddAck(id uint64, val uint64)
	AddTracking(ids string, trackerId uint) uint64
	AddTracker(id uint, tracker Tracker)
	SignalFail(id uint64)
	Start()
}

type AllStageStats struct {
	// contains filtered or unexported fields
}

type AllStages struct {
	// contains filtered or unexported fields
}

type AllStats struct {
	// contains filtered or unexported fields
}

type Collector interface {
	Emit(tuple map[string]interface{}, context interface{})
	Ack(context interface{})
	Fail(context interface{})
	AddOutput(outchan chan *OutPut)
	IsForDispatcher() bool
	// contains filtered or unexported methods
}

type Config struct {
	// contains filtered or unexported fields
}

type DispPatcherCaller struct {
	// contains filtered or unexported fields
}

type Dispatcher interface {
	LookForWork()
	Fail(string)
	Ack(string)
	TimedOut(string)
	Prepare(col Collector, tr *Tracker)
	Shutdown()
}

type DispatcherRegistry struct {
	// contains filtered or unexported fields
}

type DispatcherStageInfo struct {
	// contains filtered or unexported fields
}

type Executor interface {
	Execute(data map[string]interface{}, context interface{})
	AddCollector(Collector)
	AddIdentity(uint)
}

type ExecutorCaller struct {
	// contains filtered or unexported fields
}

type ExecutorRegistry struct {
	// contains filtered or unexported fields
}

type GraphNode struct {
	Name string
	// contains filtered or unexported fields
}

type GraphNodePool struct {
	// contains filtered or unexported fields
}

type LocalAcker struct {
	// contains filtered or unexported fields
}

type LogWriter struct {
	// contains filtered or unexported fields
}

type Logger struct {
	// contains filtered or unexported fields
}

type NextIdGetter struct {
	// contains filtered or unexported fields
}

type OutPut struct {
	// contains filtered or unexported fields
}

type StageInfo struct {
	// contains filtered or unexported fields
}

type StageStats struct {
	// contains filtered or unexported fields
}

type Tracker interface {
	Fail(id string)
	Ack(id string)
	TimedOut(id string)
}

type TupleCollector struct {
	// contains filtered or unexported fields
}

type UUID struct {
	// contains filtered or unexported fields
}