module_test_runner

Apr 4, 2024

Changes in this version

type RunnerTest

+ ExecuteWithoutStageRetryOverride func(ctx *sparkv1.JobContext, opts ...sparkv1.Option) (*Outputs, error)

May 24, 2023

Changes in this version

+ func MustEncode(data any) []byte

+ type Input struct

+ MimeType codec.MimeType

+ Value any

+ type Inputs map[string]*Input

Jan 11, 2023

Changes in this version

+ func WithSparkConfigJSON(d []byte) sparkv1.Option

+ func WithSparkConfigYAML(d []byte) sparkv1.Option

Jan 11, 2023

Changes in this version

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

+ var ErrNoOutput = errors.New("unable to find output")

+ var ErrNoStageResult = errors.New("stage result not found")

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

+ type Option = func(je *testOpts) *testOpts

+ func WithBasePath(configBasePath string) Option

+ type Outputs struct

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

+ type RunnerTest interface

+ Execute func(ctx *sparkv1.JobContext, opts ...sparkv1.Option) (*Outputs, error)

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

Nov 18, 2022

Changes in this version

+ type MockContext struct

+ func NewMockContext(ctrl *gomock.Controller) *MockContext

+ func (m *MockContext) CorrelationID() string

+ func (m *MockContext) Ctx() context.Context

+ func (m *MockContext) EXPECT() *MockContextMockRecorder

+ func (m *MockContext) JobKey() string

+ func (m *MockContext) LastActiveStage() *sdk_v1.LastActiveStage

+ func (m *MockContext) TransactionID() string

+ type MockContextMockRecorder struct

+ func (mr *MockContextMockRecorder) CorrelationID() *gomock.Call

+ func (mr *MockContextMockRecorder) Ctx() *gomock.Call

+ func (mr *MockContextMockRecorder) JobKey() *gomock.Call

+ func (mr *MockContextMockRecorder) LastActiveStage() *gomock.Call

+ func (mr *MockContextMockRecorder) TransactionID() *gomock.Call

+ type MockStageProgressHandler struct

+ func NewMockStageProgressHandler(ctrl *gomock.Controller) *MockStageProgressHandler

+ func (m *MockStageProgressHandler) EXPECT() *MockStageProgressHandlerMockRecorder

+ func (m *MockStageProgressHandler) Get(arg0, arg1 string) (*spark_v1.StageStatus, error)

+ func (m *MockStageProgressHandler) GetResult(arg0, arg1 string) *spark_v1.Result

+ func (m *MockStageProgressHandler) Set(arg0 *spark_v1.SetStageStatusRequest) error

+ func (m *MockStageProgressHandler) SetJobStatus(arg0 *spark_v1.SetJobStatusRequest) error

+ func (m *MockStageProgressHandler) SetResult(arg0 *spark_v1.SetStageResultRequest) error

+ type MockStageProgressHandlerMockRecorder struct

+ func (mr *MockStageProgressHandlerMockRecorder) Get(arg0, arg1 interface{}) *gomock.Call

+ func (mr *MockStageProgressHandlerMockRecorder) GetResult(arg0, arg1 interface{}) *gomock.Call

+ func (mr *MockStageProgressHandlerMockRecorder) Set(arg0 interface{}) *gomock.Call

+ func (mr *MockStageProgressHandlerMockRecorder) SetJobStatus(arg0 interface{}) *gomock.Call

+ func (mr *MockStageProgressHandlerMockRecorder) SetResult(arg0 interface{}) *gomock.Call