mocks_rsources

Documentation

Overview

Package mocks_rsources is a generated GoMock package.

Index

• type MockJobService
  • func NewMockJobService(ctrl *gomock.Controller) *MockJobService
  • func (m *MockJobService) AddFailedRecords(ctx context.Context, tx *sql.Tx, jobRunId string, key rsources.JobTargetKey, ...) error
  • func (m *MockJobService) Delete(ctx context.Context, tx sql.Tx, jobRunId string)
  • func (m *MockJobService) EXPECT() *MockJobServiceMockRecorder
  • func (m *MockJobService) GetFailedRecords(ctx context.Context, tx *sql.Tx, jobRunId string, filter rsources.JobFilter) (rsources.FailedRecords, error)
  • func (m *MockJobService) GetStatus(ctx context.Context, jobRunId string, filter rsources.JobFilter) (rsources.JobStatus, error)
  • func (m *MockJobService) IncrementStats(ctx context.Context, tx *sql.Tx, jobRunId string, key rsources.JobTargetKey, ...) error
• type MockJobServiceMockRecorder
  • func (mr *MockJobServiceMockRecorder) AddFailedRecords(ctx, tx, jobRunId, key, records interface{}) *gomock.Call
  • func (mr *MockJobServiceMockRecorder) Delete(ctx, tx, jobRunId interface{}) *gomock.Call
  • func (mr *MockJobServiceMockRecorder) GetFailedRecords(ctx, tx, jobRunId, filter interface{}) *gomock.Call
  • func (mr *MockJobServiceMockRecorder) GetStatus(ctx, jobRunId, filter interface{}) *gomock.Call
  • func (mr *MockJobServiceMockRecorder) IncrementStats(ctx, tx, jobRunId, key, stats interface{}) *gomock.Call

Types

type MockJobService

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

MockJobService is a mock of JobService interface.

func NewMockJobService

func NewMockJobService(ctrl *gomock.Controller) *MockJobService

NewMockJobService creates a new mock instance.

func (*MockJobService) AddFailedRecords

func (m *MockJobService) AddFailedRecords(ctx context.Context, tx *sql.Tx, jobRunId string, key rsources.JobTargetKey, records []json.RawMessage) error

AddFailedRecords mocks base method.

func (*MockJobService) Delete

func (m *MockJobService) Delete(ctx context.Context, tx sql.Tx, jobRunId string)

Delete mocks base method.

func (*MockJobService) EXPECT

func (m *MockJobService) EXPECT() *MockJobServiceMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockJobService) GetFailedRecords

func (m *MockJobService) GetFailedRecords(ctx context.Context, tx *sql.Tx, jobRunId string, filter rsources.JobFilter) (rsources.FailedRecords, error)

GetFailedRecords mocks base method.

func (*MockJobService) GetStatus

func (m *MockJobService) GetStatus(ctx context.Context, jobRunId string, filter rsources.JobFilter) (rsources.JobStatus, error)

GetStatus mocks base method.

func (*MockJobService) IncrementStats

func (m *MockJobService) IncrementStats(ctx context.Context, tx *sql.Tx, jobRunId string, key rsources.JobTargetKey, stats rsources.Stats) error

IncrementStats mocks base method.

type MockJobServiceMockRecorder

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

MockJobServiceMockRecorder is the mock recorder for MockJobService.

func (*MockJobServiceMockRecorder) AddFailedRecords

func (mr *MockJobServiceMockRecorder) AddFailedRecords(ctx, tx, jobRunId, key, records interface{}) *gomock.Call

AddFailedRecords indicates an expected call of AddFailedRecords.

func (*MockJobServiceMockRecorder) Delete

func (mr *MockJobServiceMockRecorder) Delete(ctx, tx, jobRunId interface{}) *gomock.Call

Delete indicates an expected call of Delete.

func (*MockJobServiceMockRecorder) GetFailedRecords

func (mr *MockJobServiceMockRecorder) GetFailedRecords(ctx, tx, jobRunId, filter interface{}) *gomock.Call

GetFailedRecords indicates an expected call of GetFailedRecords.

func (*MockJobServiceMockRecorder) GetStatus

func (mr *MockJobServiceMockRecorder) GetStatus(ctx, jobRunId, filter interface{}) *gomock.Call

GetStatus indicates an expected call of GetStatus.

func (*MockJobServiceMockRecorder) IncrementStats

func (mr *MockJobServiceMockRecorder) IncrementStats(ctx, tx, jobRunId, key, stats interface{}) *gomock.Call

IncrementStats indicates an expected call of IncrementStats.