mocks

package
v0.4.9 Latest Latest
Warning

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

Go to latest
Published: Dec 20, 2023 License: Apache-2.0 Imports: 9 Imported by: 0

Documentation

Overview

Package mocks is a generated GoMock package.

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) NewTransaction added in v0.3.91

func (m *MockClient) NewTransaction(arg0 time.Duration) (pulsar.Transaction, error)

NewTransaction mocks base method.

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) NewTransaction added in v0.3.91

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

NewTransaction indicates an expected call of NewTransaction.

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 MockExecutorApiClient added in v0.3.57

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

MockExecutorApiClient is a mock of ExecutorApiClient interface.

func NewMockExecutorApiClient added in v0.3.57

func NewMockExecutorApiClient(ctrl *gomock.Controller) *MockExecutorApiClient

NewMockExecutorApiClient creates a new mock instance.

func (*MockExecutorApiClient) EXPECT added in v0.3.57

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

func (*MockExecutorApiClient) LeaseJobRuns added in v0.3.57

LeaseJobRuns mocks base method.

func (*MockExecutorApiClient) ReportEvents added in v0.3.57

func (m *MockExecutorApiClient) ReportEvents(arg0 context.Context, arg1 *executorapi.EventList, arg2 ...grpc.CallOption) (*types.Empty, error)

ReportEvents mocks base method.

type MockExecutorApiClientMockRecorder added in v0.3.57

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

MockExecutorApiClientMockRecorder is the mock recorder for MockExecutorApiClient.

func (*MockExecutorApiClientMockRecorder) LeaseJobRuns added in v0.3.57

func (mr *MockExecutorApiClientMockRecorder) LeaseJobRuns(arg0 interface{}, arg1 ...interface{}) *gomock.Call

LeaseJobRuns indicates an expected call of LeaseJobRuns.

func (*MockExecutorApiClientMockRecorder) ReportEvents added in v0.3.57

func (mr *MockExecutorApiClientMockRecorder) ReportEvents(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call

ReportEvents indicates an expected call of ReportEvents.

type MockExecutorApi_LeaseJobRunsClient added in v0.3.57

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

MockExecutorApi_LeaseJobRunsClient is a mock of ExecutorApi_LeaseJobRunsClient interface.

func NewMockExecutorApi_LeaseJobRunsClient added in v0.3.57

func NewMockExecutorApi_LeaseJobRunsClient(ctrl *gomock.Controller) *MockExecutorApi_LeaseJobRunsClient

NewMockExecutorApi_LeaseJobRunsClient creates a new mock instance.

func (*MockExecutorApi_LeaseJobRunsClient) CloseSend added in v0.3.57

CloseSend mocks base method.

func (*MockExecutorApi_LeaseJobRunsClient) Context added in v0.3.57

Context mocks base method.

func (*MockExecutorApi_LeaseJobRunsClient) EXPECT added in v0.3.57

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

func (*MockExecutorApi_LeaseJobRunsClient) Header added in v0.3.57

Header mocks base method.

func (*MockExecutorApi_LeaseJobRunsClient) Recv added in v0.3.57

Recv mocks base method.

func (*MockExecutorApi_LeaseJobRunsClient) RecvMsg added in v0.3.57

func (m *MockExecutorApi_LeaseJobRunsClient) RecvMsg(arg0 interface{}) error

RecvMsg mocks base method.

func (*MockExecutorApi_LeaseJobRunsClient) Send added in v0.3.57

Send mocks base method.

func (*MockExecutorApi_LeaseJobRunsClient) SendMsg added in v0.3.57

func (m *MockExecutorApi_LeaseJobRunsClient) SendMsg(arg0 interface{}) error

SendMsg mocks base method.

func (*MockExecutorApi_LeaseJobRunsClient) Trailer added in v0.3.57

Trailer mocks base method.

type MockExecutorApi_LeaseJobRunsClientMockRecorder added in v0.3.57

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

MockExecutorApi_LeaseJobRunsClientMockRecorder is the mock recorder for MockExecutorApi_LeaseJobRunsClient.

func (*MockExecutorApi_LeaseJobRunsClientMockRecorder) CloseSend added in v0.3.57

CloseSend indicates an expected call of CloseSend.

func (*MockExecutorApi_LeaseJobRunsClientMockRecorder) Context added in v0.3.57

Context indicates an expected call of Context.

func (*MockExecutorApi_LeaseJobRunsClientMockRecorder) Header added in v0.3.57

Header indicates an expected call of Header.

func (*MockExecutorApi_LeaseJobRunsClientMockRecorder) Recv added in v0.3.57

Recv indicates an expected call of Recv.

func (*MockExecutorApi_LeaseJobRunsClientMockRecorder) RecvMsg added in v0.3.57

func (mr *MockExecutorApi_LeaseJobRunsClientMockRecorder) RecvMsg(arg0 interface{}) *gomock.Call

RecvMsg indicates an expected call of RecvMsg.

func (*MockExecutorApi_LeaseJobRunsClientMockRecorder) Send added in v0.3.57

func (mr *MockExecutorApi_LeaseJobRunsClientMockRecorder) Send(arg0 interface{}) *gomock.Call

Send indicates an expected call of Send.

func (*MockExecutorApi_LeaseJobRunsClientMockRecorder) SendMsg added in v0.3.57

func (mr *MockExecutorApi_LeaseJobRunsClientMockRecorder) SendMsg(arg0 interface{}) *gomock.Call

SendMsg indicates an expected call of SendMsg.

func (*MockExecutorApi_LeaseJobRunsClientMockRecorder) Trailer added in v0.3.57

Trailer indicates an expected call of Trailer.

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) SchemaVersion added in v0.3.91

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

SchemaVersion 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) SchemaVersion added in v0.3.91

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

SchemaVersion indicates an expected call of SchemaVersion.

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