gevents

package
v1.1.15 Latest Latest
Warning

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

Go to latest
Published: Jul 7, 2023 License: MIT Imports: 7 Imported by: 0

Documentation

Overview

Package mock_gevents is a generated GoMock package.

Package mock_gevents is a generated GoMock package.

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func Clear

func Clear()

func Register

func Register(executor Executor, opts ...RegisterOption)

func SetDefaultExecutor

func SetDefaultExecutor(executor Executor)

Types

type DefaultPublisher

type DefaultPublisher struct {
}

func (*DefaultPublisher) Publish

func (ep *DefaultPublisher) Publish(ctx context.Context, event interface{},
	opts ...PublishOption) error

type Executor

type Executor interface {
	Execute(ctx context.Context, event interface{}) error
	Types() []reflect.Type
}

type MockExecutor added in v1.1.4

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

MockExecutor is a mock of Executor interface.

func NewMockExecutor added in v1.1.4

func NewMockExecutor(ctrl *gomock.Controller) *MockExecutor

NewMockExecutor creates a new mock instance.

func (*MockExecutor) EXPECT added in v1.1.4

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

func (*MockExecutor) Execute added in v1.1.4

func (m *MockExecutor) Execute(ctx context.Context, event interface{}) error

Execute mocks base method.

func (*MockExecutor) Types added in v1.1.4

func (m *MockExecutor) Types() []reflect.Type

Types mocks base method.

type MockExecutorMockRecorder added in v1.1.4

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

MockExecutorMockRecorder is the mock recorder for MockExecutor.

func (*MockExecutorMockRecorder) Execute added in v1.1.4

func (mr *MockExecutorMockRecorder) Execute(ctx, event interface{}) *gomock.Call

Execute indicates an expected call of Execute.

func (*MockExecutorMockRecorder) Types added in v1.1.4

func (mr *MockExecutorMockRecorder) Types() *gomock.Call

Types indicates an expected call of Types.

type MockPublisher added in v1.1.4

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

MockPublisher is a mock of Publisher interface.

func NewMockPublisher added in v1.1.4

func NewMockPublisher(ctrl *gomock.Controller) *MockPublisher

NewMockPublisher creates a new mock instance.

func (*MockPublisher) EXPECT added in v1.1.4

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

func (*MockPublisher) Publish added in v1.1.4

func (m *MockPublisher) Publish(ctx context.Context, event interface{}, opts ...PublishOption) error

Publish mocks base method.

type MockPublisherMockRecorder added in v1.1.4

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

MockPublisherMockRecorder is the mock recorder for MockPublisher.

func (*MockPublisherMockRecorder) Publish added in v1.1.4

func (mr *MockPublisherMockRecorder) Publish(ctx, event interface{}, opts ...interface{}) *gomock.Call

Publish indicates an expected call of Publish.

type PublishOption added in v1.1.14

type PublishOption func(*pubOptions)

func WithMustHaveSubscriber added in v1.1.14

func WithMustHaveSubscriber() PublishOption

type Publisher

type Publisher interface {
	Publish(ctx context.Context, event interface{}, opts ...PublishOption) error
}

type RegisterOption added in v1.1.14

type RegisterOption func(opt *registerOptions)

func WithRegisterPriority added in v1.1.14

func WithRegisterPriority(priority int) RegisterOption

WithRegisterPriority priority 越大越先执行

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL