v1

Documentation

Index

• func NewSparkTestWorker(t *testing.T, chain *spark.Chain, options ...Option) sdk_v1.Worker
• func NewSparkWorker(cfg *config.Config, chain *spark.Chain, options ...Option) (sdk_v1.Worker, error)
• type Option
  • func WithIOHandler(vh sdk_v1.IOHandler) Option
  • func WithLog(log sdk_v1.Logger) Option
  • func WithStageProgressHandler(sph sdk_v1.StageProgressHandler) Option
• type SparkWorker
  • func (w *SparkWorker) Execute(metadata sdk_v1.Context) sdk_v1.StageError
• type TestWorker
  • func (t TestWorker) Execute(ctx sdk_v1.Context) sdk_v1.StageError

Functions

func NewSparkTestWorker

func NewSparkTestWorker(t *testing.T, chain *spark.Chain, options ...Option) sdk_v1.Worker

func NewSparkWorker

func NewSparkWorker(cfg *config.Config, chain *spark.Chain, options ...Option) (sdk_v1.Worker, error)

Types

type Option

type Option = func(je *SparkWorker) *SparkWorker

func WithIOHandler

func WithIOHandler(vh sdk_v1.IOHandler) Option

func WithLog

func WithLog(log sdk_v1.Logger) Option

func WithStageProgressHandler

func WithStageProgressHandler(sph sdk_v1.StageProgressHandler) Option

type SparkWorker

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

func (*SparkWorker) Execute

func (w *SparkWorker) Execute(metadata sdk_v1.Context) sdk_v1.StageError

type TestWorker

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

func (TestWorker) Execute

func (t TestWorker) Execute(ctx sdk_v1.Context) sdk_v1.StageError