mocks

package
v0.0.0-...-32ff608 Latest Latest
Warning

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

 Go to latest Published: Mar 28, 2023 License: Apache-2.0 Imports: 7 Imported by: 0

Documentation

Index

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

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.