mocks

package

v0.0.0-...-32ff608 Latest Latest Go to latest Published: Mar 28, 2023 License: Apache-2.0 Imports: 7 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/apache/incubator-eventmesh

Documentation ¶

Index ¶

type MockConsumerGroupTopicOption
- func NewMockConsumerGroupTopicOption(ctrl *gomock.Controller) *MockConsumerGroupTopicOption
type MockConsumerGroupTopicOptionMockRecorder
type MockConsumerManager
- func NewMockConsumerManager(ctrl *gomock.Controller) *MockConsumerManager
type MockConsumerManagerMockRecorder

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

This section is empty.

Types ¶

type MockConsumerGroupTopicOption ¶

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

MockConsumerGroupTopicOption is a mock of ConsumerGroupTopicOption interface.

func NewMockConsumerGroupTopicOption ¶

func NewMockConsumerGroupTopicOption(ctrl *gomock.Controller) *MockConsumerGroupTopicOption

NewMockConsumerGroupTopicOption creates a new mock instance.

func (*MockConsumerGroupTopicOption) AllEmiters ¶

func (m *MockConsumerGroupTopicOption) AllEmiters() *set.Set

AllEmiters mocks base method.

func (*MockConsumerGroupTopicOption) AllURLs ¶

func (m *MockConsumerGroupTopicOption) AllURLs() *set.Set

AllURLs mocks base method.

func (*MockConsumerGroupTopicOption) ConsumerGroup ¶

func (m *MockConsumerGroupTopicOption) ConsumerGroup() string

ConsumerGroup mocks base method.

func (*MockConsumerGroupTopicOption) DeregisterClient ¶

func (m *MockConsumerGroupTopicOption) DeregisterClient() consumer.DeregisterClient

DeregisterClient mocks base method.

func (*MockConsumerGroupTopicOption) EXPECT ¶

func (m *MockConsumerGroupTopicOption) EXPECT() *MockConsumerGroupTopicOptionMockRecorder

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

func (*MockConsumerGroupTopicOption) GRPCType ¶

func (m *MockConsumerGroupTopicOption) GRPCType() consts.GRPCType

GRPCType mocks base method.

func (*MockConsumerGroupTopicOption) IDCEmiters ¶

func (m *MockConsumerGroupTopicOption) IDCEmiters() *sync.Map

IDCEmiters mocks base method.

func (*MockConsumerGroupTopicOption) IDCURLs ¶

func (m *MockConsumerGroupTopicOption) IDCURLs() *sync.Map

IDCURLs mocks base method.

func (*MockConsumerGroupTopicOption) RegisterClient ¶

func (m *MockConsumerGroupTopicOption) RegisterClient() consumer.RegisterClient

RegisterClient mocks base method.

func (*MockConsumerGroupTopicOption) Size ¶

func (m *MockConsumerGroupTopicOption) Size() int

Size mocks base method.

func (*MockConsumerGroupTopicOption) SubscriptionMode ¶

func (m *MockConsumerGroupTopicOption) SubscriptionMode() pb.Subscription_SubscriptionItem_SubscriptionMode

SubscriptionMode mocks base method.

func (*MockConsumerGroupTopicOption) Topic ¶

func (m *MockConsumerGroupTopicOption) Topic() string

Topic mocks base method.

type MockConsumerGroupTopicOptionMockRecorder ¶

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

MockConsumerGroupTopicOptionMockRecorder is the mock recorder for MockConsumerGroupTopicOption.

func (*MockConsumerGroupTopicOptionMockRecorder) AllEmiters ¶

func (mr *MockConsumerGroupTopicOptionMockRecorder) AllEmiters() *gomock.Call

AllEmiters indicates an expected call of AllEmiters.

func (*MockConsumerGroupTopicOptionMockRecorder) AllURLs ¶

func (mr *MockConsumerGroupTopicOptionMockRecorder) AllURLs() *gomock.Call

AllURLs indicates an expected call of AllURLs.

func (*MockConsumerGroupTopicOptionMockRecorder) ConsumerGroup ¶

func (mr *MockConsumerGroupTopicOptionMockRecorder) ConsumerGroup() *gomock.Call

ConsumerGroup indicates an expected call of ConsumerGroup.

func (*MockConsumerGroupTopicOptionMockRecorder) DeregisterClient ¶

func (mr *MockConsumerGroupTopicOptionMockRecorder) DeregisterClient() *gomock.Call

DeregisterClient indicates an expected call of DeregisterClient.

func (*MockConsumerGroupTopicOptionMockRecorder) GRPCType ¶

func (mr *MockConsumerGroupTopicOptionMockRecorder) GRPCType() *gomock.Call

GRPCType indicates an expected call of GRPCType.

func (*MockConsumerGroupTopicOptionMockRecorder) IDCEmiters ¶

func (mr *MockConsumerGroupTopicOptionMockRecorder) IDCEmiters() *gomock.Call

IDCEmiters indicates an expected call of IDCEmiters.

func (*MockConsumerGroupTopicOptionMockRecorder) IDCURLs ¶

func (mr *MockConsumerGroupTopicOptionMockRecorder) IDCURLs() *gomock.Call

IDCURLs indicates an expected call of IDCURLs.

func (*MockConsumerGroupTopicOptionMockRecorder) RegisterClient ¶

func (mr *MockConsumerGroupTopicOptionMockRecorder) RegisterClient() *gomock.Call

RegisterClient indicates an expected call of RegisterClient.

func (*MockConsumerGroupTopicOptionMockRecorder) Size ¶

func (mr *MockConsumerGroupTopicOptionMockRecorder) Size() *gomock.Call

Size indicates an expected call of Size.

func (*MockConsumerGroupTopicOptionMockRecorder) SubscriptionMode ¶

func (mr *MockConsumerGroupTopicOptionMockRecorder) SubscriptionMode() *gomock.Call

SubscriptionMode indicates an expected call of SubscriptionMode.

func (*MockConsumerGroupTopicOptionMockRecorder) Topic ¶

func (mr *MockConsumerGroupTopicOptionMockRecorder) Topic() *gomock.Call

Topic indicates an expected call of Topic.

type MockConsumerManager ¶

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

MockConsumerManager is a mock of ConsumerManager interface.

func NewMockConsumerManager ¶

func NewMockConsumerManager(ctrl *gomock.Controller) *MockConsumerManager

NewMockConsumerManager creates a new mock instance.

func (*MockConsumerManager) DeRegisterClient ¶

func (m *MockConsumerManager) DeRegisterClient(arg0 *consumer.GroupClient) error

DeRegisterClient mocks base method.

func (*MockConsumerManager) EXPECT ¶

func (m *MockConsumerManager) EXPECT() *MockConsumerManagerMockRecorder

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

func (*MockConsumerManager) GetConsumer ¶

func (m *MockConsumerManager) GetConsumer(arg0 string) (consumer.EventMeshConsumer, error)

GetConsumer mocks base method.

func (*MockConsumerManager) RegisterClient ¶

func (m *MockConsumerManager) RegisterClient(arg0 *consumer.GroupClient) error

RegisterClient mocks base method.

func (*MockConsumerManager) RestartConsumer ¶

func (m *MockConsumerManager) RestartConsumer(arg0 string) error

RestartConsumer mocks base method.

func (*MockConsumerManager) Start ¶

func (m *MockConsumerManager) Start() error

Start mocks base method.

func (*MockConsumerManager) Stop ¶

func (m *MockConsumerManager) Stop() error

Stop mocks base method.

func (*MockConsumerManager) UpdateClientTime ¶

func (m *MockConsumerManager) UpdateClientTime(arg0 *consumer.GroupClient)

UpdateClientTime mocks base method.

type MockConsumerManagerMockRecorder ¶

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

MockConsumerManagerMockRecorder is the mock recorder for MockConsumerManager.

func (*MockConsumerManagerMockRecorder) DeRegisterClient ¶

func (mr *MockConsumerManagerMockRecorder) DeRegisterClient(arg0 interface{}) *gomock.Call

DeRegisterClient indicates an expected call of DeRegisterClient.

func (*MockConsumerManagerMockRecorder) GetConsumer ¶

func (mr *MockConsumerManagerMockRecorder) GetConsumer(arg0 interface{}) *gomock.Call

GetConsumer indicates an expected call of GetConsumer.

func (*MockConsumerManagerMockRecorder) RegisterClient ¶

func (mr *MockConsumerManagerMockRecorder) RegisterClient(arg0 interface{}) *gomock.Call

RegisterClient indicates an expected call of RegisterClient.

func (*MockConsumerManagerMockRecorder) RestartConsumer ¶

func (mr *MockConsumerManagerMockRecorder) RestartConsumer(arg0 interface{}) *gomock.Call

RestartConsumer indicates an expected call of RestartConsumer.

func (*MockConsumerManagerMockRecorder) Start ¶

func (mr *MockConsumerManagerMockRecorder) Start() *gomock.Call

Start indicates an expected call of Start.

func (*MockConsumerManagerMockRecorder) Stop ¶

func (mr *MockConsumerManagerMockRecorder) Stop() *gomock.Call

Stop indicates an expected call of Stop.

func (*MockConsumerManagerMockRecorder) UpdateClientTime ¶

func (mr *MockConsumerManagerMockRecorder) UpdateClientTime(arg0 interface{}) *gomock.Call

UpdateClientTime indicates an expected call of UpdateClientTime.

Source Files ¶

View all Source files

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