mocks

Documentation

Index

• type Publisher
  • func NewPublisher(t interface{ ... }) *Publisher
  • func (_mock *Publisher) Close() error
  • func (_m *Publisher) EXPECT() *Publisher_Expecter
  • func (_mock *Publisher) Publish(ctx context.Context, stream string, event events.Event) error
• type Publisher_Close_Call
  • func (_c *Publisher_Close_Call) Return(err error) *Publisher_Close_Call
  • func (_c *Publisher_Close_Call) Run(run func()) *Publisher_Close_Call
  • func (_c *Publisher_Close_Call) RunAndReturn(run func() error) *Publisher_Close_Call
• type Publisher_Expecter
  • func (_e *Publisher_Expecter) Close() *Publisher_Close_Call
  • func (_e *Publisher_Expecter) Publish(ctx interface{}, stream interface{}, event interface{}) *Publisher_Publish_Call
• type Publisher_Publish_Call
  • func (_c *Publisher_Publish_Call) Return(err error) *Publisher_Publish_Call
  • func (_c *Publisher_Publish_Call) Run(run func(ctx context.Context, stream string, event events.Event)) *Publisher_Publish_Call
  • func (_c *Publisher_Publish_Call) RunAndReturn(run func(ctx context.Context, stream string, event events.Event) error) *Publisher_Publish_Call
• type Subscriber
  • func NewSubscriber(t interface{ ... }) *Subscriber
  • func (_mock *Subscriber) Close() error
  • func (_m *Subscriber) EXPECT() *Subscriber_Expecter
  • func (_mock *Subscriber) Subscribe(ctx context.Context, cfg events.SubscriberConfig) error
• type Subscriber_Close_Call
  • func (_c *Subscriber_Close_Call) Return(err error) *Subscriber_Close_Call
  • func (_c *Subscriber_Close_Call) Run(run func()) *Subscriber_Close_Call
  • func (_c *Subscriber_Close_Call) RunAndReturn(run func() error) *Subscriber_Close_Call
• type Subscriber_Expecter
  • func (_e *Subscriber_Expecter) Close() *Subscriber_Close_Call
  • func (_e *Subscriber_Expecter) Subscribe(ctx interface{}, cfg interface{}) *Subscriber_Subscribe_Call
• type Subscriber_Subscribe_Call
  • func (_c *Subscriber_Subscribe_Call) Return(err error) *Subscriber_Subscribe_Call
  • func (_c *Subscriber_Subscribe_Call) Run(run func(ctx context.Context, cfg events.SubscriberConfig)) *Subscriber_Subscribe_Call
  • func (_c *Subscriber_Subscribe_Call) RunAndReturn(run func(ctx context.Context, cfg events.SubscriberConfig) error) *Subscriber_Subscribe_Call

Types

type Publisher

type Publisher struct {
	mock.Mock
}

Publisher is an autogenerated mock type for the Publisher type

func NewPublisher

func NewPublisher(t interface {
	mock.TestingT
	Cleanup(func())
}) *Publisher

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

func (_mock *Publisher) Close() error

Close provides a mock function for the type Publisher

func (*Publisher) EXPECT

func (_m *Publisher) EXPECT() *Publisher_Expecter

func (*Publisher) Publish

func (_mock *Publisher) Publish(ctx context.Context, stream string, event events.Event) error

Publish provides a mock function for the type Publisher

type Publisher_Close_Call

type Publisher_Close_Call struct {
	*mock.Call
}

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

func (*Publisher_Close_Call) Return

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

func (*Publisher_Close_Call) Run

func (_c *Publisher_Close_Call) Run(run func()) *Publisher_Close_Call

func (*Publisher_Close_Call) RunAndReturn

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

type Publisher_Expecter

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

func (*Publisher_Expecter) Close

func (_e *Publisher_Expecter) Close() *Publisher_Close_Call

Close is a helper method to define mock.On call

func (*Publisher_Expecter) Publish

func (_e *Publisher_Expecter) Publish(ctx interface{}, stream interface{}, event interface{}) *Publisher_Publish_Call

Publish is a helper method to define mock.On call

• ctx context.Context
• stream string
• event events.Event

type Publisher_Publish_Call

type Publisher_Publish_Call struct {
	*mock.Call
}

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

func (*Publisher_Publish_Call) Return

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

func (*Publisher_Publish_Call) Run

func (_c *Publisher_Publish_Call) Run(run func(ctx context.Context, stream string, event events.Event)) *Publisher_Publish_Call

func (*Publisher_Publish_Call) RunAndReturn

func (_c *Publisher_Publish_Call) RunAndReturn(run func(ctx context.Context, stream string, event events.Event) error) *Publisher_Publish_Call

type Subscriber

type Subscriber struct {
	mock.Mock
}

Subscriber is an autogenerated mock type for the Subscriber type

func NewSubscriber

func NewSubscriber(t interface {
	mock.TestingT
	Cleanup(func())
}) *Subscriber

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

func (_mock *Subscriber) Close() error

Close provides a mock function for the type Subscriber

func (*Subscriber) EXPECT

func (_m *Subscriber) EXPECT() *Subscriber_Expecter

func (*Subscriber) Subscribe

func (_mock *Subscriber) Subscribe(ctx context.Context, cfg events.SubscriberConfig) error

Subscribe provides a mock function for the type Subscriber

type Subscriber_Close_Call

type Subscriber_Close_Call struct {
	*mock.Call
}

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

func (*Subscriber_Close_Call) Return

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

func (*Subscriber_Close_Call) Run

func (_c *Subscriber_Close_Call) Run(run func()) *Subscriber_Close_Call

func (*Subscriber_Close_Call) RunAndReturn

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

type Subscriber_Expecter

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

func (*Subscriber_Expecter) Close

func (_e *Subscriber_Expecter) Close() *Subscriber_Close_Call

Close is a helper method to define mock.On call

func (*Subscriber_Expecter) Subscribe

func (_e *Subscriber_Expecter) Subscribe(ctx interface{}, cfg interface{}) *Subscriber_Subscribe_Call

Subscribe is a helper method to define mock.On call

• ctx context.Context
• cfg events.SubscriberConfig

type Subscriber_Subscribe_Call

type Subscriber_Subscribe_Call struct {
	*mock.Call
}

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

func (*Subscriber_Subscribe_Call) Return

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

func (*Subscriber_Subscribe_Call) Run

func (_c *Subscriber_Subscribe_Call) Run(run func(ctx context.Context, cfg events.SubscriberConfig)) *Subscriber_Subscribe_Call

func (*Subscriber_Subscribe_Call) RunAndReturn

func (_c *Subscriber_Subscribe_Call) RunAndReturn(run func(ctx context.Context, cfg events.SubscriberConfig) error) *Subscriber_Subscribe_Call