mocks

package
v2.46.2 Latest Latest
Warning

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

Go to latest
Published: Jun 2, 2026 License: Apache-2.0 Imports: 4 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Stream

type Stream struct {
	mock.Mock
}

Stream is an autogenerated mock type for the Stream type

func NewStream

func NewStream(t interface {
	mock.TestingT
	Cleanup(func())
}) *Stream

NewStream creates a new instance of Stream. 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 (*Stream) Consume

func (_m *Stream) Consume(group string, evs ...events.Unmarshaller) (<-chan raw.Event, error)

Consume provides a mock function with given fields: group, evs

func (*Stream) EXPECT

func (_m *Stream) EXPECT() *Stream_Expecter

func (*Stream) JetStream

func (_m *Stream) JetStream() jetstream.Stream

JetStream provides a mock function with no fields

type Stream_Consume_Call

type Stream_Consume_Call struct {
	*mock.Call
}

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

func (*Stream_Consume_Call) Return

func (_c *Stream_Consume_Call) Return(_a0 <-chan raw.Event, _a1 error) *Stream_Consume_Call

func (*Stream_Consume_Call) Run

func (_c *Stream_Consume_Call) Run(run func(group string, evs ...events.Unmarshaller)) *Stream_Consume_Call

func (*Stream_Consume_Call) RunAndReturn

func (_c *Stream_Consume_Call) RunAndReturn(run func(string, ...events.Unmarshaller) (<-chan raw.Event, error)) *Stream_Consume_Call

type Stream_Expecter

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

func (*Stream_Expecter) Consume

func (_e *Stream_Expecter) Consume(group interface{}, evs ...interface{}) *Stream_Consume_Call

Consume is a helper method to define mock.On call

  • group string
  • evs ...events.Unmarshaller

func (*Stream_Expecter) JetStream

func (_e *Stream_Expecter) JetStream() *Stream_JetStream_Call

JetStream is a helper method to define mock.On call

type Stream_JetStream_Call

type Stream_JetStream_Call struct {
	*mock.Call
}

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

func (*Stream_JetStream_Call) Return

func (*Stream_JetStream_Call) Run

func (_c *Stream_JetStream_Call) Run(run func()) *Stream_JetStream_Call

func (*Stream_JetStream_Call) RunAndReturn

func (_c *Stream_JetStream_Call) RunAndReturn(run func() jetstream.Stream) *Stream_JetStream_Call

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL