mock

Documentation

Overview

Package mock is a generated GoMock package.

Index

• type MockRepository
  • func NewMockRepository(ctrl *gomock.Controller) *MockRepository
  • func (m *MockRepository) Close() error
  • func (m *MockRepository) CreateStream(ctx context.Context, stream, table string) error
  • func (m *MockRepository) CreateTrackingTable(ctx context.Context, trackingTable, table string) error
  • func (m *MockRepository) EXPECT() *MockRepositoryMockRecorder
  • func (m *MockRepository) GetMaxValue(ctx context.Context, table, orderingColumn string) (any, error)
  • func (m *MockRepository) GetPrimaryKeys(ctx context.Context, table string) ([]string, error)
  • func (m *MockRepository) GetRows(ctx context.Context, table, orderingColumn string, fields []string, ...) (*sqlx.Rows, error)
  • func (m *MockRepository) GetTrackingData(ctx context.Context, stream, trackingTable string, fields []string, ...) ([]map[string]any, error)
• type MockRepositoryMockRecorder
  • func (mr *MockRepositoryMockRecorder) Close() *gomock.Call
  • func (mr *MockRepositoryMockRecorder) CreateStream(ctx, stream, table any) *gomock.Call
  • func (mr *MockRepositoryMockRecorder) CreateTrackingTable(ctx, trackingTable, table any) *gomock.Call
  • func (mr *MockRepositoryMockRecorder) GetMaxValue(ctx, table, orderingColumn any) *gomock.Call
  • func (mr *MockRepositoryMockRecorder) GetPrimaryKeys(ctx, table any) *gomock.Call
  • func (mr *MockRepositoryMockRecorder) GetRows(ctx, table, orderingColumn, fields, pos, maxValue, limit any) *gomock.Call
  • func (mr *MockRepositoryMockRecorder) GetTrackingData(ctx, stream, trackingTable, fields, offset, limit any) *gomock.Call

Types

type MockRepository

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

MockRepository is a mock of Repository interface.

func NewMockRepository

func NewMockRepository(ctrl *gomock.Controller) *MockRepository

NewMockRepository creates a new mock instance.

func (*MockRepository) Close

func (m *MockRepository) Close() error

Close mocks base method.

func (*MockRepository) CreateStream

func (m *MockRepository) CreateStream(ctx context.Context, stream, table string) error

CreateStream mocks base method.

func (*MockRepository) CreateTrackingTable

func (m *MockRepository) CreateTrackingTable(ctx context.Context, trackingTable, table string) error

CreateTrackingTable mocks base method.

func (*MockRepository) EXPECT

func (m *MockRepository) EXPECT() *MockRepositoryMockRecorder

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

func (*MockRepository) GetMaxValue

func (m *MockRepository) GetMaxValue(ctx context.Context, table, orderingColumn string) (any, error)

GetMaxValue mocks base method.

func (*MockRepository) GetPrimaryKeys

func (m *MockRepository) GetPrimaryKeys(ctx context.Context, table string) ([]string, error)

GetPrimaryKeys mocks base method.

func (*MockRepository) GetRows

func (m *MockRepository) GetRows(ctx context.Context, table, orderingColumn string, fields []string, pos *position.Position, maxValue any, limit int) (*sqlx.Rows, error)

GetRows mocks base method.

func (*MockRepository) GetTrackingData

func (m *MockRepository) GetTrackingData(ctx context.Context, stream, trackingTable string, fields []string, offset, limit int) ([]map[string]any, error)

GetTrackingData mocks base method.

type MockRepositoryMockRecorder

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

MockRepositoryMockRecorder is the mock recorder for MockRepository.

func (*MockRepositoryMockRecorder) Close

func (mr *MockRepositoryMockRecorder) Close() *gomock.Call

Close indicates an expected call of Close.

func (*MockRepositoryMockRecorder) CreateStream

func (mr *MockRepositoryMockRecorder) CreateStream(ctx, stream, table any) *gomock.Call

CreateStream indicates an expected call of CreateStream.

func (*MockRepositoryMockRecorder) CreateTrackingTable

func (mr *MockRepositoryMockRecorder) CreateTrackingTable(ctx, trackingTable, table any) *gomock.Call

CreateTrackingTable indicates an expected call of CreateTrackingTable.

func (*MockRepositoryMockRecorder) GetMaxValue

func (mr *MockRepositoryMockRecorder) GetMaxValue(ctx, table, orderingColumn any) *gomock.Call

GetMaxValue indicates an expected call of GetMaxValue.

func (*MockRepositoryMockRecorder) GetPrimaryKeys

func (mr *MockRepositoryMockRecorder) GetPrimaryKeys(ctx, table any) *gomock.Call

GetPrimaryKeys indicates an expected call of GetPrimaryKeys.

func (*MockRepositoryMockRecorder) GetRows

func (mr *MockRepositoryMockRecorder) GetRows(ctx, table, orderingColumn, fields, pos, maxValue, limit any) *gomock.Call

GetRows indicates an expected call of GetRows.

func (*MockRepositoryMockRecorder) GetTrackingData

func (mr *MockRepositoryMockRecorder) GetTrackingData(ctx, stream, trackingTable, fields, offset, limit any) *gomock.Call

GetTrackingData indicates an expected call of GetTrackingData.