function

type ExecutionEnvironment struct {
	Auth      model.Auth
	BaseName  string
	DataStore database.Persister
	Volatile  cache.Volatilizer
	Email     email.Mailer
	Search    *search.Search
	Data      model.ExecData

	CurrentRun model.ExecHistory
	Log        *logger.Logger
}

type HTTPResponse struct {
	Status int    `json:"status"`
	Body   string `json:"body"`
}

type JSFetchOptionsArg struct {
	Method         string
	Headers        map[string]string
	Body           string
	Mode           string
	Credentials    string
	Cache          string
	Redirect       string
	Referrer       string
	ReferrerPolicy string
	Integrity      string
	Keepalive      string
	Signal         string
}

type JSSendMailArg struct {
	From     string `json:"from"`
	To       string `json:"to"`
	Subject  string `json:"subject"`
	HTMLBody string `json:"htmlBody"`
	TextBody string `json:"textBody"`
}

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

type Subscriber struct {
	PubSub            cache.Volatilizer
	GetExecEnv        func(msg model.Command) (*ExecutionEnvironment, error)
	Log               *logger.Logger
	IsPrimaryInstance bool
	// contains filtered or unexported fields
}

type TaskScheduler struct {
	Volatile  cache.Volatilizer
	DataStore database.Persister
	Search    *search.Search
	Email     email.Mailer
	Log       *logger.Logger

	Scheduler *gocron.Scheduler
}