Documentation
¶
Overview ¶
Package mocks is a generated GoMock package.
Index ¶
- type MockClient
- func (m *MockClient) Close()
- func (m *MockClient) CreateProducer(arg0 pulsar.ProducerOptions) (pulsar.Producer, error)
- func (m *MockClient) CreateReader(arg0 pulsar.ReaderOptions) (pulsar.Reader, error)
- func (m *MockClient) CreateTableView(arg0 pulsar.TableViewOptions) (pulsar.TableView, error)
- func (m *MockClient) EXPECT() *MockClientMockRecorder
- func (m *MockClient) Subscribe(arg0 pulsar.ConsumerOptions) (pulsar.Consumer, error)
- func (m *MockClient) TopicPartitions(arg0 string) ([]string, error)
- type MockClientMockRecorder
- func (mr *MockClientMockRecorder) Close() *gomock.Call
- func (mr *MockClientMockRecorder) CreateProducer(arg0 interface{}) *gomock.Call
- func (mr *MockClientMockRecorder) CreateReader(arg0 interface{}) *gomock.Call
- func (mr *MockClientMockRecorder) CreateTableView(arg0 interface{}) *gomock.Call
- func (mr *MockClientMockRecorder) Subscribe(arg0 interface{}) *gomock.Call
- func (mr *MockClientMockRecorder) TopicPartitions(arg0 interface{}) *gomock.Call
- type MockMessage
- func (m *MockMessage) BrokerPublishTime() *time.Time
- func (m *MockMessage) EXPECT() *MockMessageMockRecorder
- func (m *MockMessage) EventTime() time.Time
- func (m *MockMessage) GetEncryptionContext() *pulsar.EncryptionContext
- func (m *MockMessage) GetReplicatedFrom() string
- func (m *MockMessage) GetSchemaValue(arg0 interface{}) error
- func (m *MockMessage) ID() pulsar.MessageID
- func (m *MockMessage) Index() *uint64
- func (m *MockMessage) IsReplicated() bool
- func (m *MockMessage) Key() string
- func (m *MockMessage) OrderingKey() string
- func (m *MockMessage) Payload() []byte
- func (m *MockMessage) ProducerName() string
- func (m *MockMessage) Properties() map[string]string
- func (m *MockMessage) PublishTime() time.Time
- func (m *MockMessage) RedeliveryCount() uint32
- func (m *MockMessage) Topic() string
- type MockMessageMockRecorder
- func (mr *MockMessageMockRecorder) BrokerPublishTime() *gomock.Call
- func (mr *MockMessageMockRecorder) EventTime() *gomock.Call
- func (mr *MockMessageMockRecorder) GetEncryptionContext() *gomock.Call
- func (mr *MockMessageMockRecorder) GetReplicatedFrom() *gomock.Call
- func (mr *MockMessageMockRecorder) GetSchemaValue(arg0 interface{}) *gomock.Call
- func (mr *MockMessageMockRecorder) ID() *gomock.Call
- func (mr *MockMessageMockRecorder) Index() *gomock.Call
- func (mr *MockMessageMockRecorder) IsReplicated() *gomock.Call
- func (mr *MockMessageMockRecorder) Key() *gomock.Call
- func (mr *MockMessageMockRecorder) OrderingKey() *gomock.Call
- func (mr *MockMessageMockRecorder) Payload() *gomock.Call
- func (mr *MockMessageMockRecorder) ProducerName() *gomock.Call
- func (mr *MockMessageMockRecorder) Properties() *gomock.Call
- func (mr *MockMessageMockRecorder) PublishTime() *gomock.Call
- func (mr *MockMessageMockRecorder) RedeliveryCount() *gomock.Call
- func (mr *MockMessageMockRecorder) Topic() *gomock.Call
- type MockProducer
- func (m *MockProducer) Close()
- func (m *MockProducer) EXPECT() *MockProducerMockRecorder
- func (m *MockProducer) Flush() error
- func (m *MockProducer) LastSequenceID() int64
- func (m *MockProducer) Name() string
- func (m *MockProducer) Send(arg0 context.Context, arg1 *pulsar.ProducerMessage) (pulsar.MessageID, error)
- func (m *MockProducer) SendAsync(arg0 context.Context, arg1 *pulsar.ProducerMessage, ...)
- func (m *MockProducer) Topic() string
- type MockProducerMockRecorder
- func (mr *MockProducerMockRecorder) Close() *gomock.Call
- func (mr *MockProducerMockRecorder) Flush() *gomock.Call
- func (mr *MockProducerMockRecorder) LastSequenceID() *gomock.Call
- func (mr *MockProducerMockRecorder) Name() *gomock.Call
- func (mr *MockProducerMockRecorder) Send(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockProducerMockRecorder) SendAsync(arg0, arg1, arg2 interface{}) *gomock.Call
- func (mr *MockProducerMockRecorder) Topic() *gomock.Call
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) 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) IsReplicated ¶
func (m *MockMessage) IsReplicated() bool
IsReplicated mocks base method.
func (*MockMessage) OrderingKey ¶
func (m *MockMessage) OrderingKey() string
OrderingKey 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.
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) EXPECT ¶
func (m *MockProducer) EXPECT() *MockProducerMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockProducer) LastSequenceID ¶
func (m *MockProducer) LastSequenceID() int64
LastSequenceID 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.
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.