storagefakes

Documentation

Overview

Code generated by counterfeiter. DO NOT EDIT.

Index

• type FakeTaskStorage
  • func (fake *FakeTaskStorage) CountAllWaitingTasks(arg1 context.Context) (int64, error)
  • func (fake *FakeTaskStorage) CountAllWaitingTasksArgsForCall(i int) context.Context
  • func (fake *FakeTaskStorage) CountAllWaitingTasksCallCount() int
  • func (fake *FakeTaskStorage) CountAllWaitingTasksCalls(stub func(context.Context) (int64, error))
  • func (fake *FakeTaskStorage) CountAllWaitingTasksReturns(result1 int64, result2 error)
  • func (fake *FakeTaskStorage) CountAllWaitingTasksReturnsOnCall(i int, result1 int64, result2 error)
  • func (fake *FakeTaskStorage) FetchAndRemoveDueTasks(arg1 context.Context) []*scheduler.Task
  • func (fake *FakeTaskStorage) FetchAndRemoveDueTasksArgsForCall(i int) context.Context
  • func (fake *FakeTaskStorage) FetchAndRemoveDueTasksCallCount() int
  • func (fake *FakeTaskStorage) FetchAndRemoveDueTasksCalls(stub func(context.Context) []*scheduler.Task)
  • func (fake *FakeTaskStorage) FetchAndRemoveDueTasksReturns(result1 []*scheduler.Task)
  • func (fake *FakeTaskStorage) FetchAndRemoveDueTasksReturnsOnCall(i int, result1 []*scheduler.Task)
  • func (fake *FakeTaskStorage) GetAllTasks(arg1 context.Context) []*scheduler.Task
  • func (fake *FakeTaskStorage) GetAllTasksArgsForCall(i int) context.Context
  • func (fake *FakeTaskStorage) GetAllTasksCallCount() int
  • func (fake *FakeTaskStorage) GetAllTasksCalls(stub func(context.Context) []*scheduler.Task)
  • func (fake *FakeTaskStorage) GetAllTasksPagination(arg1 context.Context, arg2 int32, arg3 int32) []*scheduler.Task
  • func (fake *FakeTaskStorage) GetAllTasksPaginationArgsForCall(i int) (context.Context, int32, int32)
  • func (fake *FakeTaskStorage) GetAllTasksPaginationCallCount() int
  • func (fake *FakeTaskStorage) GetAllTasksPaginationCalls(stub func(context.Context, int32, int32) []*scheduler.Task)
  • func (fake *FakeTaskStorage) GetAllTasksPaginationReturns(result1 []*scheduler.Task)
  • func (fake *FakeTaskStorage) GetAllTasksPaginationReturnsOnCall(i int, result1 []*scheduler.Task)
  • func (fake *FakeTaskStorage) GetAllTasksReturns(result1 []*scheduler.Task)
  • func (fake *FakeTaskStorage) GetAllTasksReturnsOnCall(i int, result1 []*scheduler.Task)
  • func (fake *FakeTaskStorage) Invocations() map[string][][]interface{}
  • func (fake *FakeTaskStorage) Publish(arg1 context.Context, arg2 string, arg3 interface{}) *redis.IntCmd
  • func (fake *FakeTaskStorage) PublishArgsForCall(i int) (context.Context, string, interface{})
  • func (fake *FakeTaskStorage) PublishCallCount() int
  • func (fake *FakeTaskStorage) PublishCalls(stub func(context.Context, string, interface{}) *redis.IntCmd)
  • func (fake *FakeTaskStorage) PublishReturns(result1 *redis.IntCmd)
  • func (fake *FakeTaskStorage) PublishReturnsOnCall(i int, result1 *redis.IntCmd)
  • func (fake *FakeTaskStorage) SetNewTask(arg1 context.Context, arg2 *scheduler.Task)
  • func (fake *FakeTaskStorage) SetNewTaskArgsForCall(i int) (context.Context, *scheduler.Task)
  • func (fake *FakeTaskStorage) SetNewTaskCallCount() int
  • func (fake *FakeTaskStorage) SetNewTaskCalls(stub func(context.Context, *scheduler.Task))
  • func (fake *FakeTaskStorage) Subscribe(arg1 context.Context, arg2 ...string) *redis.PubSub
  • func (fake *FakeTaskStorage) SubscribeArgsForCall(i int) (context.Context, []string)
  • func (fake *FakeTaskStorage) SubscribeCallCount() int
  • func (fake *FakeTaskStorage) SubscribeCalls(stub func(context.Context, ...string) *redis.PubSub)
  • func (fake *FakeTaskStorage) SubscribeReturns(result1 *redis.PubSub)
  • func (fake *FakeTaskStorage) SubscribeReturnsOnCall(i int, result1 *redis.PubSub)

Types

type FakeTaskStorage

type FakeTaskStorage struct {
	CountAllWaitingTasksStub func(context.Context) (int64, error)

	FetchAndRemoveDueTasksStub func(context.Context) []*scheduler.Task

	GetAllTasksStub func(context.Context) []*scheduler.Task

	GetAllTasksPaginationStub func(context.Context, int32, int32) []*scheduler.Task

	PublishStub func(context.Context, string, interface{}) *redis.IntCmd

	SetNewTaskStub func(context.Context, *scheduler.Task)

	SubscribeStub func(context.Context, ...string) *redis.PubSub
	// contains filtered or unexported fields
}

func (*FakeTaskStorage) CountAllWaitingTasks

func (fake *FakeTaskStorage) CountAllWaitingTasks(arg1 context.Context) (int64, error)

func (*FakeTaskStorage) CountAllWaitingTasksArgsForCall

func (fake *FakeTaskStorage) CountAllWaitingTasksArgsForCall(i int) context.Context

func (*FakeTaskStorage) CountAllWaitingTasksCallCount

func (fake *FakeTaskStorage) CountAllWaitingTasksCallCount() int

func (*FakeTaskStorage) CountAllWaitingTasksCalls

func (fake *FakeTaskStorage) CountAllWaitingTasksCalls(stub func(context.Context) (int64, error))

func (*FakeTaskStorage) CountAllWaitingTasksReturns

func (fake *FakeTaskStorage) CountAllWaitingTasksReturns(result1 int64, result2 error)

func (*FakeTaskStorage) CountAllWaitingTasksReturnsOnCall

func (fake *FakeTaskStorage) CountAllWaitingTasksReturnsOnCall(i int, result1 int64, result2 error)

func (*FakeTaskStorage) FetchAndRemoveDueTasks

func (fake *FakeTaskStorage) FetchAndRemoveDueTasks(arg1 context.Context) []*scheduler.Task

func (*FakeTaskStorage) FetchAndRemoveDueTasksArgsForCall

func (fake *FakeTaskStorage) FetchAndRemoveDueTasksArgsForCall(i int) context.Context

func (*FakeTaskStorage) FetchAndRemoveDueTasksCallCount

func (fake *FakeTaskStorage) FetchAndRemoveDueTasksCallCount() int

func (*FakeTaskStorage) FetchAndRemoveDueTasksCalls

func (fake *FakeTaskStorage) FetchAndRemoveDueTasksCalls(stub func(context.Context) []*scheduler.Task)

func (*FakeTaskStorage) FetchAndRemoveDueTasksReturns

func (fake *FakeTaskStorage) FetchAndRemoveDueTasksReturns(result1 []*scheduler.Task)

func (*FakeTaskStorage) FetchAndRemoveDueTasksReturnsOnCall

func (fake *FakeTaskStorage) FetchAndRemoveDueTasksReturnsOnCall(i int, result1 []*scheduler.Task)

func (*FakeTaskStorage) GetAllTasks

func (fake *FakeTaskStorage) GetAllTasks(arg1 context.Context) []*scheduler.Task

func (*FakeTaskStorage) GetAllTasksArgsForCall

func (fake *FakeTaskStorage) GetAllTasksArgsForCall(i int) context.Context

func (*FakeTaskStorage) GetAllTasksCallCount

func (fake *FakeTaskStorage) GetAllTasksCallCount() int

func (*FakeTaskStorage) GetAllTasksCalls

func (fake *FakeTaskStorage) GetAllTasksCalls(stub func(context.Context) []*scheduler.Task)

func (*FakeTaskStorage) GetAllTasksPagination

func (fake *FakeTaskStorage) GetAllTasksPagination(arg1 context.Context, arg2 int32, arg3 int32) []*scheduler.Task

func (*FakeTaskStorage) GetAllTasksPaginationArgsForCall

func (fake *FakeTaskStorage) GetAllTasksPaginationArgsForCall(i int) (context.Context, int32, int32)

func (*FakeTaskStorage) GetAllTasksPaginationCallCount

func (fake *FakeTaskStorage) GetAllTasksPaginationCallCount() int

func (*FakeTaskStorage) GetAllTasksPaginationCalls

func (fake *FakeTaskStorage) GetAllTasksPaginationCalls(stub func(context.Context, int32, int32) []*scheduler.Task)

func (*FakeTaskStorage) GetAllTasksPaginationReturns

func (fake *FakeTaskStorage) GetAllTasksPaginationReturns(result1 []*scheduler.Task)

func (*FakeTaskStorage) GetAllTasksPaginationReturnsOnCall

func (fake *FakeTaskStorage) GetAllTasksPaginationReturnsOnCall(i int, result1 []*scheduler.Task)

func (*FakeTaskStorage) GetAllTasksReturns

func (fake *FakeTaskStorage) GetAllTasksReturns(result1 []*scheduler.Task)

func (*FakeTaskStorage) GetAllTasksReturnsOnCall

func (fake *FakeTaskStorage) GetAllTasksReturnsOnCall(i int, result1 []*scheduler.Task)

func (*FakeTaskStorage) Invocations

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

func (*FakeTaskStorage) Publish

func (fake *FakeTaskStorage) Publish(arg1 context.Context, arg2 string, arg3 interface{}) *redis.IntCmd

func (*FakeTaskStorage) PublishArgsForCall

func (fake *FakeTaskStorage) PublishArgsForCall(i int) (context.Context, string, interface{})

func (*FakeTaskStorage) PublishCallCount

func (fake *FakeTaskStorage) PublishCallCount() int

func (*FakeTaskStorage) PublishCalls

func (fake *FakeTaskStorage) PublishCalls(stub func(context.Context, string, interface{}) *redis.IntCmd)

func (*FakeTaskStorage) PublishReturns

func (fake *FakeTaskStorage) PublishReturns(result1 *redis.IntCmd)

func (*FakeTaskStorage) PublishReturnsOnCall

func (fake *FakeTaskStorage) PublishReturnsOnCall(i int, result1 *redis.IntCmd)

func (*FakeTaskStorage) SetNewTask

func (fake *FakeTaskStorage) SetNewTask(arg1 context.Context, arg2 *scheduler.Task)

func (*FakeTaskStorage) SetNewTaskArgsForCall

func (fake *FakeTaskStorage) SetNewTaskArgsForCall(i int) (context.Context, *scheduler.Task)

func (*FakeTaskStorage) SetNewTaskCallCount

func (fake *FakeTaskStorage) SetNewTaskCallCount() int

func (*FakeTaskStorage) SetNewTaskCalls

func (fake *FakeTaskStorage) SetNewTaskCalls(stub func(context.Context, *scheduler.Task))

func (*FakeTaskStorage) Subscribe

func (fake *FakeTaskStorage) Subscribe(arg1 context.Context, arg2 ...string) *redis.PubSub

func (*FakeTaskStorage) SubscribeArgsForCall

func (fake *FakeTaskStorage) SubscribeArgsForCall(i int) (context.Context, []string)

func (*FakeTaskStorage) SubscribeCallCount

func (fake *FakeTaskStorage) SubscribeCallCount() int

func (*FakeTaskStorage) SubscribeCalls

func (fake *FakeTaskStorage) SubscribeCalls(stub func(context.Context, ...string) *redis.PubSub)

func (*FakeTaskStorage) SubscribeReturns

func (fake *FakeTaskStorage) SubscribeReturns(result1 *redis.PubSub)

func (*FakeTaskStorage) SubscribeReturnsOnCall

func (fake *FakeTaskStorage) SubscribeReturnsOnCall(i int, result1 *redis.PubSub)