mocks

package
v0.7.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Dec 29, 2025 License: Apache-2.0 Imports: 6 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type MockJobClient 

type MockJobClient struct {
	mock.Mock
}

MockJobClient is an autogenerated mock type for the JobClient type

func NewMockJobClient 

func NewMockJobClient(t interface {
	mock.TestingT
	Cleanup(func())
}) *MockJobClient

NewMockJobClient creates a new instance of MockJobClient. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.

func (*MockJobClient) Close 

func (_mock *MockJobClient) Close() error

Close provides a mock function for the type MockJobClient

func (*MockJobClient) EXPECT 

func (_m *MockJobClient) EXPECT() *MockJobClient_Expecter

func (*MockJobClient) GetPool 

func (_mock *MockJobClient) GetPool() *pgxpool.Pool

GetPool provides a mock function for the type MockJobClient

func (*MockJobClient) GetRiverClient 

func (_mock *MockJobClient) GetRiverClient() *river.Client[pgx.Tx]

GetRiverClient provides a mock function for the type MockJobClient

func (*MockJobClient) Insert 

func (_mock *MockJobClient) Insert(ctx context.Context, args river.JobArgs, opts *river.InsertOpts) (*rivertype.JobInsertResult, error)

Insert provides a mock function for the type MockJobClient

func (*MockJobClient) InsertMany 

func (_mock *MockJobClient) InsertMany(ctx context.Context, params []river.InsertManyParams) ([]*rivertype.JobInsertResult, error)

InsertMany provides a mock function for the type MockJobClient

func (*MockJobClient) InsertManyFast 

func (_mock *MockJobClient) InsertManyFast(ctx context.Context, params []river.InsertManyParams) (int, error)

InsertManyFast provides a mock function for the type MockJobClient

func (*MockJobClient) InsertManyFastTx 

func (_mock *MockJobClient) InsertManyFastTx(ctx context.Context, tx pgx.Tx, params []river.InsertManyParams) (int, error)

InsertManyFastTx provides a mock function for the type MockJobClient

func (*MockJobClient) InsertManyTx 

func (_mock *MockJobClient) InsertManyTx(ctx context.Context, tx pgx.Tx, params []river.InsertManyParams) ([]*rivertype.JobInsertResult, error)

InsertManyTx provides a mock function for the type MockJobClient

func (*MockJobClient) InsertTx 

func (_mock *MockJobClient) InsertTx(ctx context.Context, tx pgx.Tx, args river.JobArgs, opts *river.InsertOpts) (*rivertype.JobInsertResult, error)

InsertTx provides a mock function for the type MockJobClient

func (*MockJobClient) JobCancel 

func (_mock *MockJobClient) JobCancel(ctx context.Context, jobID int64) (*rivertype.JobRow, error)

JobCancel provides a mock function for the type MockJobClient

func (*MockJobClient) JobCancelTx 

func (_mock *MockJobClient) JobCancelTx(ctx context.Context, tx pgx.Tx, jobID int64) (*rivertype.JobRow, error)

JobCancelTx provides a mock function for the type MockJobClient

func (*MockJobClient) TruncateRiverTables 

func (_mock *MockJobClient) TruncateRiverTables(ctx context.Context) error

TruncateRiverTables provides a mock function for the type MockJobClient

type MockJobClient_Close_Call 

type MockJobClient_Close_Call struct {
	*mock.Call
}

MockJobClient_Close_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Close'

func (*MockJobClient_Close_Call) Return 

func (_c *MockJobClient_Close_Call) Return(err error) *MockJobClient_Close_Call

func (*MockJobClient_Close_Call) Run 

func (_c *MockJobClient_Close_Call) Run(run func()) *MockJobClient_Close_Call

func (*MockJobClient_Close_Call) RunAndReturn 

func (_c *MockJobClient_Close_Call) RunAndReturn(run func() error) *MockJobClient_Close_Call

type MockJobClient_Expecter 

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

func (*MockJobClient_Expecter) Close 

func (_e *MockJobClient_Expecter) Close() *MockJobClient_Close_Call

Close is a helper method to define mock.On call

func (*MockJobClient_Expecter) GetPool 

func (_e *MockJobClient_Expecter) GetPool() *MockJobClient_GetPool_Call

GetPool is a helper method to define mock.On call

func (*MockJobClient_Expecter) GetRiverClient 

func (_e *MockJobClient_Expecter) GetRiverClient() *MockJobClient_GetRiverClient_Call

GetRiverClient is a helper method to define mock.On call

func (*MockJobClient_Expecter) Insert 

func (_e *MockJobClient_Expecter) Insert(ctx interface{}, args interface{}, opts interface{}) *MockJobClient_Insert_Call

Insert is a helper method to define mock.On call

  • ctx context.Context
  • args river.JobArgs
  • opts *river.InsertOpts

func (*MockJobClient_Expecter) InsertMany 

func (_e *MockJobClient_Expecter) InsertMany(ctx interface{}, params interface{}) *MockJobClient_InsertMany_Call

InsertMany is a helper method to define mock.On call

  • ctx context.Context
  • params []river.InsertManyParams

func (*MockJobClient_Expecter) InsertManyFast 

func (_e *MockJobClient_Expecter) InsertManyFast(ctx interface{}, params interface{}) *MockJobClient_InsertManyFast_Call

InsertManyFast is a helper method to define mock.On call

  • ctx context.Context
  • params []river.InsertManyParams

func (*MockJobClient_Expecter) InsertManyFastTx 

func (_e *MockJobClient_Expecter) InsertManyFastTx(ctx interface{}, tx interface{}, params interface{}) *MockJobClient_InsertManyFastTx_Call

InsertManyFastTx is a helper method to define mock.On call

  • ctx context.Context
  • tx pgx.Tx
  • params []river.InsertManyParams

func (*MockJobClient_Expecter) InsertManyTx 

func (_e *MockJobClient_Expecter) InsertManyTx(ctx interface{}, tx interface{}, params interface{}) *MockJobClient_InsertManyTx_Call

InsertManyTx is a helper method to define mock.On call

  • ctx context.Context
  • tx pgx.Tx
  • params []river.InsertManyParams

func (*MockJobClient_Expecter) InsertTx 

func (_e *MockJobClient_Expecter) InsertTx(ctx interface{}, tx interface{}, args interface{}, opts interface{}) *MockJobClient_InsertTx_Call

InsertTx is a helper method to define mock.On call

  • ctx context.Context
  • tx pgx.Tx
  • args river.JobArgs
  • opts *river.InsertOpts

func (*MockJobClient_Expecter) JobCancel 

func (_e *MockJobClient_Expecter) JobCancel(ctx interface{}, jobID interface{}) *MockJobClient_JobCancel_Call

JobCancel is a helper method to define mock.On call

  • ctx context.Context
  • jobID int64

func (*MockJobClient_Expecter) JobCancelTx 

func (_e *MockJobClient_Expecter) JobCancelTx(ctx interface{}, tx interface{}, jobID interface{}) *MockJobClient_JobCancelTx_Call

JobCancelTx is a helper method to define mock.On call

  • ctx context.Context
  • tx pgx.Tx
  • jobID int64

func (*MockJobClient_Expecter) TruncateRiverTables 

func (_e *MockJobClient_Expecter) TruncateRiverTables(ctx interface{}) *MockJobClient_TruncateRiverTables_Call

TruncateRiverTables is a helper method to define mock.On call

  • ctx context.Context

type MockJobClient_GetPool_Call 

type MockJobClient_GetPool_Call struct {
	*mock.Call
}

MockJobClient_GetPool_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetPool'

func (*MockJobClient_GetPool_Call) Return 

func (_c *MockJobClient_GetPool_Call) Return(pool *pgxpool.Pool) *MockJobClient_GetPool_Call

func (*MockJobClient_GetPool_Call) Run 

func (_c *MockJobClient_GetPool_Call) Run(run func()) *MockJobClient_GetPool_Call

func (*MockJobClient_GetPool_Call) RunAndReturn 

func (_c *MockJobClient_GetPool_Call) RunAndReturn(run func() *pgxpool.Pool) *MockJobClient_GetPool_Call

type MockJobClient_GetRiverClient_Call 

type MockJobClient_GetRiverClient_Call struct {
	*mock.Call
}

MockJobClient_GetRiverClient_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetRiverClient'

func (*MockJobClient_GetRiverClient_Call) Return 

func (_c *MockJobClient_GetRiverClient_Call) Return(client *river.Client[pgx.Tx]) *MockJobClient_GetRiverClient_Call

func (*MockJobClient_GetRiverClient_Call) Run 

func (_c *MockJobClient_GetRiverClient_Call) Run(run func()) *MockJobClient_GetRiverClient_Call

func (*MockJobClient_GetRiverClient_Call) RunAndReturn 

func (_c *MockJobClient_GetRiverClient_Call) RunAndReturn(run func() *river.Client[pgx.Tx]) *MockJobClient_GetRiverClient_Call

type MockJobClient_InsertManyFastTx_Call 

type MockJobClient_InsertManyFastTx_Call struct {
	*mock.Call
}

MockJobClient_InsertManyFastTx_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'InsertManyFastTx'

func (*MockJobClient_InsertManyFastTx_Call) Return 

func (_c *MockJobClient_InsertManyFastTx_Call) Return(n int, err error) *MockJobClient_InsertManyFastTx_Call

func (*MockJobClient_InsertManyFastTx_Call) Run 

func (_c *MockJobClient_InsertManyFastTx_Call) Run(run func(ctx context.Context, tx pgx.Tx, params []river.InsertManyParams)) *MockJobClient_InsertManyFastTx_Call

func (*MockJobClient_InsertManyFastTx_Call) RunAndReturn 

func (_c *MockJobClient_InsertManyFastTx_Call) RunAndReturn(run func(ctx context.Context, tx pgx.Tx, params []river.InsertManyParams) (int, error)) *MockJobClient_InsertManyFastTx_Call

type MockJobClient_InsertManyFast_Call 

type MockJobClient_InsertManyFast_Call struct {
	*mock.Call
}

MockJobClient_InsertManyFast_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'InsertManyFast'

func (*MockJobClient_InsertManyFast_Call) Return 

func (_c *MockJobClient_InsertManyFast_Call) Return(n int, err error) *MockJobClient_InsertManyFast_Call

func (*MockJobClient_InsertManyFast_Call) Run 

func (_c *MockJobClient_InsertManyFast_Call) Run(run func(ctx context.Context, params []river.InsertManyParams)) *MockJobClient_InsertManyFast_Call

func (*MockJobClient_InsertManyFast_Call) RunAndReturn 

func (_c *MockJobClient_InsertManyFast_Call) RunAndReturn(run func(ctx context.Context, params []river.InsertManyParams) (int, error)) *MockJobClient_InsertManyFast_Call

type MockJobClient_InsertManyTx_Call 

type MockJobClient_InsertManyTx_Call struct {
	*mock.Call
}

MockJobClient_InsertManyTx_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'InsertManyTx'

func (*MockJobClient_InsertManyTx_Call) Return 

func (_c *MockJobClient_InsertManyTx_Call) Return(jobInsertResults []*rivertype.JobInsertResult, err error) *MockJobClient_InsertManyTx_Call

func (*MockJobClient_InsertManyTx_Call) Run 

func (_c *MockJobClient_InsertManyTx_Call) Run(run func(ctx context.Context, tx pgx.Tx, params []river.InsertManyParams)) *MockJobClient_InsertManyTx_Call

func (*MockJobClient_InsertManyTx_Call) RunAndReturn 

func (_c *MockJobClient_InsertManyTx_Call) RunAndReturn(run func(ctx context.Context, tx pgx.Tx, params []river.InsertManyParams) ([]*rivertype.JobInsertResult, error)) *MockJobClient_InsertManyTx_Call

type MockJobClient_InsertMany_Call 

type MockJobClient_InsertMany_Call struct {
	*mock.Call
}

MockJobClient_InsertMany_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'InsertMany'

func (*MockJobClient_InsertMany_Call) Return 

func (_c *MockJobClient_InsertMany_Call) Return(jobInsertResults []*rivertype.JobInsertResult, err error) *MockJobClient_InsertMany_Call

func (*MockJobClient_InsertMany_Call) Run 

func (_c *MockJobClient_InsertMany_Call) Run(run func(ctx context.Context, params []river.InsertManyParams)) *MockJobClient_InsertMany_Call

func (*MockJobClient_InsertMany_Call) RunAndReturn 

func (_c *MockJobClient_InsertMany_Call) RunAndReturn(run func(ctx context.Context, params []river.InsertManyParams) ([]*rivertype.JobInsertResult, error)) *MockJobClient_InsertMany_Call

type MockJobClient_InsertTx_Call 

type MockJobClient_InsertTx_Call struct {
	*mock.Call
}

MockJobClient_InsertTx_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'InsertTx'

func (*MockJobClient_InsertTx_Call) Return 

func (_c *MockJobClient_InsertTx_Call) Return(jobInsertResult *rivertype.JobInsertResult, err error) *MockJobClient_InsertTx_Call

func (*MockJobClient_InsertTx_Call) Run 

func (_c *MockJobClient_InsertTx_Call) Run(run func(ctx context.Context, tx pgx.Tx, args river.JobArgs, opts *river.InsertOpts)) *MockJobClient_InsertTx_Call

func (*MockJobClient_InsertTx_Call) RunAndReturn 

func (_c *MockJobClient_InsertTx_Call) RunAndReturn(run func(ctx context.Context, tx pgx.Tx, args river.JobArgs, opts *river.InsertOpts) (*rivertype.JobInsertResult, error)) *MockJobClient_InsertTx_Call

type MockJobClient_Insert_Call 

type MockJobClient_Insert_Call struct {
	*mock.Call
}

MockJobClient_Insert_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Insert'

func (*MockJobClient_Insert_Call) Return 

func (_c *MockJobClient_Insert_Call) Return(jobInsertResult *rivertype.JobInsertResult, err error) *MockJobClient_Insert_Call

func (*MockJobClient_Insert_Call) Run 

func (_c *MockJobClient_Insert_Call) Run(run func(ctx context.Context, args river.JobArgs, opts *river.InsertOpts)) *MockJobClient_Insert_Call

func (*MockJobClient_Insert_Call) RunAndReturn 

func (_c *MockJobClient_Insert_Call) RunAndReturn(run func(ctx context.Context, args river.JobArgs, opts *river.InsertOpts) (*rivertype.JobInsertResult, error)) *MockJobClient_Insert_Call

type MockJobClient_JobCancelTx_Call 

type MockJobClient_JobCancelTx_Call struct {
	*mock.Call
}

MockJobClient_JobCancelTx_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'JobCancelTx'

func (*MockJobClient_JobCancelTx_Call) Return 

func (_c *MockJobClient_JobCancelTx_Call) Return(jobRow *rivertype.JobRow, err error) *MockJobClient_JobCancelTx_Call

func (*MockJobClient_JobCancelTx_Call) Run 

func (_c *MockJobClient_JobCancelTx_Call) Run(run func(ctx context.Context, tx pgx.Tx, jobID int64)) *MockJobClient_JobCancelTx_Call

func (*MockJobClient_JobCancelTx_Call) RunAndReturn 

func (_c *MockJobClient_JobCancelTx_Call) RunAndReturn(run func(ctx context.Context, tx pgx.Tx, jobID int64) (*rivertype.JobRow, error)) *MockJobClient_JobCancelTx_Call

type MockJobClient_JobCancel_Call 

type MockJobClient_JobCancel_Call struct {
	*mock.Call
}

MockJobClient_JobCancel_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'JobCancel'

func (*MockJobClient_JobCancel_Call) Return 

func (_c *MockJobClient_JobCancel_Call) Return(jobRow *rivertype.JobRow, err error) *MockJobClient_JobCancel_Call

func (*MockJobClient_JobCancel_Call) Run 

func (_c *MockJobClient_JobCancel_Call) Run(run func(ctx context.Context, jobID int64)) *MockJobClient_JobCancel_Call

func (*MockJobClient_JobCancel_Call) RunAndReturn 

func (_c *MockJobClient_JobCancel_Call) RunAndReturn(run func(ctx context.Context, jobID int64) (*rivertype.JobRow, error)) *MockJobClient_JobCancel_Call

type MockJobClient_TruncateRiverTables_Call 

type MockJobClient_TruncateRiverTables_Call struct {
	*mock.Call
}

MockJobClient_TruncateRiverTables_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'TruncateRiverTables'

func (*MockJobClient_TruncateRiverTables_Call) Return 

func (_c *MockJobClient_TruncateRiverTables_Call) Return(err error) *MockJobClient_TruncateRiverTables_Call

func (*MockJobClient_TruncateRiverTables_Call) Run 

func (_c *MockJobClient_TruncateRiverTables_Call) Run(run func(ctx context.Context)) *MockJobClient_TruncateRiverTables_Call

func (*MockJobClient_TruncateRiverTables_Call) RunAndReturn 

func (_c *MockJobClient_TruncateRiverTables_Call) RunAndReturn(run func(ctx context.Context) error) *MockJobClient_TruncateRiverTables_Call

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.