mock

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

Overview

Package mock is a generated GoMock package.

Package mock is a generated GoMock package.

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type MockRocketMQConsumer 

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

MockRocketMQConsumer is a mock of RocketMQConsumer interface.

func NewMockRocketMQConsumer 

func NewMockRocketMQConsumer(ctrl *gomock.Controller) *MockRocketMQConsumer

NewMockRocketMQConsumer creates a new mock instance.

func (*MockRocketMQConsumer) EXPECT 

func (m *MockRocketMQConsumer) EXPECT() *MockRocketMQConsumerMockRecorder

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

func (*MockRocketMQConsumer) IsBroadCasting 

func (m *MockRocketMQConsumer) IsBroadCasting() bool

IsBroadCasting mocks base method.

func (*MockRocketMQConsumer) Resume 

func (m *MockRocketMQConsumer) Resume()

Resume mocks base method.

func (*MockRocketMQConsumer) Shutdown 

func (m *MockRocketMQConsumer) Shutdown() error

Shutdown mocks base method.

func (*MockRocketMQConsumer) Start 

func (m *MockRocketMQConsumer) Start() error

Start mocks base method.

func (*MockRocketMQConsumer) Subscribe 

func (m *MockRocketMQConsumer) Subscribe(topic string, selector consumer.MessageSelector, f client.SubscribeFunc) error

Subscribe mocks base method.

func (*MockRocketMQConsumer) Suspend 

func (m *MockRocketMQConsumer) Suspend()

Suspend mocks base method.

func (*MockRocketMQConsumer) Unsubscribe 

func (m *MockRocketMQConsumer) Unsubscribe(topic string) error

Unsubscribe mocks base method.

type MockRocketMQConsumerMockRecorder 

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

MockRocketMQConsumerMockRecorder is the mock recorder for MockRocketMQConsumer.

func (*MockRocketMQConsumerMockRecorder) IsBroadCasting 

func (mr *MockRocketMQConsumerMockRecorder) IsBroadCasting() *gomock.Call

IsBroadCasting indicates an expected call of IsBroadCasting.

func (*MockRocketMQConsumerMockRecorder) Resume 

func (mr *MockRocketMQConsumerMockRecorder) Resume() *gomock.Call

Resume indicates an expected call of Resume.

func (*MockRocketMQConsumerMockRecorder) Shutdown 

func (mr *MockRocketMQConsumerMockRecorder) Shutdown() *gomock.Call

Shutdown indicates an expected call of Shutdown.

func (*MockRocketMQConsumerMockRecorder) Start 

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

Start indicates an expected call of Start.

func (*MockRocketMQConsumerMockRecorder) Subscribe 

func (mr *MockRocketMQConsumerMockRecorder) Subscribe(topic, selector, f interface{}) *gomock.Call

Subscribe indicates an expected call of Subscribe.

func (*MockRocketMQConsumerMockRecorder) Suspend 

func (mr *MockRocketMQConsumerMockRecorder) Suspend() *gomock.Call

Suspend indicates an expected call of Suspend.

func (*MockRocketMQConsumerMockRecorder) Unsubscribe 

func (mr *MockRocketMQConsumerMockRecorder) Unsubscribe(topic interface{}) *gomock.Call

Unsubscribe indicates an expected call of Unsubscribe.

type MockRocketMQProducer 

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

MockRocketMQProducer is a mock of RocketMQProducer interface.

func NewMockRocketMQProducer 

func NewMockRocketMQProducer(ctrl *gomock.Controller) *MockRocketMQProducer

NewMockRocketMQProducer creates a new mock instance.

func (*MockRocketMQProducer) EXPECT 

func (m *MockRocketMQProducer) EXPECT() *MockRocketMQProducerMockRecorder

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

func (*MockRocketMQProducer) Request 

func (m *MockRocketMQProducer) Request(ctx context.Context, ttl time.Duration, msg *primitive.Message) (*primitive.Message, error)

Request mocks base method.

func (*MockRocketMQProducer) RequestAsync 

func (m *MockRocketMQProducer) RequestAsync(ctx context.Context, ttl time.Duration, callback func(context.Context, *primitive.Message, error), msg *primitive.Message) error

RequestAsync mocks base method.

func (*MockRocketMQProducer) SendAsync 

func (m *MockRocketMQProducer) SendAsync(ctx context.Context, mq func(context.Context, *primitive.SendResult, error), msg ...*primitive.Message) error

SendAsync mocks base method.

func (*MockRocketMQProducer) SendOneWay 

func (m *MockRocketMQProducer) SendOneWay(ctx context.Context, mq ...*primitive.Message) error

SendOneWay mocks base method.

func (*MockRocketMQProducer) SendSync 

func (m *MockRocketMQProducer) SendSync(ctx context.Context, mq ...*primitive.Message) (*primitive.SendResult, error)

SendSync mocks base method.

func (*MockRocketMQProducer) Shutdown 

func (m *MockRocketMQProducer) Shutdown() error

Shutdown mocks base method.

func (*MockRocketMQProducer) Start 

func (m *MockRocketMQProducer) Start() error

Start mocks base method.

type MockRocketMQProducerMockRecorder 

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

MockRocketMQProducerMockRecorder is the mock recorder for MockRocketMQProducer.

func (*MockRocketMQProducerMockRecorder) Request 

func (mr *MockRocketMQProducerMockRecorder) Request(ctx, ttl, msg interface{}) *gomock.Call

Request indicates an expected call of Request.

func (*MockRocketMQProducerMockRecorder) RequestAsync 

func (mr *MockRocketMQProducerMockRecorder) RequestAsync(ctx, ttl, callback, msg interface{}) *gomock.Call

RequestAsync indicates an expected call of RequestAsync.

func (*MockRocketMQProducerMockRecorder) SendAsync 

func (mr *MockRocketMQProducerMockRecorder) SendAsync(ctx, mq interface{}, msg ...interface{}) *gomock.Call

SendAsync indicates an expected call of SendAsync.

func (*MockRocketMQProducerMockRecorder) SendOneWay 

func (mr *MockRocketMQProducerMockRecorder) SendOneWay(ctx interface{}, mq ...interface{}) *gomock.Call

SendOneWay indicates an expected call of SendOneWay.

func (*MockRocketMQProducerMockRecorder) SendSync 

func (mr *MockRocketMQProducerMockRecorder) SendSync(ctx interface{}, mq ...interface{}) *gomock.Call

SendSync indicates an expected call of SendSync.

func (*MockRocketMQProducerMockRecorder) Shutdown 

func (mr *MockRocketMQProducerMockRecorder) Shutdown() *gomock.Call

Shutdown indicates an expected call of Shutdown.

func (*MockRocketMQProducerMockRecorder) Start 

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

Start indicates an expected call of Start.

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.