pipeline

Documentation

Index

• type PipeInput
  • func CreateInput() *PipeInput
• type Pipeline
  • func NewPipeline(config *config.Config, client *interpreter.Handler) *Pipeline
  • func (p *Pipeline) Config() *config.Config
  • func (p *Pipeline) Input(input interface{}) error
  • func (p *Pipeline) Start(client *interpreter.Handler) error
  • func (p *Pipeline) State() State
  • func (p *Pipeline) Stop() error
• type PipelineHandler
  • func NewPipelineHandler(rulesUri, directory string) *PipelineHandler
  • func (p *PipelineHandler) Eval(data interface{}) error
  • func (p *PipelineHandler) Evaluate(w http.ResponseWriter, r *http.Request)
  • func (p *PipelineHandler) NewPipe(conf *config.Config, ruleUri string) error
  • func (p *PipelineHandler) NewPipeline(w http.ResponseWriter, r *http.Request)
  • func (p *PipelineHandler) ReadConfigFile(filename string) (*config.Config, error)
  • func (p *PipelineHandler) ReadPipelineConfig(w http.ResponseWriter, r *http.Request)
  • func (p *PipelineHandler) SetRoutes(r *mux.Router)
  • func (p *PipelineHandler) WatchConfigFile(directory string)
• type State

Types

type PipeInput

type PipeInput struct {
	Input chan interface{}
	Quit  chan bool
}

func CreateInput

func CreateInput() *PipeInput

type Pipeline

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

func NewPipeline

func NewPipeline(config *config.Config, client *interpreter.Handler) *Pipeline

func (*Pipeline) Config

func (p *Pipeline) Config() *config.Config

func (*Pipeline) Input

func (p *Pipeline) Input(input interface{}) error

func (*Pipeline) Start

func (p *Pipeline) Start(client *interpreter.Handler) error

func (*Pipeline) State

func (p *Pipeline) State() State

func (*Pipeline) Stop

func (p *Pipeline) Stop() error

type PipelineHandler

type PipelineHandler struct {
	RulesUrl string
	Parser   inference.Parser

	sync.RWMutex
	// contains filtered or unexported fields
}

func NewPipelineHandler

func NewPipelineHandler(rulesUri, directory string) *PipelineHandler

func (*PipelineHandler) Eval

func (p *PipelineHandler) Eval(data interface{}) error

func (*PipelineHandler) Evaluate

func (p *PipelineHandler) Evaluate(w http.ResponseWriter, r *http.Request)

func (*PipelineHandler) NewPipe

func (p *PipelineHandler) NewPipe(conf *config.Config, ruleUri string) error

func (*PipelineHandler) NewPipeline

func (p *PipelineHandler) NewPipeline(w http.ResponseWriter, r *http.Request)

func (*PipelineHandler) ReadConfigFile

func (p *PipelineHandler) ReadConfigFile(filename string) (*config.Config, error)

func (*PipelineHandler) ReadPipelineConfig

func (p *PipelineHandler) ReadPipelineConfig(w http.ResponseWriter, r *http.Request)

func (*PipelineHandler) SetRoutes

func (p *PipelineHandler) SetRoutes(r *mux.Router)

func (*PipelineHandler) WatchConfigFile

func (p *PipelineHandler) WatchConfigFile(directory string)

type State

type State int

const (
	RUNNING State = 1
	STOPPED State = 2
)