mocks

Documentation

Overview

Code generated by counterfeiter. DO NOT EDIT.

Index

• type PubSub
  • func (fake *PubSub) Close() error
  • func (fake *PubSub) CloseCallCount() int
  • func (fake *PubSub) CloseCalls(stub func() error)
  • func (fake *PubSub) CloseReturns(result1 error)
  • func (fake *PubSub) CloseReturnsOnCall(i int, result1 error)
  • func (fake *PubSub) Invocations() map[string][][]interface{}
  • func (fake *PubSub) PublishWithOpts(arg1 string, arg2 *message.Message, arg3 ...spi.Option) error
  • func (fake *PubSub) PublishWithOptsArgsForCall(i int) (string, *message.Message, []spi.Option)
  • func (fake *PubSub) PublishWithOptsCallCount() int
  • func (fake *PubSub) PublishWithOptsCalls(stub func(string, *message.Message, ...spi.Option) error)
  • func (fake *PubSub) PublishWithOptsReturns(result1 error)
  • func (fake *PubSub) PublishWithOptsReturnsOnCall(i int, result1 error)
  • func (fake *PubSub) SubscribeWithOpts(arg1 context.Context, arg2 string, arg3 ...spi.Option) (<-chan *message.Message, error)
  • func (fake *PubSub) SubscribeWithOptsArgsForCall(i int) (context.Context, string, []spi.Option)
  • func (fake *PubSub) SubscribeWithOptsCallCount() int
  • func (fake *PubSub) SubscribeWithOptsCalls(...)
  • func (fake *PubSub) SubscribeWithOptsReturns(result1 <-chan *message.Message, result2 error)
  • func (fake *PubSub) SubscribeWithOptsReturnsOnCall(i int, result1 <-chan *message.Message, result2 error)

Types

type PubSub

type PubSub struct {
	CloseStub func() error

	PublishWithOptsStub func(string, *message.Message, ...spi.Option) error

	SubscribeWithOptsStub func(context.Context, string, ...spi.Option) (<-chan *message.Message, error)
	// contains filtered or unexported fields
}

func (*PubSub) Close

func (fake *PubSub) Close() error

func (*PubSub) CloseCallCount

func (fake *PubSub) CloseCallCount() int

func (*PubSub) CloseCalls

func (fake *PubSub) CloseCalls(stub func() error)

func (*PubSub) CloseReturns

func (fake *PubSub) CloseReturns(result1 error)

func (*PubSub) CloseReturnsOnCall

func (fake *PubSub) CloseReturnsOnCall(i int, result1 error)

func (*PubSub) Invocations

func (fake *PubSub) Invocations() map[string][][]interface{}

func (*PubSub) PublishWithOpts

func (fake *PubSub) PublishWithOpts(arg1 string, arg2 *message.Message, arg3 ...spi.Option) error

func (*PubSub) PublishWithOptsArgsForCall

func (fake *PubSub) PublishWithOptsArgsForCall(i int) (string, *message.Message, []spi.Option)

func (*PubSub) PublishWithOptsCallCount

func (fake *PubSub) PublishWithOptsCallCount() int

func (*PubSub) PublishWithOptsCalls

func (fake *PubSub) PublishWithOptsCalls(stub func(string, *message.Message, ...spi.Option) error)

func (*PubSub) PublishWithOptsReturns

func (fake *PubSub) PublishWithOptsReturns(result1 error)

func (*PubSub) PublishWithOptsReturnsOnCall

func (fake *PubSub) PublishWithOptsReturnsOnCall(i int, result1 error)

func (*PubSub) SubscribeWithOpts

func (fake *PubSub) SubscribeWithOpts(arg1 context.Context, arg2 string, arg3 ...spi.Option) (<-chan *message.Message, error)

func (*PubSub) SubscribeWithOptsArgsForCall

func (fake *PubSub) SubscribeWithOptsArgsForCall(i int) (context.Context, string, []spi.Option)

func (*PubSub) SubscribeWithOptsCallCount

func (fake *PubSub) SubscribeWithOptsCallCount() int

func (*PubSub) SubscribeWithOptsCalls

func (fake *PubSub) SubscribeWithOptsCalls(stub func(context.Context, string, ...spi.Option) (<-chan *message.Message, error))

func (*PubSub) SubscribeWithOptsReturns

func (fake *PubSub) SubscribeWithOptsReturns(result1 <-chan *message.Message, result2 error)

func (*PubSub) SubscribeWithOptsReturnsOnCall

func (fake *PubSub) SubscribeWithOptsReturnsOnCall(i int, result1 <-chan *message.Message, result2 error)