Versions in this module Expand all Collapse all v0 v0.6.9 Jan 10, 2019 Changes in this version + const SortInputsFirst + const SortOutputsFirst + func HTTPHandler(path string, s http.Handler) fnMux + func Pipelines() map[string]*Pipeline + func ProcessorsDocs(code string) map[string]*doc.Processor + func RegisterProcessor(name string, procFact ProcessorFactory) + func Start(opt Options) + func Stop() error + func StopPipeline(Uuid string) error + func Storage() *store.Store + type Agent struct + AgentRecipients PortList + AgentSources PortList + Buffer int + Done chan bool + ID int + Label string + Options map[string]interface{} + PipelineName string + PipelineUUID string + PoolSize int + Schedule string + Sources []string + Trace bool + Type string + Wd string + func NewAgent() Agent + func Sort(agentConflist map[int]*Agent, sortOrder int) []*Agent + func (a *Agent) Processor() processors.Processor + type Codec struct + Name string + Options map[string]interface{} + Role string + func NewCodec(name string) *Codec + func (c *Codec) GetName() string + func (c *Codec) GetOptions() map[string]interface{} + func (c *Codec) GetRole() string + func (c *Codec) String() string + type Logger struct + func Log() *Logger + func NewLogger(component string, data map[string]interface{}) *Logger + func (p *Logger) Debug(args ...interface{}) + func (p *Logger) Debugf(format string, args ...interface{}) + func (p *Logger) Debugln(args ...interface{}) + func (p *Logger) Error(args ...interface{}) + func (p *Logger) Errorf(format string, args ...interface{}) + func (p *Logger) Errorln(args ...interface{}) + func (p *Logger) Fatal(args ...interface{}) + func (p *Logger) Fatalf(format string, args ...interface{}) + func (p *Logger) Fatalln(args ...interface{}) + func (p *Logger) Info(args ...interface{}) + func (p *Logger) Infof(format string, args ...interface{}) + func (p *Logger) Infoln(args ...interface{}) + func (p *Logger) Panic(args ...interface{}) + func (p *Logger) Panicf(format string, args ...interface{}) + func (p *Logger) Panicln(args ...interface{}) + func (p *Logger) Print(args ...interface{}) + func (p *Logger) Printf(format string, args ...interface{}) + func (p *Logger) Println(args ...interface{}) + func (p *Logger) Warn(args ...interface{}) + func (p *Logger) Warnf(format string, args ...interface{}) + func (p *Logger) Warning(args ...interface{}) + func (p *Logger) Warningf(format string, args ...interface{}) + func (p *Logger) Warningln(args ...interface{}) + func (p *Logger) Warnln(args ...interface{}) + type Options struct + DataLocation string + Debug bool + Host string + HttpHandlers []fnMux + LogFile string + Prometheus string + VerboseLog bool + type Pipeline struct + ConfigHostLocation string + ConfigLocation string + Description string + Label string + Schedulers []schedulerJob + StartedAt time.Time + Uuid string + Webhooks []webhook.Hook + func GetPipeline(UUID string) (*Pipeline, bool) + func NewPipeline() *Pipeline + func (p *Pipeline) AddAgent(a Agent) error + func (p *Pipeline) Agents() map[int]*Agent + func (p *Pipeline) Start() (string, error) + func (p *Pipeline) Stop() error + type Port struct + AgentID int + PortNumber int + type PortList []Port + func (a *PortList) String() string + func (a *PortList) StringReversePort() string + type ProcessorFactory func() processors.Processor