queuefakes

Documentation

Overview

This file was generated by counterfeiter

This file was generated by counterfeiter

This file was generated by counterfeiter

This file was generated by counterfeiter

This file was generated by counterfeiter

This file was generated by counterfeiter

Index

• type FakeEnqueuer
  • func (fake *FakeEnqueuer) Enqueue(arg1 queue.Task) error
  • func (fake *FakeEnqueuer) EnqueueArgsForCall(i int) queue.Task
  • func (fake *FakeEnqueuer) EnqueueCallCount() int
  • func (fake *FakeEnqueuer) EnqueueReturns(result1 error)
  • func (fake *FakeEnqueuer) Invocations() map[string][][]interface{}
• type FakePlan
  • func (fake *FakePlan) Invocations() map[string][][]interface{}
  • func (fake *FakePlan) Task(arg1 string) queue.Task
  • func (fake *FakePlan) TaskArgsForCall(i int) string
  • func (fake *FakePlan) TaskCallCount() int
  • func (fake *FakePlan) TaskReturns(result1 queue.Task)
• type FakePubSubProcessor
  • func (fake *FakePubSubProcessor) Invocations() map[string][][]interface{}
  • func (fake *FakePubSubProcessor) Process(arg1 lager.Logger, arg2 *pubsub.Message) (bool, error)
  • func (fake *FakePubSubProcessor) ProcessArgsForCall(i int) (lager.Logger, *pubsub.Message)
  • func (fake *FakePubSubProcessor) ProcessCallCount() int
  • func (fake *FakePubSubProcessor) ProcessReturns(result1 bool, result2 error)
• type FakeTask
  • func (fake *FakeTask) ID() string
  • func (fake *FakeTask) IDCallCount() int
  • func (fake *FakeTask) IDReturns(result1 string)
  • func (fake *FakeTask) Invocations() map[string][][]interface{}
  • func (fake *FakeTask) Payload() string
  • func (fake *FakeTask) PayloadCallCount() int
  • func (fake *FakeTask) PayloadReturns(result1 string)
  • func (fake *FakeTask) Type() string
  • func (fake *FakeTask) TypeCallCount() int
  • func (fake *FakeTask) TypeReturns(result1 string)
• type FakeTopic
  • func (fake *FakeTopic) Invocations() map[string][][]interface{}
  • func (fake *FakeTopic) Publish(arg1 context.Context, arg2 ...*pubsub.Message) ([]string, error)
  • func (fake *FakeTopic) PublishArgsForCall(i int) (context.Context, []*pubsub.Message)
  • func (fake *FakeTopic) PublishCallCount() int
  • func (fake *FakeTopic) PublishReturns(result1 []string, result2 error)
• type FakeUUIDGenerator
  • func (fake *FakeUUIDGenerator) Generate() string
  • func (fake *FakeUUIDGenerator) GenerateCallCount() int
  • func (fake *FakeUUIDGenerator) GenerateReturns(result1 string)
  • func (fake *FakeUUIDGenerator) Invocations() map[string][][]interface{}

Types

type FakeEnqueuer

type FakeEnqueuer struct {
	EnqueueStub func(queue.Task) error
	// contains filtered or unexported fields
}

func (*FakeEnqueuer) Enqueue

func (fake *FakeEnqueuer) Enqueue(arg1 queue.Task) error

func (*FakeEnqueuer) EnqueueArgsForCall

func (fake *FakeEnqueuer) EnqueueArgsForCall(i int) queue.Task

func (*FakeEnqueuer) EnqueueCallCount

func (fake *FakeEnqueuer) EnqueueCallCount() int

func (*FakeEnqueuer) EnqueueReturns

func (fake *FakeEnqueuer) EnqueueReturns(result1 error)

func (*FakeEnqueuer) Invocations

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

type FakePlan

type FakePlan struct {
	TaskStub func(string) queue.Task
	// contains filtered or unexported fields
}

func (*FakePlan) Invocations

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

func (*FakePlan) Task

func (fake *FakePlan) Task(arg1 string) queue.Task

func (*FakePlan) TaskArgsForCall

func (fake *FakePlan) TaskArgsForCall(i int) string

func (*FakePlan) TaskCallCount

func (fake *FakePlan) TaskCallCount() int

func (*FakePlan) TaskReturns

func (fake *FakePlan) TaskReturns(result1 queue.Task)

type FakePubSubProcessor

type FakePubSubProcessor struct {
	ProcessStub func(lager.Logger, *pubsub.Message) (bool, error)
	// contains filtered or unexported fields
}

func (*FakePubSubProcessor) Invocations

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

func (*FakePubSubProcessor) Process

func (fake *FakePubSubProcessor) Process(arg1 lager.Logger, arg2 *pubsub.Message) (bool, error)

func (*FakePubSubProcessor) ProcessArgsForCall

func (fake *FakePubSubProcessor) ProcessArgsForCall(i int) (lager.Logger, *pubsub.Message)

func (*FakePubSubProcessor) ProcessCallCount

func (fake *FakePubSubProcessor) ProcessCallCount() int

func (*FakePubSubProcessor) ProcessReturns

func (fake *FakePubSubProcessor) ProcessReturns(result1 bool, result2 error)

type FakeTask

type FakeTask struct {
	IDStub func() string

	TypeStub func() string

	PayloadStub func() string
	// contains filtered or unexported fields
}

func (*FakeTask) ID

func (fake *FakeTask) ID() string

func (*FakeTask) IDCallCount

func (fake *FakeTask) IDCallCount() int

func (*FakeTask) IDReturns

func (fake *FakeTask) IDReturns(result1 string)

func (*FakeTask) Invocations

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

func (*FakeTask) Payload

func (fake *FakeTask) Payload() string

func (*FakeTask) PayloadCallCount

func (fake *FakeTask) PayloadCallCount() int

func (*FakeTask) PayloadReturns

func (fake *FakeTask) PayloadReturns(result1 string)

func (*FakeTask) Type

func (fake *FakeTask) Type() string

func (*FakeTask) TypeCallCount

func (fake *FakeTask) TypeCallCount() int

func (*FakeTask) TypeReturns

func (fake *FakeTask) TypeReturns(result1 string)

type FakeTopic

type FakeTopic struct {
	PublishStub func(context.Context, ...*pubsub.Message) ([]string, error)
	// contains filtered or unexported fields
}

func (*FakeTopic) Invocations

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

func (*FakeTopic) Publish

func (fake *FakeTopic) Publish(arg1 context.Context, arg2 ...*pubsub.Message) ([]string, error)

func (*FakeTopic) PublishArgsForCall

func (fake *FakeTopic) PublishArgsForCall(i int) (context.Context, []*pubsub.Message)

func (*FakeTopic) PublishCallCount

func (fake *FakeTopic) PublishCallCount() int

func (*FakeTopic) PublishReturns

func (fake *FakeTopic) PublishReturns(result1 []string, result2 error)

type FakeUUIDGenerator

type FakeUUIDGenerator struct {
	GenerateStub func() string
	// contains filtered or unexported fields
}

func (*FakeUUIDGenerator) Generate

func (fake *FakeUUIDGenerator) Generate() string

func (*FakeUUIDGenerator) GenerateCallCount

func (fake *FakeUUIDGenerator) GenerateCallCount() int

func (*FakeUUIDGenerator) GenerateReturns

func (fake *FakeUUIDGenerator) GenerateReturns(result1 string)

func (*FakeUUIDGenerator) Invocations

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