mocks

package
v1.11.23 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Aug 3, 2022 License: Apache-2.0 Imports: 3 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Persistent added in v1.7.1 

type Persistent struct {
	mock.Mock
}

Persistent is an autogenerated mock type for the Persistent type

func NewPersistent added in v1.11.21 

func NewPersistent(t mockConstructorTestingTNewPersistent) *Persistent

NewPersistent creates a new instance of Persistent. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations.

func (*Persistent) AggregateAllTaskJob added in v1.7.1 

func (_m *Persistent) AggregateAllTaskJob(ctx context.Context, filter *taskqueueworker.Filter) []taskqueueworker.TaskSummary

AggregateAllTaskJob provides a mock function with given fields: ctx, filter

func (*Persistent) CleanJob added in v1.7.1 

func (_m *Persistent) CleanJob(ctx context.Context, filter *taskqueueworker.Filter) int64

CleanJob provides a mock function with given fields: ctx, filter

func (*Persistent) CountAllJob added in v1.7.1 

func (_m *Persistent) CountAllJob(ctx context.Context, filter *taskqueueworker.Filter) int

CountAllJob provides a mock function with given fields: ctx, filter

func (*Persistent) DeleteJob added in v1.10.4 

func (_m *Persistent) DeleteJob(ctx context.Context, id string) (taskqueueworker.Job, error)

DeleteJob provides a mock function with given fields: ctx, id

func (*Persistent) FindAllJob added in v1.7.1 

func (_m *Persistent) FindAllJob(ctx context.Context, filter *taskqueueworker.Filter) []taskqueueworker.Job

FindAllJob provides a mock function with given fields: ctx, filter

func (*Persistent) FindJobByID added in v1.7.1 

func (_m *Persistent) FindJobByID(ctx context.Context, id string, filterHistory *taskqueueworker.Filter) (taskqueueworker.Job, error)

FindJobByID provides a mock function with given fields: ctx, id, filterHistory

func (*Persistent) Ping added in v1.11.21 

func (_m *Persistent) Ping(ctx context.Context) error

Ping provides a mock function with given fields: ctx

func (*Persistent) SaveJob added in v1.7.1 

func (_m *Persistent) SaveJob(ctx context.Context, job *taskqueueworker.Job, retryHistories ...taskqueueworker.RetryHistory)

SaveJob provides a mock function with given fields: ctx, job, retryHistories

func (*Persistent) SetSummary added in v1.11.6 

func (_m *Persistent) SetSummary(_a0 taskqueueworker.Summary)

SetSummary provides a mock function with given fields: _a0

func (*Persistent) Summary added in v1.11.6 

func (_m *Persistent) Summary() taskqueueworker.Summary

Summary provides a mock function with given fields:

func (*Persistent) Type added in v1.11.23 

func (_m *Persistent) Type() string

Type provides a mock function with given fields:

func (*Persistent) UpdateJob added in v1.11.0 

func (_m *Persistent) UpdateJob(ctx context.Context, filter *taskqueueworker.Filter, updated map[string]interface{}, retryHistories ...taskqueueworker.RetryHistory) (int64, int64, error)

UpdateJob provides a mock function with given fields: ctx, filter, updated, retryHistories

type QueueStorage 

type QueueStorage struct {
	mock.Mock
}

QueueStorage is an autogenerated mock type for the QueueStorage type

func NewQueueStorage added in v1.11.21 

func NewQueueStorage(t mockConstructorTestingTNewQueueStorage) *QueueStorage

NewQueueStorage creates a new instance of QueueStorage. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations.

func (*QueueStorage) Clear 

func (_m *QueueStorage) Clear(ctx context.Context, taskName string)

Clear provides a mock function with given fields: ctx, taskName

func (*QueueStorage) NextJob 

func (_m *QueueStorage) NextJob(ctx context.Context, taskName string) string

NextJob provides a mock function with given fields: ctx, taskName

func (*QueueStorage) Ping added in v1.11.21 

func (_m *QueueStorage) Ping() error

Ping provides a mock function with given fields:

func (*QueueStorage) PopJob 

func (_m *QueueStorage) PopJob(ctx context.Context, taskName string) string

PopJob provides a mock function with given fields: ctx, taskName

func (*QueueStorage) PushJob 

func (_m *QueueStorage) PushJob(ctx context.Context, job *taskqueueworker.Job) int64

PushJob provides a mock function with given fields: ctx, job

func (*QueueStorage) Type added in v1.11.23 

func (_m *QueueStorage) Type() string

Type provides a mock function with given fields:

type Summary added in v1.11.6 

type Summary struct {
	mock.Mock
}

Summary is an autogenerated mock type for the Summary type

func NewSummary added in v1.11.21 

func NewSummary(t mockConstructorTestingTNewSummary) *Summary

NewSummary creates a new instance of Summary. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations.

func (*Summary) FindAllSummary added in v1.11.6 

func (_m *Summary) FindAllSummary(ctx context.Context, filter *taskqueueworker.Filter) []taskqueueworker.TaskSummary

FindAllSummary provides a mock function with given fields: ctx, filter

func (*Summary) FindDetailSummary added in v1.11.6 

func (_m *Summary) FindDetailSummary(ctx context.Context, taskName string) taskqueueworker.TaskSummary

FindDetailSummary provides a mock function with given fields: ctx, taskName

func (*Summary) IncrementSummary added in v1.11.6 

func (_m *Summary) IncrementSummary(ctx context.Context, taskName string, incr map[string]int64)

IncrementSummary provides a mock function with given fields: ctx, taskName, incr

func (*Summary) UpdateSummary added in v1.11.6 

func (_m *Summary) UpdateSummary(ctx context.Context, taskName string, updated map[string]interface{})

UpdateSummary provides a mock function with given fields: ctx, taskName, updated

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.