mocks

Documentation

Overview

Code generated by counterfeiter. DO NOT EDIT.

Code generated by counterfeiter. DO NOT EDIT.

Code generated by counterfeiter. DO NOT EDIT.

Index

• type FakeConsumer
  • func (fake *FakeConsumer) Consume(arg1 context.Context, arg2 pubsub.HandlerFunc) error
  • func (fake *FakeConsumer) ConsumeArgsForCall(i int) (context.Context, pubsub.HandlerFunc)
  • func (fake *FakeConsumer) ConsumeCallCount() int
  • func (fake *FakeConsumer) ConsumeReturns(result1 error)
  • func (fake *FakeConsumer) ConsumeReturnsOnCall(i int, result1 error)
  • func (fake *FakeConsumer) Invocations() map[string][][]interface{}
• type FakeMessage
  • func (fake *FakeMessage) Ack()
  • func (fake *FakeMessage) AckCallCount() int
  • func (fake *FakeMessage) Data() []byte
  • func (fake *FakeMessage) DataCallCount() int
  • func (fake *FakeMessage) DataReturns(result1 []byte)
  • func (fake *FakeMessage) DataReturnsOnCall(i int, result1 []byte)
  • func (fake *FakeMessage) Invocations() map[string][][]interface{}
  • func (fake *FakeMessage) Nack()
  • func (fake *FakeMessage) NackCallCount() int
• type FakeProducer
  • func (fake *FakeProducer) Invocations() map[string][][]interface{}
  • func (fake *FakeProducer) Produce(ctx context.Context, data []byte) error
  • func (fake *FakeProducer) ProduceArgsForCall(i int) (context.Context, []byte)
  • func (fake *FakeProducer) ProduceCallCount() int
  • func (fake *FakeProducer) ProduceReturns(result1 error)
  • func (fake *FakeProducer) ProduceReturnsOnCall(i int, result1 error)

Types

type FakeConsumer

type FakeConsumer struct {
	ConsumeStub func(context.Context, pubsub.HandlerFunc) error
	// contains filtered or unexported fields
}

func (*FakeConsumer) Consume

func (fake *FakeConsumer) Consume(arg1 context.Context, arg2 pubsub.HandlerFunc) error

func (*FakeConsumer) ConsumeArgsForCall

func (fake *FakeConsumer) ConsumeArgsForCall(i int) (context.Context, pubsub.HandlerFunc)

func (*FakeConsumer) ConsumeCallCount

func (fake *FakeConsumer) ConsumeCallCount() int

func (*FakeConsumer) ConsumeReturns

func (fake *FakeConsumer) ConsumeReturns(result1 error)

func (*FakeConsumer) ConsumeReturnsOnCall

func (fake *FakeConsumer) ConsumeReturnsOnCall(i int, result1 error)

func (*FakeConsumer) Invocations

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

type FakeMessage

type FakeMessage struct {
	AckStub func()

	NackStub func()

	DataStub func() []byte
	// contains filtered or unexported fields
}

func (*FakeMessage) Ack

func (fake *FakeMessage) Ack()

func (*FakeMessage) AckCallCount

func (fake *FakeMessage) AckCallCount() int

func (*FakeMessage) Data

func (fake *FakeMessage) Data() []byte

func (*FakeMessage) DataCallCount

func (fake *FakeMessage) DataCallCount() int

func (*FakeMessage) DataReturns

func (fake *FakeMessage) DataReturns(result1 []byte)

func (*FakeMessage) DataReturnsOnCall

func (fake *FakeMessage) DataReturnsOnCall(i int, result1 []byte)

func (*FakeMessage) Invocations

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

func (*FakeMessage) Nack

func (fake *FakeMessage) Nack()

func (*FakeMessage) NackCallCount

func (fake *FakeMessage) NackCallCount() int

type FakeProducer

type FakeProducer struct {
	ProduceStub func(ctx context.Context, data []byte) error
	// contains filtered or unexported fields
}

func (*FakeProducer) Invocations

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

func (*FakeProducer) Produce

func (fake *FakeProducer) Produce(ctx context.Context, data []byte) error

func (*FakeProducer) ProduceArgsForCall

func (fake *FakeProducer) ProduceArgsForCall(i int) (context.Context, []byte)

func (*FakeProducer) ProduceCallCount

func (fake *FakeProducer) ProduceCallCount() int

func (*FakeProducer) ProduceReturns

func (fake *FakeProducer) ProduceReturns(result1 error)

func (*FakeProducer) ProduceReturnsOnCall

func (fake *FakeProducer) ProduceReturnsOnCall(i int, result1 error)