workerfakes

Documentation

Overview

Code generated by counterfeiter. DO NOT EDIT.

Index

• type FakeTaskExecutor
  • func (fake *FakeTaskExecutor) ExecuteCommandConsumerKafka(arg1 *sarama.ConsumerMessage)
  • func (fake *FakeTaskExecutor) ExecuteCommandConsumerKafkaArgsForCall(i int) *sarama.ConsumerMessage
  • func (fake *FakeTaskExecutor) ExecuteCommandConsumerKafkaCallCount() int
  • func (fake *FakeTaskExecutor) ExecuteCommandConsumerKafkaCalls(stub func(*sarama.ConsumerMessage))
  • func (fake *FakeTaskExecutor) Invocations() map[string][][]interface{}
  • func (fake *FakeTaskExecutor) SetUpSubscriber(arg1 context.Context)
  • func (fake *FakeTaskExecutor) SetUpSubscriberArgsForCall(i int) context.Context
  • func (fake *FakeTaskExecutor) SetUpSubscriberCallCount() int
  • func (fake *FakeTaskExecutor) SetUpSubscriberCalls(stub func(context.Context))
  • func (fake *FakeTaskExecutor) Stop()
  • func (fake *FakeTaskExecutor) StopCallCount() int
  • func (fake *FakeTaskExecutor) StopCalls(stub func())

Types

type FakeTaskExecutor

type FakeTaskExecutor struct {
	ExecuteCommandConsumerKafkaStub func(*sarama.ConsumerMessage)

	SetUpSubscriberStub func(context.Context)

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

func (*FakeTaskExecutor) ExecuteCommandConsumerKafka

func (fake *FakeTaskExecutor) ExecuteCommandConsumerKafka(arg1 *sarama.ConsumerMessage)

func (*FakeTaskExecutor) ExecuteCommandConsumerKafkaArgsForCall

func (fake *FakeTaskExecutor) ExecuteCommandConsumerKafkaArgsForCall(i int) *sarama.ConsumerMessage

func (*FakeTaskExecutor) ExecuteCommandConsumerKafkaCallCount

func (fake *FakeTaskExecutor) ExecuteCommandConsumerKafkaCallCount() int

func (*FakeTaskExecutor) ExecuteCommandConsumerKafkaCalls

func (fake *FakeTaskExecutor) ExecuteCommandConsumerKafkaCalls(stub func(*sarama.ConsumerMessage))

func (*FakeTaskExecutor) Invocations

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

func (*FakeTaskExecutor) SetUpSubscriber

func (fake *FakeTaskExecutor) SetUpSubscriber(arg1 context.Context)

func (*FakeTaskExecutor) SetUpSubscriberArgsForCall

func (fake *FakeTaskExecutor) SetUpSubscriberArgsForCall(i int) context.Context

func (*FakeTaskExecutor) SetUpSubscriberCallCount

func (fake *FakeTaskExecutor) SetUpSubscriberCallCount() int

func (*FakeTaskExecutor) SetUpSubscriberCalls

func (fake *FakeTaskExecutor) SetUpSubscriberCalls(stub func(context.Context))

func (*FakeTaskExecutor) Stop

func (fake *FakeTaskExecutor) Stop()

func (*FakeTaskExecutor) StopCallCount

func (fake *FakeTaskExecutor) StopCallCount() int

func (*FakeTaskExecutor) StopCalls

func (fake *FakeTaskExecutor) StopCalls(stub func())