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) CloseReturns(result1 error)
  • func (fake *PubSub) CloseReturnsOnCall(i int, result1 error)
  • func (fake *PubSub) Invocations() map[string][][]interface{}
  • func (fake *PubSub) Publish(topic string, messages ...*message.Message) error
  • func (fake *PubSub) PublishArgsForCall(i int) (string, []*message.Message)
  • func (fake *PubSub) PublishCallCount() int
  • func (fake *PubSub) PublishReturns(result1 error)
  • func (fake *PubSub) PublishReturnsOnCall(i int, result1 error)
  • func (fake *PubSub) SubscribeWithOpts(ctx context.Context, topic string, opts ...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) 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 {
	SubscribeWithOptsStub func(ctx context.Context, topic string, opts ...spi.Option) (<-chan *message.Message, error)

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

	CloseStub func() error
	// contains filtered or unexported fields
}

func (*PubSub) Close

func (fake *PubSub) Close() error

func (*PubSub) CloseCallCount

func (fake *PubSub) CloseCallCount() int

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

func (fake *PubSub) Publish(topic string, messages ...*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) PublishReturns

func (fake *PubSub) PublishReturns(result1 error)

func (*PubSub) PublishReturnsOnCall

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

func (*PubSub) SubscribeWithOpts

func (fake *PubSub) SubscribeWithOpts(ctx context.Context, topic string, opts ...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) 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)