mocks

package
v0.9.0 Latest Latest
Warning

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

 Go to latest Published: Sep 29, 2025 License: Apache-2.0 Imports: 5 Imported by: 0

Documentation

Overview

Package mocks is a generated GoMock package.

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type MockBus added in v0.6.0 

type MockBus struct{}

func (MockBus) Broadcast added in v0.6.0 

func (m MockBus) Broadcast(channel string, data interface{})

func (MockBus) ClusteringBroadcast added in v0.6.0 

func (m MockBus) ClusteringBroadcast(event string, data interface{}) error

func (MockBus) ClusteringSubscribe added in v0.6.0 

func (m MockBus) ClusteringSubscribe(channel string, fn func(data []byte))

func (MockBus) Subscribe added in v0.6.0 

func (m MockBus) Subscribe(channel string, cb eventbus.Callback)

type MockTaskQueue 

type MockTaskQueue struct {
	// contains filtered or unexported fields
}

MockTaskQueue is a mock of TaskQueue interface.

func NewMockTaskQueue 

func NewMockTaskQueue(ctrl *gomock.Controller) *MockTaskQueue

NewMockTaskQueue creates a new mock instance.

func (*MockTaskQueue) Add 

func (m *MockTaskQueue) Add(ctx context.Context, tasks []*taskqueue.TaskMessage) error

Add mocks base method.

func (*MockTaskQueue) Delete 

func (m *MockTaskQueue) Delete(ctx context.Context, task *taskqueue.TaskMessage) error

Delete mocks base method.

func (*MockTaskQueue) EXPECT 

func (m *MockTaskQueue) EXPECT() *MockTaskQueueMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockTaskQueue) Get 

func (m *MockTaskQueue) Get(ctx context.Context, opts *taskqueue.GetOptions) ([]*taskqueue.TaskMessage, error)

Get mocks base method.

func (*MockTaskQueue) Schedule added in v0.9.0 

func (m *MockTaskQueue) Schedule(ctx context.Context, task *taskqueue.TaskMessage) error

Schedule mocks base method.

func (*MockTaskQueue) Size 

func (m *MockTaskQueue) Size(ctx context.Context) (int64, error)

Size mocks base method.

func (*MockTaskQueue) Stats added in v0.8.0 

func (m *MockTaskQueue) Stats() map[string]any

Stats mocks base method.

type MockTaskQueueMockRecorder 

type MockTaskQueueMockRecorder struct {
	// contains filtered or unexported fields
}

MockTaskQueueMockRecorder is the mock recorder for MockTaskQueue.

func (*MockTaskQueueMockRecorder) Add 

func (mr *MockTaskQueueMockRecorder) Add(ctx, tasks any) *gomock.Call

Add indicates an expected call of Add.

func (*MockTaskQueueMockRecorder) Delete 

func (mr *MockTaskQueueMockRecorder) Delete(ctx, task any) *gomock.Call

Delete indicates an expected call of Delete.

func (*MockTaskQueueMockRecorder) Get 

func (mr *MockTaskQueueMockRecorder) Get(ctx, opts any) *gomock.Call

Get indicates an expected call of Get.

func (*MockTaskQueueMockRecorder) Schedule added in v0.9.0 

func (mr *MockTaskQueueMockRecorder) Schedule(ctx, task any) *gomock.Call

Schedule indicates an expected call of Schedule.

func (*MockTaskQueueMockRecorder) Size 

func (mr *MockTaskQueueMockRecorder) Size(ctx any) *gomock.Call

Size indicates an expected call of Size.

func (*MockTaskQueueMockRecorder) Stats added in v0.8.0 

func (mr *MockTaskQueueMockRecorder) Stats() *gomock.Call

Stats indicates an expected call of Stats.

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.