mocks

package
v0.3.94 Latest Latest
Warning

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

 Go to latest Published: Oct 6, 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 

func (m *MockExecutorApiClient) EXPECT() *MockExecutorApiClientMockRecorder

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

func (*MockExecutorApiClient) LeaseJobRuns added in v0.3.57 

func (m *MockExecutorApiClient) LeaseJobRuns(arg0 context.Context, arg1 ...grpc.CallOption) (executorapi.ExecutorApi_LeaseJobRunsClient, error)

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 

func (m *MockExecutorApi_LeaseJobRunsClient) CloseSend() error

CloseSend mocks base method.

func (*MockExecutorApi_LeaseJobRunsClient) Context added in v0.3.57 

func (m *MockExecutorApi_LeaseJobRunsClient) Context() context.Context

Context mocks base method.

func (*MockExecutorApi_LeaseJobRunsClient) EXPECT added in v0.3.57 

func (m *MockExecutorApi_LeaseJobRunsClient) EXPECT() *MockExecutorApi_LeaseJobRunsClientMockRecorder

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

func (*MockExecutorApi_LeaseJobRunsClient) Header added in v0.3.57 

func (m *MockExecutorApi_LeaseJobRunsClient) Header() (metadata.MD, error)

Header mocks base method.

func (*MockExecutorApi_LeaseJobRunsClient) Recv added in v0.3.57 

func (m *MockExecutorApi_LeaseJobRunsClient) Recv() (*executorapi.LeaseStreamMessage, error)

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 

func (m *MockExecutorApi_LeaseJobRunsClient) Send(arg0 *executorapi.LeaseRequest) error

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 

func (m *MockExecutorApi_LeaseJobRunsClient) Trailer() metadata.MD

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 

func (mr *MockExecutorApi_LeaseJobRunsClientMockRecorder) CloseSend() *gomock.Call

CloseSend indicates an expected call of CloseSend.

func (*MockExecutorApi_LeaseJobRunsClientMockRecorder) Context added in v0.3.57 

func (mr *MockExecutorApi_LeaseJobRunsClientMockRecorder) Context() *gomock.Call

Context indicates an expected call of Context.

func (*MockExecutorApi_LeaseJobRunsClientMockRecorder) Header added in v0.3.57 

func (mr *MockExecutorApi_LeaseJobRunsClientMockRecorder) Header() *gomock.Call

Header indicates an expected call of Header.

func (*MockExecutorApi_LeaseJobRunsClientMockRecorder) Recv added in v0.3.57 

func (mr *MockExecutorApi_LeaseJobRunsClientMockRecorder) Recv() *gomock.Call

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 

func (mr *MockExecutorApi_LeaseJobRunsClientMockRecorder) Trailer() *gomock.Call

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 

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) 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 

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.