function

package
v1.3.0 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Mar 16, 2022 License: MIT Imports: 11 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type ExecutionEnvironment

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

	CurrentRun internal.ExecHistory
}

func (*ExecutionEnvironment) Execute

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

type Result

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

type Subscriber

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

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 {
	Client    *mongo.Client
	Volatile  internal.PubSuber
	DataStore internal.Persister
	Scheduler *gocron.Scheduler
}

func (*TaskScheduler) Start

func (ts *TaskScheduler) Start()

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL