floop

Mar 27, 2018

Changes in this version

type Lifecycle

+ func (lc *Lifecycle) Canceled(result *types.ChildResult)

Nov 20, 2017

Changes in this version

+ func TransformResult(transform []string, input *types.ChildResult, out *types.Event) (transformed bool, err error)

type Config

+ ReadFromStderr bool

type Handler

+ CloseConnection func() error

type Lifecycle

+ func (lc *Lifecycle) Close()

+ type Result struct

+ Code int

+ Stderr interface{}

+ Stdout interface{}

Sep 29, 2017

Changes in this version

+ const VERSION

type Config

+ ResolverHosts []string

+ ResolverPort int

Jul 27, 2017

Changes in this version

+ func Transform(transform []string, input []byte, out *types.Event) (transformed bool, err error)

+ type BufferedWriter struct

+ func NewBufferedWriter(cb func([]byte), buffer bool) *BufferedWriter

+ func (wr *BufferedWriter) Bytes() []byte

+ func (wr *BufferedWriter) Write(b []byte) (int, error)

+ type Config struct

+ Args []string

+ Command string

+ Handlers map[types.EventType][]*types.HandlerConfig

+ Meta []string

+ Quiet bool

+ func DefaultConfig() *Config

+ func LoadConfig(filename string) (*Config, error)

+ func (conf *Config) HasMeta(meta map[string]interface{}) bool

+ type Floop struct

+ func New(conf *Config, input *child.NewInput) (*Floop, error)

+ func (floop *Floop) Start(meta map[string]interface{}) error

+ func (floop *Floop) Wait() int

+ type Handler interface

+ Handle func(event *types.Event, conf *types.HandlerConfig) (map[string]interface{}, error)

+ Init func(conf *types.HandlerConfig) error

+ type Lifecycle struct

+ func NewLifecycle(conf *Config) (*Lifecycle, error)

+ func (lc *Lifecycle) Begin(ctx *types.Context) error

+ func (lc *Lifecycle) Completed(result *types.ChildResult)

+ func (lc *Lifecycle) Failed(result *types.ChildResult)

+ func (lc *Lifecycle) Progress(line []byte)