function

Documentation

Index

• type ExecutionEnvironment
  • func (env *ExecutionEnvironment) Execute(data interface{}) error
• type HTTPResponse
• type JSFetchOptionsArg
  • func NewJSFetcthOptionArg() JSFetchOptionsArg
• type JSSendMailArg
• type Result
• type Subscriber
  • func (sub *Subscriber) Start()
• type TaskScheduler
  • func (ts *TaskScheduler) AddOnTheFly(task model.Task)
  • func (ts *TaskScheduler) CancelTask(id string) error
  • func (ts *TaskScheduler) Start()

Types

type ExecutionEnvironment

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
}

func (*ExecutionEnvironment) Execute

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

type HTTPResponse

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

type JSFetchOptionsArg

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
}

func NewJSFetcthOptionArg

func NewJSFetcthOptionArg() JSFetchOptionsArg

type JSSendMailArg

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

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

type Subscriber

type Subscriber struct {
	PubSub            cache.Volatilizer
	GetExecEnv        func(msg model.Command) (*ExecutionEnvironment, error)
	Log               *logger.Logger
	IsPrimaryInstance bool
	// 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 the topic/trigger

type TaskScheduler

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

	Scheduler *gocron.Scheduler
}

func (*TaskScheduler) AddOnTheFly

func (ts *TaskScheduler) AddOnTheFly(task model.Task)

func (*TaskScheduler) CancelTask

func (ts *TaskScheduler) CancelTask(id string) error

func (*TaskScheduler) Start

func (ts *TaskScheduler) Start()