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

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

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

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.

Jump to

Keyboard shortcuts

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