mocks

package
v0.3.53 Latest Latest
Warning

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

 Go to latest Published: Mar 2, 2023 License: Apache-2.0 Imports: 5 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 MockClient 

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

MockClient is a mock of Client interface.

func NewMockClient 

func NewMockClient(ctrl *gomock.Controller) *MockClient

NewMockClient creates a new mock instance.

func (*MockClient) Close 

func (m *MockClient) Close()

Close mocks base method.

func (*MockClient) CreateProducer 

func (m *MockClient) CreateProducer(arg0 pulsar.ProducerOptions) (pulsar.Producer, error)

CreateProducer mocks base method.

func (*MockClient) CreateReader 

func (m *MockClient) CreateReader(arg0 pulsar.ReaderOptions) (pulsar.Reader, error)

CreateReader mocks base method.

func (*MockClient) CreateTableView 

func (m *MockClient) CreateTableView(arg0 pulsar.TableViewOptions) (pulsar.TableView, error)

CreateTableView mocks base method.

func (*MockClient) EXPECT 

func (m *MockClient) EXPECT() *MockClientMockRecorder

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

func (*MockClient) Subscribe 

func (m *MockClient) Subscribe(arg0 pulsar.ConsumerOptions) (pulsar.Consumer, error)

Subscribe mocks base method.

func (*MockClient) TopicPartitions 

func (m *MockClient) TopicPartitions(arg0 string) ([]string, error)

TopicPartitions mocks base method.

type MockClientMockRecorder 

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

MockClientMockRecorder is the mock recorder for MockClient.

func (*MockClientMockRecorder) Close 

func (mr *MockClientMockRecorder) Close() *gomock.Call

Close indicates an expected call of Close.

func (*MockClientMockRecorder) CreateProducer 

func (mr *MockClientMockRecorder) CreateProducer(arg0 interface{}) *gomock.Call

CreateProducer indicates an expected call of CreateProducer.

func (*MockClientMockRecorder) CreateReader 

func (mr *MockClientMockRecorder) CreateReader(arg0 interface{}) *gomock.Call

CreateReader indicates an expected call of CreateReader.

func (*MockClientMockRecorder) CreateTableView 

func (mr *MockClientMockRecorder) CreateTableView(arg0 interface{}) *gomock.Call

CreateTableView indicates an expected call of CreateTableView.

func (*MockClientMockRecorder) Subscribe 

func (mr *MockClientMockRecorder) Subscribe(arg0 interface{}) *gomock.Call

Subscribe indicates an expected call of Subscribe.

func (*MockClientMockRecorder) TopicPartitions 

func (mr *MockClientMockRecorder) TopicPartitions(arg0 interface{}) *gomock.Call

TopicPartitions indicates an expected call of TopicPartitions.

type MockMessage 

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

MockMessage is a mock of Message interface.

func NewMockMessage 

func NewMockMessage(ctrl *gomock.Controller) *MockMessage

NewMockMessage creates a new mock instance.

func (*MockMessage) BrokerPublishTime 

func (m *MockMessage) BrokerPublishTime() *time.Time

BrokerPublishTime mocks base method.

func (*MockMessage) EXPECT 

func (m *MockMessage) EXPECT() *MockMessageMockRecorder

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

func (*MockMessage) EventTime 

func (m *MockMessage) EventTime() time.Time

EventTime mocks base method.

func (*MockMessage) GetEncryptionContext 

func (m *MockMessage) GetEncryptionContext() *pulsar.EncryptionContext

GetEncryptionContext mocks base method.

func (*MockMessage) GetReplicatedFrom 

func (m *MockMessage) GetReplicatedFrom() string

GetReplicatedFrom mocks base method.

func (*MockMessage) GetSchemaValue 

func (m *MockMessage) GetSchemaValue(arg0 interface{}) error

GetSchemaValue mocks base method.

func (*MockMessage) ID 

func (m *MockMessage) ID() pulsar.MessageID

ID mocks base method.

func (*MockMessage) Index 

func (m *MockMessage) Index() *uint64

Index mocks base method.

func (*MockMessage) IsReplicated 

func (m *MockMessage) IsReplicated() bool

IsReplicated mocks base method.

func (*MockMessage) Key 

func (m *MockMessage) Key() string

Key mocks base method.

func (*MockMessage) OrderingKey 

func (m *MockMessage) OrderingKey() string

OrderingKey mocks base method.

func (*MockMessage) Payload 

func (m *MockMessage) Payload() []byte

Payload mocks base method.

func (*MockMessage) ProducerName 

func (m *MockMessage) ProducerName() string

ProducerName mocks base method.

func (*MockMessage) Properties 

func (m *MockMessage) Properties() map[string]string

Properties mocks base method.

func (*MockMessage) PublishTime 

func (m *MockMessage) PublishTime() time.Time

PublishTime mocks base method.

func (*MockMessage) RedeliveryCount 

func (m *MockMessage) RedeliveryCount() uint32

RedeliveryCount mocks base method.

func (*MockMessage) Topic 

func (m *MockMessage) Topic() string

Topic mocks base method.

type MockMessageMockRecorder 

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

MockMessageMockRecorder is the mock recorder for MockMessage.

func (*MockMessageMockRecorder) BrokerPublishTime 

func (mr *MockMessageMockRecorder) BrokerPublishTime() *gomock.Call

BrokerPublishTime indicates an expected call of BrokerPublishTime.

func (*MockMessageMockRecorder) EventTime 

func (mr *MockMessageMockRecorder) EventTime() *gomock.Call

EventTime indicates an expected call of EventTime.

func (*MockMessageMockRecorder) GetEncryptionContext 

func (mr *MockMessageMockRecorder) GetEncryptionContext() *gomock.Call

GetEncryptionContext indicates an expected call of GetEncryptionContext.

func (*MockMessageMockRecorder) GetReplicatedFrom 

func (mr *MockMessageMockRecorder) GetReplicatedFrom() *gomock.Call

GetReplicatedFrom indicates an expected call of GetReplicatedFrom.

func (*MockMessageMockRecorder) GetSchemaValue 

func (mr *MockMessageMockRecorder) GetSchemaValue(arg0 interface{}) *gomock.Call

GetSchemaValue indicates an expected call of GetSchemaValue.

func (*MockMessageMockRecorder) ID 

func (mr *MockMessageMockRecorder) ID() *gomock.Call

ID indicates an expected call of ID.

func (*MockMessageMockRecorder) Index 

func (mr *MockMessageMockRecorder) Index() *gomock.Call

Index indicates an expected call of Index.

func (*MockMessageMockRecorder) IsReplicated 

func (mr *MockMessageMockRecorder) IsReplicated() *gomock.Call

IsReplicated indicates an expected call of IsReplicated.

func (*MockMessageMockRecorder) Key 

func (mr *MockMessageMockRecorder) Key() *gomock.Call

Key indicates an expected call of Key.

func (*MockMessageMockRecorder) OrderingKey 

func (mr *MockMessageMockRecorder) OrderingKey() *gomock.Call

OrderingKey indicates an expected call of OrderingKey.

func (*MockMessageMockRecorder) Payload 

func (mr *MockMessageMockRecorder) Payload() *gomock.Call

Payload indicates an expected call of Payload.

func (*MockMessageMockRecorder) ProducerName 

func (mr *MockMessageMockRecorder) ProducerName() *gomock.Call

ProducerName indicates an expected call of ProducerName.

func (*MockMessageMockRecorder) Properties 

func (mr *MockMessageMockRecorder) Properties() *gomock.Call

Properties indicates an expected call of Properties.

func (*MockMessageMockRecorder) PublishTime 

func (mr *MockMessageMockRecorder) PublishTime() *gomock.Call

PublishTime indicates an expected call of PublishTime.

func (*MockMessageMockRecorder) RedeliveryCount 

func (mr *MockMessageMockRecorder) RedeliveryCount() *gomock.Call

RedeliveryCount indicates an expected call of RedeliveryCount.

func (*MockMessageMockRecorder) Topic 

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

Topic indicates an expected call of Topic.

type MockProducer 

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

MockProducer is a mock of Producer interface.

func NewMockProducer 

func NewMockProducer(ctrl *gomock.Controller) *MockProducer

NewMockProducer creates a new mock instance.

func (*MockProducer) Close 

func (m *MockProducer) Close()

Close mocks base method.

func (*MockProducer) EXPECT 

func (m *MockProducer) EXPECT() *MockProducerMockRecorder

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

func (*MockProducer) Flush 

func (m *MockProducer) Flush() error

Flush mocks base method.

func (*MockProducer) LastSequenceID 

func (m *MockProducer) LastSequenceID() int64

LastSequenceID mocks base method.

func (*MockProducer) Name 

func (m *MockProducer) Name() string

Name mocks base method.

func (*MockProducer) Send 

func (m *MockProducer) Send(arg0 context.Context, arg1 *pulsar.ProducerMessage) (pulsar.MessageID, error)

Send mocks base method.

func (*MockProducer) SendAsync 

func (m *MockProducer) SendAsync(arg0 context.Context, arg1 *pulsar.ProducerMessage, arg2 func(pulsar.MessageID, *pulsar.ProducerMessage, error))

SendAsync mocks base method.

func (*MockProducer) Topic 

func (m *MockProducer) Topic() string

Topic mocks base method.

type MockProducerMockRecorder 

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

MockProducerMockRecorder is the mock recorder for MockProducer.

func (*MockProducerMockRecorder) Close 

func (mr *MockProducerMockRecorder) Close() *gomock.Call

Close indicates an expected call of Close.

func (*MockProducerMockRecorder) Flush 

func (mr *MockProducerMockRecorder) Flush() *gomock.Call

Flush indicates an expected call of Flush.

func (*MockProducerMockRecorder) LastSequenceID 

func (mr *MockProducerMockRecorder) LastSequenceID() *gomock.Call

LastSequenceID indicates an expected call of LastSequenceID.

func (*MockProducerMockRecorder) Name 

func (mr *MockProducerMockRecorder) Name() *gomock.Call

Name indicates an expected call of Name.

func (*MockProducerMockRecorder) Send 

func (mr *MockProducerMockRecorder) Send(arg0, arg1 interface{}) *gomock.Call

Send indicates an expected call of Send.

func (*MockProducerMockRecorder) SendAsync 

func (mr *MockProducerMockRecorder) SendAsync(arg0, arg1, arg2 interface{}) *gomock.Call

SendAsync indicates an expected call of SendAsync.

func (*MockProducerMockRecorder) Topic 

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

Topic indicates an expected call of Topic.

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.