localbinary

Nov 16, 2015

Changes in this version

+ type Executor struct

+ DriverName string

+ func (lbe *Executor) Close() error

+ func (lbe *Executor) Start() (*bufio.Scanner, *bufio.Scanner, error)

+ type Plugin struct

+ Addr string

+ Executor McnBinaryExecutor

+ MachineName string

+ func NewPlugin(driverName string) (*Plugin, error)

+ func (lbp *Plugin) Address() (string, error)

+ func (lbp *Plugin) AttachStream(scanner *bufio.Scanner) (<-chan string, chan<- bool)

+ func (lbp *Plugin) Close() error

+ func (lbp *Plugin) Serve() error

Nov 3, 2015

Changes in this version

+ const PluginEnvKey

+ const PluginEnvVal

+ type DriverPlugin interface

+ type ErrPluginBinaryNotFound struct

+ func (e ErrPluginBinaryNotFound) Error() string

+ type LocalBinaryExecutor struct

+ DriverName string

+ func (lbe *LocalBinaryExecutor) Close() error

+ func (lbe *LocalBinaryExecutor) Start() (*bufio.Scanner, *bufio.Scanner, error)

+ type LocalBinaryPlugin struct

+ Addr string

+ Executor McnBinaryExecutor

+ MachineName string

+ func NewLocalBinaryPlugin(driverName string) (*LocalBinaryPlugin, error)

+ func (lbp *LocalBinaryPlugin) Address() (string, error)

+ func (lbp *LocalBinaryPlugin) AttachStream(scanner *bufio.Scanner) (<-chan string, chan<- bool)

+ func (lbp *LocalBinaryPlugin) Close() error

+ func (lbp *LocalBinaryPlugin) Serve() error

+ type McnBinaryExecutor interface

+ Close func() error

+ Start func() (*bufio.Scanner, *bufio.Scanner, error)

+ type PluginServer interface

+ Address func() (string, error)

+ Close func() error

+ Serve func() error

+ type PluginStreamer interface

+ AttachStream func(*bufio.Scanner) (<-chan string, chan<- bool)