modules

Documentation

Index

• func RunJob(ctx context.Context, cancel context.CancelFunc, conf *FateJobConfig)
• type FateJobConfig
• type Module
  • func NewJob(i *FateJobConfig) (Module, error)

Functions

func RunJob

func RunJob(ctx context.Context, cancel context.CancelFunc, conf *FateJobConfig)

Types

type FateJobConfig

type FateJobConfig struct {
	TaskConfig     map[string]string
	ClusterAddress string
}

type Module

type Module interface {
	Run(ctx context.Context) error
	WaitReady(ctx context.Context) error
	Name() string
}

func NewJob

func NewJob(i *FateJobConfig) (Module, error)