core

Documentation

Index

• func AddEndpoint(path string, handler http.Handler)
• func NewVMWithPlugins(context types.JobContext) *otto.Otto
• func RegisterPlugin(plugin types.Plugin)
• func StartServer(port int)
• type JobEngine
  • func GetEngineInstance() *JobEngine
  • func (engine *JobEngine) ExecuteStoredJob(jobName string, receivedParameters map[string]interface{}) error
  • func (engine *JobEngine) GetJobByName(name string) (types.Job, error)
  • func (engine *JobEngine) GetJobs() []types.Job
  • func (engine *JobEngine) Start()

Functions

func AddEndpoint

func AddEndpoint(path string, handler http.Handler)

AddEndpoint Adds a http endpoint to the server

func NewVMWithPlugins

func NewVMWithPlugins(context types.JobContext) *otto.Otto

NewVMWithPlugins Creates a new VM instance using plugins. @Param context map[string]interface{} Contains information about the process who creates this VM

func RegisterPlugin

func RegisterPlugin(plugin types.Plugin)

RegisterPlugin Registers a plugin

func StartServer

func StartServer(port int)

StartServer Starts graphql api on selected port

Types

type JobEngine

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

JobEngine Represents the state machine manager

func GetEngineInstance

func GetEngineInstance() *JobEngine

GetEngineInstance Returns the singleton instance of JobEngine

func (*JobEngine) ExecuteStoredJob

func (engine *JobEngine) ExecuteStoredJob(jobName string, receivedParameters map[string]interface{}) error

ExecuteStoredJob Executes an existing job

func (*JobEngine) GetJobByName

func (engine *JobEngine) GetJobByName(name string) (types.Job, error)

GetJobByName Returns the job with specified name

func (*JobEngine) GetJobs

func (engine *JobEngine) GetJobs() []types.Job

GetJobs Returns the list of jobs registered

func (*JobEngine) Start

func (engine *JobEngine) Start()

Start Starts engine logic