module_runner

Documentation

Index

• Variables
• func LoadModuleConfig(opts ...ModuleOption) (*config, error)
• type ModuleOption
  • func WithBasePath(configBasePath string) ModuleOption
  • func WithBinBasePath(binBasePath string) ModuleOption
• type Runner
  • func RunModule(cfg *config) (Runner, error)

Variables

var (
	ErrStageResultNotFound            = errors.New("stage result not found")
	ErrChainDoesNotHaveACompleteStage = errors.New("no complete stage found in spark chain")
)

Functions

func LoadModuleConfig

func LoadModuleConfig(opts ...ModuleOption) (*config, error)

Types

type ModuleOption

type ModuleOption = func(je *moduleOpts) *moduleOpts

func WithBasePath

func WithBasePath(configBasePath string) ModuleOption

func WithBinBasePath

func WithBinBasePath(binBasePath string) ModuleOption

type Runner

type Runner interface {
	Stop() error
}

func RunModule

func RunModule(cfg *config) (Runner, error)