execution

package

v0.0.0-...-1c95f08 Latest Latest Go to latest Published: Mar 2, 2018 License: Apache-2.0 Imports: 12 Imported by: 0

Details

View Source

const (
	LIMIT   = "limit"
	FOREACH = "foreach"
	FILTER  = "filter"
	MAP     = "map"
	FOLD    = "fold"
)

View Source

var LuaPool *lStatePool = nil

This section is empty.

type Execution interface {
	ExecuteJob(message []byte, job *cluster.StartJob) (bool, error)
}

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

func NewLuaExecution(eventsProducer events.EventsProducer) (*LuaExecutor, error)

func (e *LuaExecutor) ExecuteJob(message []byte, job *cluster.StartJob) (bool, error)