engine

package module
v0.0.0-...-780ac92 Latest Latest
Warning

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

Go to latest
Published: Mar 7, 2024 License: Apache-2.0 Imports: 14 Imported by: 0

README

as-etl-engine

engine

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func NewEnveronment

func NewEnveronment(filename string, addr string) (e *enveronment)

func NewMetricHandler

func NewMetricHandler(engine *Engine) *metricHandler

Types

type Engine

type Engine struct {
	container.Container
	// contains filtered or unexported fields
}

Engine: execution engine

func NewEngine

func NewEngine(ctx context.Context, conf *config.JSON) *Engine

NewEngine: create a new execution engine based on context ctx and JSON configuration conf

func (*Engine) Start

func (e *Engine) Start() (err error)

Start: start

type Model

type Model string

Model Mode

var (
	ModelJob       Model = "job"       // Work by Job
	ModelTaskGroup Model = "taskGroup" // Work by Task Group
)

Container Work Mode

func (Model) IsJob

func (m Model) IsJob() bool

IsJob: whether to work by job

func (Model) IsTaskGroup

func (m Model) IsTaskGroup() bool

IsTaskGroup: whether to work by task group

Jump to

Keyboard shortcuts

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