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) IsConnected() bool
  • func (fake *PubSub) IsConnectedCallCount() int
  • func (fake *PubSub) IsConnectedCalls(stub func() bool)
  • func (fake *PubSub) IsConnectedReturns(result1 bool)
  • func (fake *PubSub) IsConnectedReturnsOnCall(i int, result1 bool)
  • func (fake *PubSub) Publish(arg1 string, arg2 ...*message.Message) error
  • func (fake *PubSub) PublishArgsForCall(i int) (string, []*message.Message)
  • func (fake *PubSub) PublishCallCount() int
  • func (fake *PubSub) PublishCalls(stub func(string, ...*message.Message) error)
  • func (fake *PubSub) PublishReturns(result1 error)
  • func (fake *PubSub) PublishReturnsOnCall(i int, result1 error)
  • 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) Subscribe(arg1 context.Context, arg2 string) (<-chan *message.Message, error)
  • func (fake *PubSub) SubscribeArgsForCall(i int) (context.Context, string)
  • func (fake *PubSub) SubscribeCallCount() int
  • func (fake *PubSub) SubscribeCalls(stub func(context.Context, string) (<-chan *message.Message, error))
  • func (fake *PubSub) SubscribeReturns(result1 <-chan *message.Message, result2 error)
  • func (fake *PubSub) SubscribeReturnsOnCall(i int, result1 <-chan *message.Message, result2 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

	IsConnectedStub func() bool

	PublishStub func(string, ...*message.Message) error

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

	SubscribeStub func(context.Context, string) (<-chan *message.Message, 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) IsConnected

func (fake *PubSub) IsConnected() bool

func (*PubSub) IsConnectedCallCount

func (fake *PubSub) IsConnectedCallCount() int

func (*PubSub) IsConnectedCalls

func (fake *PubSub) IsConnectedCalls(stub func() bool)

func (*PubSub) IsConnectedReturns

func (fake *PubSub) IsConnectedReturns(result1 bool)

func (*PubSub) IsConnectedReturnsOnCall

func (fake *PubSub) IsConnectedReturnsOnCall(i int, result1 bool)

func (*PubSub) Publish

func (fake *PubSub) Publish(arg1 string, arg2 ...*message.Message) error

func (*PubSub) PublishArgsForCall

func (fake *PubSub) PublishArgsForCall(i int) (string, []*message.Message)

func (*PubSub) PublishCallCount

func (fake *PubSub) PublishCallCount() int

func (*PubSub) PublishCalls

func (fake *PubSub) PublishCalls(stub func(string, ...*message.Message) error)

func (*PubSub) PublishReturns

func (fake *PubSub) PublishReturns(result1 error)

func (*PubSub) PublishReturnsOnCall

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

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) Subscribe

func (fake *PubSub) Subscribe(arg1 context.Context, arg2 string) (<-chan *message.Message, error)

func (*PubSub) SubscribeArgsForCall

func (fake *PubSub) SubscribeArgsForCall(i int) (context.Context, string)

func (*PubSub) SubscribeCallCount

func (fake *PubSub) SubscribeCallCount() int

func (*PubSub) SubscribeCalls

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

func (*PubSub) SubscribeReturns

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

func (*PubSub) SubscribeReturnsOnCall

func (fake *PubSub) SubscribeReturnsOnCall(i int, result1 <-chan *message.Message, result2 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)