type ExecutionEnvironment struct {Authmodel.AuthBaseNamestringDataStoredatabase.PersisterVolatilecache.VolatilizerEmailemail.MailerSearch    *search.SearchDatamodel.ExecDataCurrentRunmodel.ExecHistoryLog        *logger.Logger}

func (*ExecutionEnvironment)Execute¶

func (env *ExecutionEnvironment) Execute(data interface{})error

type HTTPResponse struct {Statusint    `json:"status"`Bodystring `json:"body"`}

type JSFetchOptionsArg struct {MethodstringHeaders        map[string]stringBodystringModestringCredentialsstringCachestringRedirectstringReferrerstringReferrerPolicystringIntegritystringKeepalivestringSignalstring}

funcNewJSFetcthOptionArg¶added inv1.4.0

func NewJSFetcthOptionArg()JSFetchOptionsArg

type JSSendMailArg struct {Fromstring `json:"from"`Tostring `json:"to"`Subjectstring `json:"subject"`HTMLBodystring `json:"htmlBody"`TextBodystring `json:"textBody"`}

type Result struct {OKbool        `json:"ok"`Content interface{} `json:"content"`}

type Subscriber struct {PubSubcache.VolatilizerGetExecEnv        func(msgmodel.Command) (*ExecutionEnvironment,error)Log               *logger.LoggerIsPrimaryInstancebool// contains filtered or unexported fields}

func (*Subscriber)Start¶

func (sub *Subscriber) Start()

Start starts the system event subscription.This channel is responsible of executing functions that match thetopic/trigger

type TaskScheduler struct {Volatilecache.VolatilizerDataStoredatabase.PersisterSearch    *search.SearchEmailemail.MailerLog       *logger.LoggerScheduler *gocron.Scheduler}

func (*TaskScheduler)AddOnTheFly¶added inv1.5.0

func (ts *TaskScheduler) AddOnTheFly(taskmodel.Task)

func (*TaskScheduler)CancelTask¶added inv1.5.0

func (ts *TaskScheduler) CancelTask(idstring)error

func (*TaskScheduler)Start¶

func (ts *TaskScheduler) Start()