module_test_runner

Documentation

Index

• Variables
• func MustEncode(data any) []byte
• func NewTestJobContext(ctx context.Context, jobKey, correlationId, transactionId string, ...) *sparkv1.JobContext
• func WithSparkConfigJSON(d []byte) sparkv1.Option
• func WithSparkConfigYAML(d []byte) sparkv1.Option
• type Input
• type Inputs
• type Option
  • func WithBasePath(configBasePath string) Option
• type Outputs
  • func (o *Outputs) Bind(varName string, target any) error
• type RunnerTest
  • func NewTestRunner(t *testing.T, spark sparkv1.Spark, options ...Option) (RunnerTest, error)

Variables

var (
	ErrNoStageResult = errors.New("stage result not found")
	ErrNoOutput      = errors.New("unable to find output")
)

var (
	ErrInvalidStageResultMimeType = errors.New("stage result expects mime-type of application/json")
)

Functions

func MustEncode

func MustEncode(data any) []byte

func NewTestJobContext

func NewTestJobContext(ctx context.Context, jobKey, correlationId, transactionId string, inputs Inputs) *sparkv1.JobContext

func WithSparkConfigJSON

func WithSparkConfigJSON(d []byte) sparkv1.Option

func WithSparkConfigYAML

func WithSparkConfigYAML(d []byte) sparkv1.Option

Types

type Input

type Input struct {
	Value    any
	MimeType codec.MimeType
}

type Inputs

type Inputs map[string]*Input

type Option

type Option = func(je *testOpts) *testOpts

func WithBasePath

func WithBasePath(configBasePath string) Option

type Outputs

type Outputs struct {
	sparkv1.ExecuteSparkOutput
}

func (*Outputs) Bind

func (o *Outputs) Bind(varName string, target any) error

type RunnerTest

type RunnerTest interface {
	sparkv1.StageTracker
	Execute(ctx *sparkv1.JobContext, opts ...sparkv1.Option) (*Outputs, error)
	ExecuteWithoutStageRetryOverride(ctx *sparkv1.JobContext, opts ...sparkv1.Option) (*Outputs, error)
}

RunnerTest Test Helper

func NewTestRunner

func NewTestRunner(t *testing.T, spark sparkv1.Spark, options ...Option) (RunnerTest, error)