mocks

package
v0.22.0 Latest Latest
Warning

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

 Go to latest Published: Aug 22, 2024 License: MIT Imports: 3 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Batcher 

type Batcher struct {
	mock.Mock
}

Batcher is an autogenerated mock type for the Batcher type

func NewBatcher 

func NewBatcher(t interface {
	mock.TestingT
	Cleanup(func())
}) *Batcher

NewBatcher creates a new instance of Batcher. 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 (*Batcher) EXPECT 

func (_m *Batcher) EXPECT() *Batcher_Expecter

func (*Batcher) Get 

func (_m *Batcher) Get(ctx context.Context) []kafka.Message

Get provides a mock function with given fields: ctx

type Batcher_Expecter 

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

func (*Batcher_Expecter) Get 

func (_e *Batcher_Expecter) Get(ctx interface{}) *Batcher_Get_Call

Get is a helper method to define mock.On call

  • ctx context.Context

type Batcher_Get_Call 

type Batcher_Get_Call struct {
	*mock.Call
}

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

func (*Batcher_Get_Call) Return 

func (_c *Batcher_Get_Call) Return(_a0 []kafka.Message) *Batcher_Get_Call

func (*Batcher_Get_Call) Run 

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

func (*Batcher_Get_Call) RunAndReturn 

func (_c *Batcher_Get_Call) RunAndReturn(run func(context.Context) []kafka.Message) *Batcher_Get_Call

type OffsetManager 

type OffsetManager struct {
	mock.Mock
}

OffsetManager is an autogenerated mock type for the OffsetManager type

func NewOffsetManager 

func NewOffsetManager(t interface {
	mock.TestingT
	Cleanup(func())
}) *OffsetManager

NewOffsetManager creates a new instance of OffsetManager. 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 (*OffsetManager) Batch 

func (_m *OffsetManager) Batch(ctx context.Context) []kafka.Message

Batch provides a mock function with given fields: ctx

func (*OffsetManager) Commit 

func (_m *OffsetManager) Commit(ctx context.Context, msgs ...kafka.Message) error

Commit provides a mock function with given fields: ctx, msgs

func (*OffsetManager) EXPECT 

func (_m *OffsetManager) EXPECT() *OffsetManager_Expecter

func (*OffsetManager) Flush 

func (_m *OffsetManager) Flush() error

Flush provides a mock function with given fields:

func (*OffsetManager) Start 

func (_m *OffsetManager) Start(ctx context.Context) error

Start provides a mock function with given fields: ctx

type OffsetManager_Batch_Call 

type OffsetManager_Batch_Call struct {
	*mock.Call
}

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

func (*OffsetManager_Batch_Call) Return 

func (_c *OffsetManager_Batch_Call) Return(_a0 []kafka.Message) *OffsetManager_Batch_Call

func (*OffsetManager_Batch_Call) Run 

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

func (*OffsetManager_Batch_Call) RunAndReturn 

func (_c *OffsetManager_Batch_Call) RunAndReturn(run func(context.Context) []kafka.Message) *OffsetManager_Batch_Call

type OffsetManager_Commit_Call 

type OffsetManager_Commit_Call struct {
	*mock.Call
}

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

func (*OffsetManager_Commit_Call) Return 

func (_c *OffsetManager_Commit_Call) Return(_a0 error) *OffsetManager_Commit_Call

func (*OffsetManager_Commit_Call) Run 

func (_c *OffsetManager_Commit_Call) Run(run func(ctx context.Context, msgs ...kafka.Message)) *OffsetManager_Commit_Call

func (*OffsetManager_Commit_Call) RunAndReturn 

func (_c *OffsetManager_Commit_Call) RunAndReturn(run func(context.Context, ...kafka.Message) error) *OffsetManager_Commit_Call

type OffsetManager_Expecter 

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

func (*OffsetManager_Expecter) Batch 

func (_e *OffsetManager_Expecter) Batch(ctx interface{}) *OffsetManager_Batch_Call

Batch is a helper method to define mock.On call

  • ctx context.Context

func (*OffsetManager_Expecter) Commit 

func (_e *OffsetManager_Expecter) Commit(ctx interface{}, msgs ...interface{}) *OffsetManager_Commit_Call

Commit is a helper method to define mock.On call

  • ctx context.Context
  • msgs ...kafka.Message

func (*OffsetManager_Expecter) Flush 

func (_e *OffsetManager_Expecter) Flush() *OffsetManager_Flush_Call

Flush is a helper method to define mock.On call

func (*OffsetManager_Expecter) Start 

func (_e *OffsetManager_Expecter) Start(ctx interface{}) *OffsetManager_Start_Call

Start is a helper method to define mock.On call

  • ctx context.Context

type OffsetManager_Flush_Call 

type OffsetManager_Flush_Call struct {
	*mock.Call
}

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

func (*OffsetManager_Flush_Call) Return 

func (_c *OffsetManager_Flush_Call) Return(_a0 error) *OffsetManager_Flush_Call

func (*OffsetManager_Flush_Call) Run 

func (_c *OffsetManager_Flush_Call) Run(run func()) *OffsetManager_Flush_Call

func (*OffsetManager_Flush_Call) RunAndReturn 

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

type OffsetManager_Start_Call 

type OffsetManager_Start_Call struct {
	*mock.Call
}

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

func (*OffsetManager_Start_Call) Return 

func (_c *OffsetManager_Start_Call) Return(_a0 error) *OffsetManager_Start_Call

func (*OffsetManager_Start_Call) Run 

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

func (*OffsetManager_Start_Call) RunAndReturn 

func (_c *OffsetManager_Start_Call) RunAndReturn(run func(context.Context) error) *OffsetManager_Start_Call

type Reader 

type Reader struct {
	mock.Mock
}

Reader is an autogenerated mock type for the Reader type

func NewReader 

func NewReader(t interface {
	mock.TestingT
	Cleanup(func())
}) *Reader

NewReader creates a new instance of Reader. 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 (*Reader) Close 

func (_m *Reader) Close() error

Close provides a mock function with given fields:

func (*Reader) CommitMessages 

func (_m *Reader) CommitMessages(_a0 context.Context, _a1 ...kafka.Message) error

CommitMessages provides a mock function with given fields: _a0, _a1

func (*Reader) EXPECT 

func (_m *Reader) EXPECT() *Reader_Expecter

func (*Reader) FetchMessage 

func (_m *Reader) FetchMessage(_a0 context.Context) (kafka.Message, error)

FetchMessage provides a mock function with given fields: _a0

func (*Reader) ReadMessage 

func (_m *Reader) ReadMessage(_a0 context.Context) (kafka.Message, error)

ReadMessage provides a mock function with given fields: _a0

func (*Reader) Stats 

func (_m *Reader) Stats() kafka.ReaderStats

Stats provides a mock function with given fields:

type Reader_Close_Call 

type Reader_Close_Call struct {
	*mock.Call
}

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

func (*Reader_Close_Call) Return 

func (_c *Reader_Close_Call) Return(_a0 error) *Reader_Close_Call

func (*Reader_Close_Call) Run 

func (_c *Reader_Close_Call) Run(run func()) *Reader_Close_Call

func (*Reader_Close_Call) RunAndReturn 

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

type Reader_CommitMessages_Call 

type Reader_CommitMessages_Call struct {
	*mock.Call
}

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

func (*Reader_CommitMessages_Call) Return 

func (_c *Reader_CommitMessages_Call) Return(_a0 error) *Reader_CommitMessages_Call

func (*Reader_CommitMessages_Call) Run 

func (_c *Reader_CommitMessages_Call) Run(run func(_a0 context.Context, _a1 ...kafka.Message)) *Reader_CommitMessages_Call

func (*Reader_CommitMessages_Call) RunAndReturn 

func (_c *Reader_CommitMessages_Call) RunAndReturn(run func(context.Context, ...kafka.Message) error) *Reader_CommitMessages_Call

type Reader_Expecter 

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

func (*Reader_Expecter) Close 

func (_e *Reader_Expecter) Close() *Reader_Close_Call

Close is a helper method to define mock.On call

func (*Reader_Expecter) CommitMessages 

func (_e *Reader_Expecter) CommitMessages(_a0 interface{}, _a1 ...interface{}) *Reader_CommitMessages_Call

CommitMessages is a helper method to define mock.On call

  • _a0 context.Context
  • _a1 ...kafka.Message

func (*Reader_Expecter) FetchMessage 

func (_e *Reader_Expecter) FetchMessage(_a0 interface{}) *Reader_FetchMessage_Call

FetchMessage is a helper method to define mock.On call

  • _a0 context.Context

func (*Reader_Expecter) ReadMessage 

func (_e *Reader_Expecter) ReadMessage(_a0 interface{}) *Reader_ReadMessage_Call

ReadMessage is a helper method to define mock.On call

  • _a0 context.Context

func (*Reader_Expecter) Stats 

func (_e *Reader_Expecter) Stats() *Reader_Stats_Call

Stats is a helper method to define mock.On call

type Reader_FetchMessage_Call 

type Reader_FetchMessage_Call struct {
	*mock.Call
}

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

func (*Reader_FetchMessage_Call) Return 

func (_c *Reader_FetchMessage_Call) Return(_a0 kafka.Message, _a1 error) *Reader_FetchMessage_Call

func (*Reader_FetchMessage_Call) Run 

func (_c *Reader_FetchMessage_Call) Run(run func(_a0 context.Context)) *Reader_FetchMessage_Call

func (*Reader_FetchMessage_Call) RunAndReturn 

func (_c *Reader_FetchMessage_Call) RunAndReturn(run func(context.Context) (kafka.Message, error)) *Reader_FetchMessage_Call

type Reader_ReadMessage_Call 

type Reader_ReadMessage_Call struct {
	*mock.Call
}

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

func (*Reader_ReadMessage_Call) Return 

func (_c *Reader_ReadMessage_Call) Return(_a0 kafka.Message, _a1 error) *Reader_ReadMessage_Call

func (*Reader_ReadMessage_Call) Run 

func (_c *Reader_ReadMessage_Call) Run(run func(_a0 context.Context)) *Reader_ReadMessage_Call

func (*Reader_ReadMessage_Call) RunAndReturn 

func (_c *Reader_ReadMessage_Call) RunAndReturn(run func(context.Context) (kafka.Message, error)) *Reader_ReadMessage_Call

type Reader_Stats_Call 

type Reader_Stats_Call struct {
	*mock.Call
}

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

func (*Reader_Stats_Call) Return 

func (_c *Reader_Stats_Call) Return(_a0 kafka.ReaderStats) *Reader_Stats_Call

func (*Reader_Stats_Call) Run 

func (_c *Reader_Stats_Call) Run(run func()) *Reader_Stats_Call

func (*Reader_Stats_Call) RunAndReturn 

func (_c *Reader_Stats_Call) RunAndReturn(run func() kafka.ReaderStats) *Reader_Stats_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.