rabbitfakes

package

v1.3.1 Latest Latest Go to latest Published: Feb 14, 2022 License: MIT Imports: 4 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/batchcorp/plumber

Links

Open Source Insights

Documentation ¶

Overview ¶

Code generated by counterfeiter. DO NOT EDIT.

Index ¶

type FakeIRabbit

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

This section is empty.

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)

Source Files ¶

View all Source files

fake_rabbit.go

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL