mocks

package
v1.0.1 Latest Latest
Warning

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

 Go to latest Published: Feb 6, 2026 License: Apache-2.0 Imports: 6 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(ctx context.Context, channel string, value interface{})

func (MockBus) ClusteringBroadcast added in v0.6.0 

func (m MockBus) ClusteringBroadcast(ctx context.Context, channel string, value eventbus.Marshaler) error

func (MockBus) ClusteringSubscribe added in v0.6.0 

func (m MockBus) ClusteringSubscribe(channel string, handler eventbus.ClusteringHandler)

func (MockBus) Subscribe added in v0.6.0 

func (m MockBus) Subscribe(channel string, handler eventbus.Handler)

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, ids ...string) 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, id string, scheduledAt time.Time) 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 any, ids ...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, id, scheduledAt 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.