Documentation
¶
Index ¶
- type Stream
- type Stream_Consume_Call
- func (_c *Stream_Consume_Call) Return(_a0 <-chan raw.Event, _a1 error) *Stream_Consume_Call
- func (_c *Stream_Consume_Call) Run(run func(group string, evs ...events.Unmarshaller)) *Stream_Consume_Call
- func (_c *Stream_Consume_Call) RunAndReturn(run func(string, ...events.Unmarshaller) (<-chan raw.Event, error)) *Stream_Consume_Call
- type Stream_Expecter
- type Stream_JetStream_Call
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Stream ¶
Stream is an autogenerated mock type for the Stream type
func NewStream ¶
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) EXPECT ¶
func (_m *Stream) EXPECT() *Stream_Expecter
type Stream_Consume_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 ¶
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 (_c *Stream_JetStream_Call) Return(_a0 jetstream.Stream) *Stream_JetStream_Call
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
Click to show internal directories.
Click to hide internal directories.