rabbitfakes

Documentation

Overview

Code generated by counterfeiter. DO NOT EDIT.

Index

• type FakeIRabbit
  • func (fake *FakeIRabbit) Close() error
  • func (fake *FakeIRabbit) CloseCallCount() int
  • func (fake *FakeIRabbit) CloseCalls(stub func() error)
  • func (fake *FakeIRabbit) CloseReturns(result1 error)
  • func (fake *FakeIRabbit) CloseReturnsOnCall(i int, result1 error)
  • func (fake *FakeIRabbit) Consume(arg1 context.Context, arg2 chan *rabbit.ConsumeError, ...)
  • func (fake *FakeIRabbit) ConsumeArgsForCall(i int) (context.Context, chan *rabbit.ConsumeError, func(msg amqp.Delivery) error)
  • func (fake *FakeIRabbit) ConsumeCallCount() int
  • func (fake *FakeIRabbit) ConsumeCalls(...)
  • func (fake *FakeIRabbit) ConsumeOnce(arg1 context.Context, arg2 func(msg amqp.Delivery) error) error
  • func (fake *FakeIRabbit) ConsumeOnceArgsForCall(i int) (context.Context, func(msg amqp.Delivery) error)
  • func (fake *FakeIRabbit) ConsumeOnceCallCount() int
  • func (fake *FakeIRabbit) ConsumeOnceCalls(stub func(context.Context, func(msg amqp.Delivery) error) error)
  • func (fake *FakeIRabbit) ConsumeOnceReturns(result1 error)
  • func (fake *FakeIRabbit) ConsumeOnceReturnsOnCall(i int, result1 error)
  • func (fake *FakeIRabbit) Invocations() map[string][][]interface{}
  • func (fake *FakeIRabbit) Publish(arg1 context.Context, arg2 string, arg3 []byte) error
  • func (fake *FakeIRabbit) PublishArgsForCall(i int) (context.Context, string, []byte)
  • func (fake *FakeIRabbit) PublishCallCount() int
  • func (fake *FakeIRabbit) PublishCalls(stub func(context.Context, string, []byte) error)
  • func (fake *FakeIRabbit) PublishReturns(result1 error)
  • func (fake *FakeIRabbit) PublishReturnsOnCall(i int, result1 error)
  • func (fake *FakeIRabbit) Stop() error
  • func (fake *FakeIRabbit) StopCallCount() int
  • func (fake *FakeIRabbit) StopCalls(stub func() error)
  • func (fake *FakeIRabbit) StopReturns(result1 error)
  • func (fake *FakeIRabbit) StopReturnsOnCall(i int, result1 error)

Types

type FakeIRabbit

type FakeIRabbit struct {
	CloseStub func() error

	ConsumeStub func(context.Context, chan *rabbit.ConsumeError, func(msg amqp.Delivery) error)

	ConsumeOnceStub func(context.Context, func(msg amqp.Delivery) error) error

	PublishStub func(context.Context, string, []byte) error

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

func (*FakeIRabbit) Close

func (fake *FakeIRabbit) Close() error

func (*FakeIRabbit) CloseCallCount

func (fake *FakeIRabbit) CloseCallCount() int

func (*FakeIRabbit) CloseCalls

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

func (*FakeIRabbit) CloseReturns

func (fake *FakeIRabbit) CloseReturns(result1 error)

func (*FakeIRabbit) CloseReturnsOnCall

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

func (*FakeIRabbit) Consume

func (fake *FakeIRabbit) Consume(arg1 context.Context, arg2 chan *rabbit.ConsumeError, arg3 func(msg amqp.Delivery) error)

func (*FakeIRabbit) ConsumeArgsForCall

func (fake *FakeIRabbit) ConsumeArgsForCall(i int) (context.Context, chan *rabbit.ConsumeError, func(msg amqp.Delivery) error)

func (*FakeIRabbit) ConsumeCallCount

func (fake *FakeIRabbit) ConsumeCallCount() int

func (*FakeIRabbit) ConsumeCalls

func (fake *FakeIRabbit) ConsumeCalls(stub func(context.Context, chan *rabbit.ConsumeError, func(msg amqp.Delivery) error))

func (*FakeIRabbit) ConsumeOnce

func (fake *FakeIRabbit) ConsumeOnce(arg1 context.Context, arg2 func(msg amqp.Delivery) error) error

func (*FakeIRabbit) ConsumeOnceArgsForCall

func (fake *FakeIRabbit) ConsumeOnceArgsForCall(i int) (context.Context, func(msg amqp.Delivery) error)

func (*FakeIRabbit) ConsumeOnceCallCount

func (fake *FakeIRabbit) ConsumeOnceCallCount() int

func (*FakeIRabbit) ConsumeOnceCalls

func (fake *FakeIRabbit) ConsumeOnceCalls(stub func(context.Context, func(msg amqp.Delivery) error) error)

func (*FakeIRabbit) ConsumeOnceReturns

func (fake *FakeIRabbit) ConsumeOnceReturns(result1 error)

func (*FakeIRabbit) ConsumeOnceReturnsOnCall

func (fake *FakeIRabbit) ConsumeOnceReturnsOnCall(i int, result1 error)

func (*FakeIRabbit) Invocations

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

func (*FakeIRabbit) Publish

func (fake *FakeIRabbit) Publish(arg1 context.Context, arg2 string, arg3 []byte) error

func (*FakeIRabbit) PublishArgsForCall

func (fake *FakeIRabbit) PublishArgsForCall(i int) (context.Context, string, []byte)

func (*FakeIRabbit) PublishCallCount

func (fake *FakeIRabbit) PublishCallCount() int

func (*FakeIRabbit) PublishCalls

func (fake *FakeIRabbit) PublishCalls(stub func(context.Context, string, []byte) error)

func (*FakeIRabbit) PublishReturns

func (fake *FakeIRabbit) PublishReturns(result1 error)

func (*FakeIRabbit) PublishReturnsOnCall

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

func (*FakeIRabbit) Stop

func (fake *FakeIRabbit) Stop() error

func (*FakeIRabbit) StopCallCount

func (fake *FakeIRabbit) StopCallCount() int

func (*FakeIRabbit) StopCalls

func (fake *FakeIRabbit) StopCalls(stub func() error)

func (*FakeIRabbit) StopReturns

func (fake *FakeIRabbit) StopReturns(result1 error)

func (*FakeIRabbit) StopReturnsOnCall

func (fake *FakeIRabbit) StopReturnsOnCall(i int, result1 error)