function

type ExecutionEnvironment struct {
	Auth      internal.Auth
	BaseName  string
	DataStore internal.Persister
	Volatile  internal.PubSuber
	Data      internal.ExecData

	CurrentRun internal.ExecHistory
	// contains filtered or unexported fields
}

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 Result struct {
	OK      bool        `json:"ok"`
	Content interface{} `json:"content"`
}

type Subscriber struct {
	PubSub     internal.PubSuber
	GetExecEnv func(token string) (ExecutionEnvironment, error)
	Log        *logger.Logger
}

type TaskScheduler struct {
	Client    *mongo.Client
	Volatile  internal.PubSuber
	DataStore internal.Persister
	Scheduler *gocron.Scheduler
	// contains filtered or unexported fields
}