engine

package

v0.1.3 Latest Latest Go to latest Published: Sep 10, 2023 License: MIT Imports: 16 Imported by: 4

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/runabol/tork

Links

Open Source Insights

Documentation ¶

Index ¶

type Engine
- func New(mode Mode) *Engine
type Mode
type OnStartedHandler

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

This section is empty.

Types ¶

type Engine ¶

type Engine struct {
	// contains filtered or unexported fields
}

func New ¶

func New(mode Mode) *Engine

func (*Engine) OnStarted ¶

func (e *Engine) OnStarted(h OnStartedHandler)

func (*Engine) RegisterEndpoint ¶

func (e *Engine) RegisterEndpoint(method, path string, handler request.HandlerFunc)

func (*Engine) RegisterJobMiddleware ¶ added in v0.1.3

func (e *Engine) RegisterJobMiddleware(mw job.MiddlewareFunc)

func (*Engine) RegisterNodeMiddleware ¶ added in v0.1.3

func (e *Engine) RegisterNodeMiddleware(mw node.MiddlewareFunc)

func (*Engine) RegisterRequestMiddleware ¶ added in v0.1.3

func (e *Engine) RegisterRequestMiddleware(mw request.MiddlewareFunc)

func (*Engine) RegisterTaskMiddleware ¶ added in v0.1.3

func (e *Engine) RegisterTaskMiddleware(mw task.MiddlewareFunc)

func (*Engine) Start ¶

func (e *Engine) Start() error

func (*Engine) Terminate ¶

func (e *Engine) Terminate()

type Mode ¶

type Mode string

const (
	ModeCoordinator Mode = "coordinator"
	ModeWorker      Mode = "worker"
	ModeStandalone  Mode = "standalone"
)

type OnStartedHandler ¶

type OnStartedHandler func() error

OnStartedHandler a bootstrap hook that is called after Tork has finished starting up. If a non-nil error is returned it will terminate the bootstrap process.

Source Files ¶

View all Source files

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